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 |
---|---|
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 |
Channel.outboundPipeline()
Returns the
OutboundPipeline that belongs to this Channel. |
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.wakeup()
Request to flush all data to flush from the handlers to
the network.
|
Modifier and Type | Class and Description |
---|---|
class |
NioOutboundPipeline |
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.wakeup() |
Copyright © 2020 Hazelcast, Inc.. All Rights Reserved.