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