com.hazelcast.spi.impl.transceiver.impl

Class PacketTransceiverImpl

java.lang.Object

com.hazelcast.spi.impl.transceiver.impl.PacketTransceiverImpl

All Implemented Interfaces:

PacketTransceiver

public class PacketTransceiverImpl
extends Object
implements PacketTransceiver

Default PacketTransceiver implementation.

Constructor Summary

Constructors

Constructor and Description
PacketTransceiverImpl(Node node, ILogger logger, InternalOperationService operationService, InternalEventService eventService, WanReplicationService wanReplicationService, ExecutionService executionService)

Method Summary

Methods

Modifier and Type	Method and Description
void	receive(Packet packet) Lets the PacketTransceiver receive a packet.
boolean	transmit(Packet packet, Address target) Retries sending packet maximum 5 times until connection to target becomes available.
boolean	transmit(Packet packet, Connection connection) Transmits a packet to a certain connection.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

PacketTransceiverImpl

public PacketTransceiverImpl(Node node,
                     ILogger logger,
                     InternalOperationService operationService,
                     InternalEventService eventService,
                     WanReplicationService wanReplicationService,
                     ExecutionService executionService)

Method Detail

transmit

public boolean transmit(Packet packet,
               Connection connection)

Description copied from interface: PacketTransceiver

Transmits a packet to a certain connection.

Specified by:

transmit in interface PacketTransceiver

Parameters:

packet - The Packet to transmit.

connection - The connection to where the Packet should be transmitted.

Returns:

true if the transmit was a success, false if a failure. There is no guarantee that the packet is actually going to be received since the Packet perhaps is stuck in some buffer. It just means that it is buffered somewhere.

receive

public void receive(Packet packet)

Description copied from interface: PacketTransceiver

Lets the PacketTransceiver receive a packet. This method is likely going to be called from the IO system when it takes a Packet of the wire and offers it to be processed by the system. This is where the dispatching (demultiplexing) to the appropriate services takes place.

Specified by:

receive in interface PacketTransceiver

Parameters:

packet - the Packet to receive.

transmit

public boolean transmit(Packet packet,
               Address target)

Retries sending packet maximum 5 times until connection to target becomes available.

Specified by:

transmit in interface PacketTransceiver

Parameters:

packet - The Packet to transmit.

target - The address of the target machine where the Packet should be transmitted.

Returns:

true if the transmit was a success, false if a failure.

See Also:

PacketTransceiver.transmit(com.hazelcast.nio.Packet, com.hazelcast.nio.Connection)