com.hazelcast.spi.impl.operationservice.impl

Class AsyncInboundResponseHandler

java.lang.Object

com.hazelcast.spi.impl.operationservice.impl.AsyncInboundResponseHandler

All Implemented Interfaces:

MetricsProvider, PacketHandler

public class AsyncInboundResponseHandler
extends Object
implements PacketHandler, MetricsProvider

The AsyncInboundResponseHandler is a PacketHandler that asynchronously process operation-response packets. The actual processing is done by the InboundResponseHandler. 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.

Field Summary

Fields

Modifier and Type	Field and Description
static HazelcastProperty	IDLE_STRATEGY

Method Summary

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 registry)
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 registry)

Specified by:

provideMetrics in interface MetricsProvider

start

public void start()

shutdown

public void shutdown()

getIdleStrategy

public static IdleStrategy getIdleStrategy(HazelcastProperties properties,
                                           HazelcastProperty property)