org.apache.activemq.transport.tcp: public class: ResponseHolder

org.apache.activemq.transport.tcp
public class: ResponseHolder [javadoc | source]

java.lang.Object
   org.apache.activemq.transport.tcp.ResponseHolder

ResponseHolder utility

version: $ - Revision: 1.1.1.1 $

Field Summary
protected Response	response
protected Object	lock
protected boolean	notified

Constructor:
public ResponseHolder() { } Construct a receipt holder

Constructor:

 public ResponseHolder() {

}

Construct a receipt holder

Method from org.apache.activemq.transport.tcp.ResponseHolder Summary:
close, getResponse, getResponse, setResponse

Methods from java.lang.Object:
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method from org.apache.activemq.transport.tcp.ResponseHolder Detail:
public void close() { synchronized (lock) { notified = true; lock.notifyAll(); } } close this holder
public Response getResponse() { return getResponse(0); } Get the Response
public Response getResponse(int timeout) { synchronized (lock) { if (!notified) { try { lock.wait(timeout); } catch (InterruptedException e) { Thread.currentThread().interrupt(); } } } return this.response; } wait upto `timeout` timeout ms to get a receipt
public void setResponse(Response r) { synchronized (lock) { this.response = r; notified = true; lock.notify(); } } Set the Response for this holder

Method from org.apache.activemq.transport.tcp.ResponseHolder Detail:

 public  void close() {
        synchronized (lock) {
            notified = true;
            lock.notifyAll();
        }
}

close this holder

 public Response getResponse() {
        return getResponse(0);
}

Get the Response

 public Response getResponse(int timeout) {
        synchronized (lock) {
            if (!notified) {
                try {
                    lock.wait(timeout);
                } catch (InterruptedException e) {
                    Thread.currentThread().interrupt();
                }
            }
        }
        return this.response;
}

timeout

 public  void setResponse(Response r) {
        synchronized (lock) {
            this.response = r;
            notified = true;
            lock.notify();
        }
}

Set the Response for this holder