Package | Description |
---|---|
com.hazelcast.client.connection.nio |
Contains classes related to New IO for com.hazelcast.client.connection
|
com.hazelcast.internal.networking |
Contains the socket connection functionality.
|
com.hazelcast.internal.networking.nio |
Contains the non blocking
EventLoopGroup functionality. |
com.hazelcast.internal.networking.spinning |
Contains the implementation of the
SpinningEventLoopGroup . |
com.hazelcast.nio.tcp |
Contains functionality for the TCP/IP Networking for cluster members
This whole package is internal and no compatibility will be provided. |
Constructor and Description |
---|
ClientConnection(HazelcastClientInstanceImpl client,
int connectionId,
Channel channel) |
Modifier and Type | Class and Description |
---|---|
class |
AbstractChannel
An abstract
Channel implementation. |
Modifier and Type | Method and Description |
---|---|
Channel |
ChannelFactory.create(SocketChannel channel,
boolean clientMode,
boolean directBuffer)
Creates the Channel.
|
Modifier and Type | Method and Description |
---|---|
InitResult<ChannelInboundHandler> |
ChannelInitializer.initInbound(Channel channel)
Called when the Channel receives the first data.
|
InitResult<ChannelOutboundHandler> |
ChannelInitializer.initOutbound(Channel channel)
Called when the Channel writes the first data.
|
void |
ChannelCloseListener.onClose(Channel channel)
Called when the channel is closed.
|
void |
ChannelErrorHandler.onError(Channel channel,
Throwable cause)
Called when an error happened.
|
void |
EventLoopGroup.register(Channel channel)
Registers a channel at this
EventLoopGroup . |
Modifier and Type | Class and Description |
---|---|
class |
NioChannel
A
Channel implementation tailored for non blocking IO using
Selector in combination with a non blocking SocketChannel . |
Modifier and Type | Field and Description |
---|---|
protected Channel |
AbstractHandler.channel |
Modifier and Type | Method and Description |
---|---|
Channel |
NioChannelFactory.create(SocketChannel channel,
boolean clientMode,
boolean directBuffer) |
Channel |
AbstractHandler.getChannel() |
Modifier and Type | Method and Description |
---|---|
void |
NioEventLoopGroup.register(Channel channel) |
Modifier and Type | Class and Description |
---|---|
class |
SpinningChannel |
Modifier and Type | Field and Description |
---|---|
protected Channel |
AbstractHandler.channel |
Modifier and Type | Method and Description |
---|---|
Channel |
SpinningChannelFactory.create(SocketChannel channel,
boolean clientMode,
boolean directBuffer) |
Channel |
AbstractHandler.getChannel() |
Modifier and Type | Method and Description |
---|---|
void |
SpinningEventLoopGroup.register(Channel channel) |
Constructor and Description |
---|
SpinningChannelReader(Channel channel,
ILogger logger,
ChannelErrorHandler errorHandler,
ChannelInitializer initializer) |
SpinningChannelWriter(Channel channel,
ILogger logger,
ChannelErrorHandler errorHandler,
ChannelInitializer initializer) |
Modifier and Type | Method and Description |
---|---|
Channel |
TcpIpConnection.getChannel() |
Modifier and Type | Method and Description |
---|---|
InitResult<ChannelInboundHandler> |
MemberChannelInitializer.initInbound(Channel channel) |
InitResult<ChannelOutboundHandler> |
MemberChannelInitializer.initOutbound(Channel channel)
called when 'client' side member connects; will call with protocol "MEMBER'
indirectly called 'server' side when the 'client' has told the protocol.
|
void |
TcpIpConnectionChannelErrorHandler.onError(Channel channel,
Throwable cause) |
Constructor and Description |
---|
TcpIpConnection(TcpIpConnectionManager connectionManager,
int connectionId,
Channel channel) |
Copyright © 2017 Hazelcast, Inc.. All Rights Reserved.