| Package | Description | 
|---|---|
| com.hazelcast.nio | 
 This package contains classes related to New IO 
 | 
| 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.  | 
| com.hazelcast.spi.impl | 
 Contains implementations for Hazelcast SPI. 
 | 
| com.hazelcast.spi.impl.eventservice.impl | 
 Contains the code for the  
InternalEventService implementation. | 
| com.hazelcast.spi.impl.operationexecutor | 
 Contains the  
OperationRunner code. | 
| com.hazelcast.spi.impl.operationexecutor.impl | 
 Contains the  
OperationExecutorImpl code. | 
| com.hazelcast.spi.impl.operationservice.impl | 
 Contains the code for the  
InternalOperationService implementation. | 
| Modifier and Type | Method and Description | 
|---|---|
Packet | 
Packet.raiseFlags(int flagsToRaise)
Raises all the flags raised in the argument. 
 | 
Packet | 
PacketIOHelper.readFrom(ByteBuffer src)
Reads the packet data from the supplied  
ByteBuffer. | 
Packet | 
Packet.resetFlagsTo(int flagsToSet)
Resets the entire  
flags bitfield to the supplied value. | 
Packet | 
Packet.setConn(Connection conn)
Sets the Connection this Packet is send with. 
 | 
Packet | 
Packet.setPacketType(Packet.Type type)
Sets the packet type by updating the packet type bits in the  
flags bitfield. | 
| Modifier and Type | Method and Description | 
|---|---|
boolean | 
ConnectionManager.transmit(Packet packet,
        Address target)
Transmits a packet to a certain address. 
 | 
boolean | 
ConnectionManager.transmit(Packet packet,
        Connection connection)
Transmits a packet to a certain connection. 
 | 
boolean | 
PacketIOHelper.writeTo(Packet packet,
       ByteBuffer dst)
Writes the packet data to the supplied  
ByteBuffer, up to the buffer's limit. | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
TcpIpConnectionManager.accept(Packet packet)  | 
protected void | 
PacketDecoder.onPacketComplete(Packet packet)  | 
boolean | 
TcpIpConnectionManager.transmit(Packet packet,
        Address target)
Retries sending packet maximum 5 times until connection to target becomes available. 
 | 
boolean | 
TcpIpConnectionManager.transmit(Packet packet,
        Connection connection)  | 
| Constructor and Description | 
|---|
PacketDecoder(TcpIpConnection connection,
             Consumer<Packet> dst)  | 
| Modifier and Type | Method and Description | 
|---|---|
Consumer<Packet> | 
NodeEngineImpl.getPacketDispatcher()  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
PacketDispatcher.accept(Packet packet)  | 
| Constructor and Description | 
|---|
PacketDispatcher(ILogger logger,
                Consumer<Packet> operationExecutor,
                Consumer<Packet> responseHandler,
                Consumer<Packet> invocationMonitor,
                Consumer<Packet> eventService,
                Consumer<Packet> connectionManager,
                Consumer<Packet> jetService)  | 
PacketDispatcher(ILogger logger,
                Consumer<Packet> operationExecutor,
                Consumer<Packet> responseHandler,
                Consumer<Packet> invocationMonitor,
                Consumer<Packet> eventService,
                Consumer<Packet> connectionManager,
                Consumer<Packet> jetService)  | 
PacketDispatcher(ILogger logger,
                Consumer<Packet> operationExecutor,
                Consumer<Packet> responseHandler,
                Consumer<Packet> invocationMonitor,
                Consumer<Packet> eventService,
                Consumer<Packet> connectionManager,
                Consumer<Packet> jetService)  | 
PacketDispatcher(ILogger logger,
                Consumer<Packet> operationExecutor,
                Consumer<Packet> responseHandler,
                Consumer<Packet> invocationMonitor,
                Consumer<Packet> eventService,
                Consumer<Packet> connectionManager,
                Consumer<Packet> jetService)  | 
PacketDispatcher(ILogger logger,
                Consumer<Packet> operationExecutor,
                Consumer<Packet> responseHandler,
                Consumer<Packet> invocationMonitor,
                Consumer<Packet> eventService,
                Consumer<Packet> connectionManager,
                Consumer<Packet> jetService)  | 
PacketDispatcher(ILogger logger,
                Consumer<Packet> operationExecutor,
                Consumer<Packet> responseHandler,
                Consumer<Packet> invocationMonitor,
                Consumer<Packet> eventService,
                Consumer<Packet> connectionManager,
                Consumer<Packet> jetService)  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
EventServiceImpl.accept(Packet packet)
Performs this operation on the given argument. 
 | 
| Constructor and Description | 
|---|
RemoteEventProcessor(EventServiceImpl eventService,
                    Packet packet)  | 
| Modifier and Type | Method and Description | 
|---|---|
abstract void | 
OperationRunner.run(Packet packet)  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
OperationExecutorImpl.accept(Packet packet)  | 
| Modifier and Type | Method and Description | 
|---|---|
Consumer<Packet> | 
InboundResponseHandlerSupplier.get()  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
InvocationMonitor.accept(Packet packet)  | 
void | 
InboundResponseHandler.accept(Packet packet)  | 
Copyright © 2020 Hazelcast, Inc.. All Rights Reserved.