diff options
| author | Arnaud Simon <arnaudsimon@apache.org> | 2007-09-19 15:23:58 +0000 |
|---|---|---|
| committer | Arnaud Simon <arnaudsimon@apache.org> | 2007-09-19 15:23:58 +0000 |
| commit | df9985518ead7ebde7322e690a2c475524dbcd87 (patch) | |
| tree | c7060e4005c41b559ac7af89acf14fdd82b91501 /java/common/src | |
| parent | 79d0c1361620c718574368c8e028073232228dfc (diff) | |
| download | qpid-python-df9985518ead7ebde7322e690a2c475524dbcd87.tar.gz | |
added messageAcquire method
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@577330 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'java/common/src')
| -rw-r--r-- | java/common/src/main/java/org/apache/qpidity/ToyBroker.java | 6 |
1 files changed, 6 insertions, 0 deletions
diff --git a/java/common/src/main/java/org/apache/qpidity/ToyBroker.java b/java/common/src/main/java/org/apache/qpidity/ToyBroker.java index f69b72227c..5aff49cb16 100644 --- a/java/common/src/main/java/org/apache/qpidity/ToyBroker.java +++ b/java/common/src/main/java/org/apache/qpidity/ToyBroker.java @@ -56,6 +56,12 @@ class ToyBroker extends SessionDelegate 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()); |