java.lang.Object
org.apache.activemq.artemis.core.protocol.core.impl.ResponseCache

public class ResponseCache extends Object
  • 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()