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 2010/07/29 00:47:10 UTC
svn commit: r980259 -
/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/messaging/address/AddressHelper.java
Author: rajith
Date: Wed Jul 28 22:47:10 2010
New Revision: 980259
URL: http://svn.apache.org/viewvc?rev=980259&view=rev
Log:
QPID-2774
If the exchange type is not specified, then it is set to null when parsing the string.
If the exchange needs to be created, it's set to 'topic' if the exchange type is null.
Modified:
qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/messaging/address/AddressHelper.java
Modified: qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/messaging/address/AddressHelper.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/messaging/address/AddressHelper.java?rev=980259&r1=980258&r2=980259&view=diff
==============================================================================
--- qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/messaging/address/AddressHelper.java (original)
+++ qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/messaging/address/AddressHelper.java Wed Jul 28 22:47:10 2010
@@ -27,6 +27,7 @@ import java.util.Map;
import org.apache.qpid.client.AMQDestination;
import org.apache.qpid.client.AMQDestination.Binding;
+import org.apache.qpid.client.messaging.address.Link.Reliability;
import org.apache.qpid.client.messaging.address.Node.ExchangeNode;
import org.apache.qpid.client.messaging.address.Node.QueueNode;
import org.apache.qpid.client.messaging.address.Node.UnknownNodeType;
@@ -257,7 +258,7 @@ public class AddressHelper
MapAccessor argsMap = new MapAccessor(declareArgs);
ExchangeNode node = new ExchangeNode();
node.setExchangeType(argsMap.getString(TYPE) == null?
- "topic":argsMap.getString(TYPE));
+ null:argsMap.getString(TYPE));
node.setDeclareArgs(getQpidExchangeOptions(argsMap));
fillInCommonNodeArgs(node,parent,argsMap);
return node;
@@ -316,7 +317,7 @@ public class AddressHelper
{
link.setDurable(linkProps.getBoolean(DURABLE)== null? false : linkProps.getBoolean(DURABLE));
link.setName(linkProps.getString(NAME));
-
+
if (((Map)address.getOptions().get(LINK)).get(CAPACITY) instanceof Map)
{
MapAccessor capacityProps = new MapAccessor(
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:commits-subscribe@qpid.apache.org