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

[arnaudsimon]

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