qpid-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From arnaudsi...@apache.org
Subject svn commit: r577330 - /incubator/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpidity/ToyBroker.java
Date Wed, 19 Sep 2007 15:23:58 GMT
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());



Mime
View raw message