diff options
Diffstat (limited to 'java/newclient/src/main/java/org/apache/qpid/nclient/api/QpidMessageConsumer.java')
| -rw-r--r-- | java/newclient/src/main/java/org/apache/qpid/nclient/api/QpidMessageConsumer.java | 6 |
1 files changed, 6 insertions, 0 deletions
diff --git a/java/newclient/src/main/java/org/apache/qpid/nclient/api/QpidMessageConsumer.java b/java/newclient/src/main/java/org/apache/qpid/nclient/api/QpidMessageConsumer.java index 41adc23727..3053fc3ddc 100644 --- a/java/newclient/src/main/java/org/apache/qpid/nclient/api/QpidMessageConsumer.java +++ b/java/newclient/src/main/java/org/apache/qpid/nclient/api/QpidMessageConsumer.java @@ -31,4 +31,10 @@ public interface QpidMessageConsumer public AMQPApplicationMessage receive()throws QpidException; public AMQPApplicationMessage receive(long timeout, TimeUnit tu)throws QpidException; + + public void messageArrived(AMQPApplicationMessage msg)throws QpidException; + + public void open() throws QpidException; + + public void close() throws QpidException; } |