com.hazelcast.spi.impl.operationservice.impl

Class InboundResponseHandler

java.lang.Object

com.hazelcast.spi.impl.operationservice.impl.InboundResponseHandler

All Implemented Interfaces:

Consumer<Packet>

public final class InboundResponseHandler
extends Object
implements Consumer<Packet>

Responsible for handling responses for invocations. Based on the content of the response packet, it will lookup the Invocation from the InvocationRegistry and notify the Invocation. InboundResponseHandlers are not thread-safe. So if there are multiple threads processing responses, each thread needs to get its own instance. Only the backup handling is thread-safe since backups can be completed locally by any thread.

Method Summary

Modifier and Type	Method and Description
void	accept(Packet packet) Performs this operation on the given argument.
void	notifyBackupComplete(long callId)

Methods inherited from class java.lang.Object

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

Method Detail

accept

public void accept(Packet packet)

Description copied from interface: Consumer

Performs this operation on the given argument.

Specified by:

accept in interface Consumer<Packet>

Parameters:

packet - the input argument

notifyBackupComplete

public void notifyBackupComplete(long callId)