Package | Description |
---|---|
com.hazelcast.client.connection.nio |
Contains classes related to New IO for com.hazelcast.client.connection
|
com.hazelcast.client.impl.protocol.util |
Protocol utils
|
com.hazelcast.instance |
This package contains Hazelcast Instance functionality.
|
com.hazelcast.internal.networking |
Contains the socket connection functionality.
|
com.hazelcast.internal.networking.nio |
Contains the non blocking
Networking functionality. |
com.hazelcast.nio |
This package contains classes related to New IO
|
com.hazelcast.nio.ascii |
Contains SocketTextReader and SocketTextWriter classes;
|
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. |
Modifier and Type | Class and Description |
---|---|
class |
ClientProtocolEncoder
A
OutboundHandler that writes the client protocol bytes
and once they have been fully written, it removes itself from pipeline. |
Modifier and Type | Class and Description |
---|---|
class |
ClientMessageEncoder
A
OutboundHandler for the new-client. |
Modifier and Type | Method and Description |
---|---|
OutboundHandler[] |
DefaultNodeExtension.createOutboundHandlers(EndpointQualifier qualifier,
TcpIpConnection connection,
IOService ioService) |
OutboundHandler[] |
NodeExtension.createOutboundHandlers(EndpointQualifier qualifier,
TcpIpConnection connection,
IOService ioService)
Creates a OutboundHandler for given Connection instance.
|
Modifier and Type | Method and Description |
---|---|
OutboundPipeline |
OutboundPipeline.addLast(OutboundHandler... handlers)
Adds the handlers at the end of the pipeline
No verification is done if the handler is already added and a handler
should only be added once.
|
OutboundPipeline |
OutboundPipeline.remove(OutboundHandler handler)
Removes the given handler from the pipeline.
|
OutboundPipeline |
OutboundPipeline.replace(OutboundHandler oldHandler,
OutboundHandler... newHandlers)
Replaces the old OutboundHandler by the new ones.
|
OutboundPipeline |
OutboundPipeline.replace(OutboundHandler oldHandler,
OutboundHandler... newHandlers)
Replaces the old OutboundHandler by the new ones.
|
Modifier and Type | Method and Description |
---|---|
OutboundPipeline |
NioOutboundPipeline.addLast(OutboundHandler... addedHandlers) |
OutboundPipeline |
NioOutboundPipeline.remove(OutboundHandler handler) |
OutboundPipeline |
NioOutboundPipeline.replace(OutboundHandler oldHandler,
OutboundHandler... addedHandlers) |
OutboundPipeline |
NioOutboundPipeline.replace(OutboundHandler oldHandler,
OutboundHandler... addedHandlers) |
Modifier and Type | Method and Description |
---|---|
OutboundHandler[] |
NodeIOService.createOutboundHandlers(EndpointQualifier qualifier,
TcpIpConnection connection) |
OutboundHandler[] |
IOService.createOutboundHandlers(EndpointQualifier qualifier,
TcpIpConnection connection) |
Modifier and Type | Class and Description |
---|---|
class |
TextEncoder |
Modifier and Type | Class and Description |
---|---|
class |
MemberProtocolEncoder |
class |
PacketEncoder
A
OutboundHandler that for member to member communication. |
class |
UnifiedProtocolEncoder
The ProtocolEncoder is responsible for writing the protocol and once the protocol
has been written, the ProtocolEncoder is replaced by the appropriate handler.
|
Constructor and Description |
---|
MemberProtocolEncoder(OutboundHandler[] next)
Decodes first 3 incoming bytes, validates against
supportedProtocol and, when
matching, replaces itself in the inbound pipeline with the next InboundHandler . |
Copyright © 2022 Hazelcast, Inc.. All Rights Reserved.