Package | Description |
---|---|
com.hazelcast.internal.networking |
Contains the socket connection functionality.
|
com.hazelcast.internal.networking.nio |
Contains the non blocking
Networking functionality. |
Modifier and Type | Method and Description |
---|---|
InboundPipeline |
InboundPipeline.addLast(InboundHandler... handlers)
Adds the handlers at the end of the pipeline.
|
InboundPipeline |
Channel.inboundPipeline()
Returns the
InboundPipeline that belongs to this Channel. |
InboundPipeline |
InboundPipeline.remove(InboundHandler handler)
Removes the given handler from the pipeline.
|
InboundPipeline |
InboundPipeline.replace(InboundHandler oldHandler,
InboundHandler... newHandlers)
Replaces the old InboundHandler by the new ones.
|
InboundPipeline |
InboundPipeline.wakeup()
Wakes up the inbound pipeline and lets it to start reading again from the
network.
|
Modifier and Type | Class and Description |
---|---|
class |
NioInboundPipeline
When the
NioThread receives a read event from the
Selector , then the NioInboundPipeline.process() is called to read
out the data from the socket into a bytebuffer and hand it over to the
InboundHandler to get processed. |
Modifier and Type | Method and Description |
---|---|
InboundPipeline |
NioInboundPipeline.addLast(InboundHandler... addedHandlers) |
InboundPipeline |
NioInboundPipeline.remove(InboundHandler handler) |
InboundPipeline |
NioInboundPipeline.replace(InboundHandler oldHandler,
InboundHandler... addedHandlers) |
Copyright © 2022 Hazelcast, Inc.. All Rights Reserved.