Package 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	Description
ResponseCache()

Method Summary

Modifier and Type	Method	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 Details

ResponseCache

public ResponseCache()

Method Details

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