You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by ar...@apache.org on 2007/09/19 17:23:58 UTC

svn commit: r577330 - /incubator/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpidity/ToyBroker.java

Author: arnaudsimon
Date: Wed Sep 19 08:23:58 2007
New Revision: 577330

URL: http://svn.apache.org/viewvc?rev=577330&view=rev
Log:
added messageAcquire method 

Modified:
    incubator/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpidity/ToyBroker.java

Modified: incubator/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpidity/ToyBroker.java
URL: http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpidity/ToyBroker.java?rev=577330&r1=577329&r2=577330&view=diff
==============================================================================
--- incubator/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpidity/ToyBroker.java (original)
+++ incubator/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpidity/ToyBroker.java Wed Sep 19 08:23:58 2007
@@ -56,6 +56,12 @@
         this.exchange = exchange;
     }
 
+    public void messageAcquire(Session context, MessageAcquire struct)
+    {
+        System.out.println("\n==================> messageAcquire " );
+        context.messageAcquired(struct.getTransfers());
+    }
+
     @Override public void queueDeclare(Session ssn, QueueDeclare qd)
     {
         exchange.createQueue(qd.getQueue());