From 032db1f5a1cbff8d7467fc7acc6ea7efa3d4f0ce Mon Sep 17 00:00:00 2001 From: Rajith Muditha Attapattu Date: Wed, 5 Dec 2012 23:17:40 +0000 Subject: NO-JIRA added consumer.close() and producer.close() to Drain and Spout. This allows proper demonstration of the delete keyword in addressing. Allthough session.close() does call consumer and producer close, the session is marked closed, thereby preventing the qeueue or exchange delete being sent. This is a safety mechanism to prevent a deadlock situation in the client. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1417692 13f79535-47bb-0310-9956-ffa450edef68 --- .../client/example/src/main/java/org/apache/qpid/example/Drain.java | 2 +- .../client/example/src/main/java/org/apache/qpid/example/Spout.java | 1 + 2 files changed, 2 insertions(+), 1 deletion(-) (limited to 'qpid/java/client/example') diff --git a/qpid/java/client/example/src/main/java/org/apache/qpid/example/Drain.java b/qpid/java/client/example/src/main/java/org/apache/qpid/example/Drain.java index 28e1d5a87e..f0eb83ad24 100644 --- a/qpid/java/client/example/src/main/java/org/apache/qpid/example/Drain.java +++ b/qpid/java/client/example/src/main/java/org/apache/qpid/example/Drain.java @@ -88,7 +88,7 @@ public class Drain extends OptionParser } } } - + consumer.close(); ssn.close(); con.close(); } diff --git a/qpid/java/client/example/src/main/java/org/apache/qpid/example/Spout.java b/qpid/java/client/example/src/main/java/org/apache/qpid/example/Spout.java index 61ff2dfc19..09e813f8c1 100644 --- a/qpid/java/client/example/src/main/java/org/apache/qpid/example/Spout.java +++ b/qpid/java/client/example/src/main/java/org/apache/qpid/example/Spout.java @@ -100,6 +100,7 @@ public class Spout extends OptionParser System.out.println(msg); System.out.println("-------------------------------\n"); } + producer.close(); ssn.close(); con.close(); } -- cgit v1.2.1