com.hazelcast.spi.impl.operationservice.impl

Class AsyncResponseHandler

java.lang.Object

com.hazelcast.spi.impl.operationservice.impl.AsyncResponseHandler

All Implemented Interfaces:

MetricsProvider, PacketHandler

public class AsyncResponseHandler
extends Object
implements PacketHandler, MetricsProvider

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 responseQueue of the ResponseThread. Then the ResponseThread takes it from this responseQueue 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.

Field Summary

Fields

Modifier and Type	Field and Description
static HazelcastProperty	IDLE_STRATEGY

Method Summary

Methods

Modifier and Type	Method and Description
static IdleStrategy	getIdleStrategy(HazelcastProperties properties, HazelcastProperty property)
int	getQueueSize()
void	handle(Packet packet) Signals the PacketHandler that there is a packet to be handled.
void	provideMetrics(MetricsRegistry metricsRegistry)
void	shutdown()
void	start()

Methods inherited from class java.lang.Object

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

Field Detail

IDLE_STRATEGY

public static final HazelcastProperty IDLE_STRATEGY

Method Detail

getQueueSize

public int getQueueSize()

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

provideMetrics

public void provideMetrics(MetricsRegistry metricsRegistry)

Specified by:

provideMetrics in interface MetricsProvider

start

public void start()

shutdown

public void shutdown()

getIdleStrategy

public static IdleStrategy getIdleStrategy(HazelcastProperties properties,
                           HazelcastProperty property)