com.hazelcast.spi.impl.operationservice.impl

Class AsyncResponsePacketHandler

java.lang.Object

com.hazelcast.spi.impl.operationservice.impl.AsyncResponsePacketHandler

All Implemented Interfaces:

PacketHandler

public class AsyncResponsePacketHandler
extends Object
implements PacketHandler

The AsyncResponsePacketHandler is a PacketHandler that asynchronously process operation-response packets. So when a response is received from a remote system, it is put in the workQueue of the ResponseThread. Then the ResponseThread takes it from this workQueue and calls the PacketHandler for the actual processing. The reason that the IO thread doesn't immediately deals with the response is that deserializing the Response and let the invocation-future deal with the response can be rather expensive currently.

Constructor Summary

Constructors

Constructor and Description
AsyncResponsePacketHandler(HazelcastThreadGroup threadGroup, ILogger logger, PacketHandler responsePacketHandler)

Method Summary

Methods

Modifier and Type	Method and Description
int	getQueueSize()
void	handle(Packet packet) Signals the PacketHandler that there is a packet to be handled.
void	shutdown()

Methods inherited from class java.lang.Object

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

Constructor Detail

AsyncResponsePacketHandler

public AsyncResponsePacketHandler(HazelcastThreadGroup threadGroup,
                          ILogger logger,
                          PacketHandler responsePacketHandler)

Method Detail

getQueueSize

public int getQueueSize()

shutdown

public void shutdown()

handle

public void handle(Packet packet)

Description copied from interface: PacketHandler

Signals the PacketHandler that there is a packet to be handled.

Specified by:

handle in interface PacketHandler

Parameters:

packet - the response packet to handle