You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by ra...@apache.org on 2012/12/06 00:17:41 UTC
svn commit: r1417692 - in
/qpid/trunk/qpid/java/client/example/src/main/java/org/apache/qpid/example:
Drain.java Spout.java
Author: rajith
Date: Wed Dec 5 23:17:40 2012
New Revision: 1417692
URL: http://svn.apache.org/viewvc?rev=1417692&view=rev
Log:
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.
Modified:
qpid/trunk/qpid/java/client/example/src/main/java/org/apache/qpid/example/Drain.java
qpid/trunk/qpid/java/client/example/src/main/java/org/apache/qpid/example/Spout.java
Modified: qpid/trunk/qpid/java/client/example/src/main/java/org/apache/qpid/example/Drain.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/client/example/src/main/java/org/apache/qpid/example/Drain.java?rev=1417692&r1=1417691&r2=1417692&view=diff
==============================================================================
--- qpid/trunk/qpid/java/client/example/src/main/java/org/apache/qpid/example/Drain.java (original)
+++ qpid/trunk/qpid/java/client/example/src/main/java/org/apache/qpid/example/Drain.java Wed Dec 5 23:17:40 2012
@@ -88,7 +88,7 @@ public class Drain extends OptionParser
}
}
}
-
+ consumer.close();
ssn.close();
con.close();
}
Modified: qpid/trunk/qpid/java/client/example/src/main/java/org/apache/qpid/example/Spout.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/client/example/src/main/java/org/apache/qpid/example/Spout.java?rev=1417692&r1=1417691&r2=1417692&view=diff
==============================================================================
--- qpid/trunk/qpid/java/client/example/src/main/java/org/apache/qpid/example/Spout.java (original)
+++ qpid/trunk/qpid/java/client/example/src/main/java/org/apache/qpid/example/Spout.java Wed Dec 5 23:17:40 2012
@@ -100,6 +100,7 @@ public class Spout extends OptionParser
System.out.println(msg);
System.out.println("-------------------------------\n");
}
+ producer.close();
ssn.close();
con.close();
}
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org