Author: rhs
Date: Sun Nov 1 12:36:35 2009
New Revision: 831671
URL: http://svn.apache.org/viewvc?rev=831671&view=rev
Log:
ensure only passive declares of amq.* exchanges
Modified:
qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/BasicMessageProducer_0_10.java
Modified:
qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/BasicMessageProducer_0_10.java
URL:
http://svn.apache.org/viewvc/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/BasicMessageProducer_0_10.java?rev=831671&r1=831670&r2=831671&view=diff
==============================================================================
---
qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/BasicMessageProducer_0_10.java
(original)
+++
qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/BasicMessageProducer_0_10.java
Sun Nov 1 12:36:35 2009
@@ -59,9 +59,12 @@
void declareDestination(AMQDestination destination)
{
- ((AMQSession_0_10)
getSession()).getQpidSession().exchangeDeclare(destination.getExchangeName().toString(),
-
destination.getExchangeClass().toString(),
-
null, null);
+ String name = destination.getExchangeName().toString();
+ ((AMQSession_0_10) getSession()).getQpidSession().exchangeDeclare
+ (name,
+ destination.getExchangeClass().toString(),
+ null, null,
+ name.startsWith("amq.") ? Option.PASSIVE : Option.NONE);
}
//--- Overwritten methods
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:commits-subscr...@qpid.apache.org
