| 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 © 2020 Hazelcast, Inc.. All Rights Reserved.