org.apache.activemq.artemis.core.protocol.core.impl

Class ResponseCache

java.lang.Object

org.apache.activemq.artemis.core.protocol.core.impl.ResponseCache

public class ResponseCache
extends Object

Constructor Summary

Constructors

Constructor and Description
ResponseCache()

Method Summary

Modifier and Type	Method and Description
boolean	add(Packet packet)
void	errorAll(ActiveMQException exception)
void	handleResponse(Packet response)
long	nextCorrelationID()
Packet	remove(long correlationID)
void	setResponseHandler(ResponseHandler responseHandler)
int	size()

Methods inherited from class java.lang.Object

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

Constructor Detail

ResponseCache

public ResponseCache()

Method Detail

nextCorrelationID

public long nextCorrelationID()

add

public boolean add(Packet packet)

remove

public Packet remove(long correlationID)

handleResponse

public void handleResponse(Packet response)

errorAll

public void errorAll(ActiveMQException exception)

setResponseHandler

public void setResponseHandler(ResponseHandler responseHandler)

size

public int size()