You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by rg...@apache.org on 2014/09/08 14:28:16 UTC
svn commit: r1623371 -
/qpid/branches/0.30/qpid/java/broker-core/src/main/java/org/apache/qpid/server/exchange/DefaultDestination.java
Author: rgodfrey
Date: Mon Sep 8 12:28:16 2014
New Revision: 1623371
URL: http://svn.apache.org/r1623371
Log:
QPID-6076 : Merged revision 1622884 from trunk to 0.30
Modified:
qpid/branches/0.30/qpid/java/broker-core/src/main/java/org/apache/qpid/server/exchange/DefaultDestination.java
Modified: qpid/branches/0.30/qpid/java/broker-core/src/main/java/org/apache/qpid/server/exchange/DefaultDestination.java
URL: http://svn.apache.org/viewvc/qpid/branches/0.30/qpid/java/broker-core/src/main/java/org/apache/qpid/server/exchange/DefaultDestination.java?rev=1623371&r1=1623370&r2=1623371&view=diff
==============================================================================
--- qpid/branches/0.30/qpid/java/broker-core/src/main/java/org/apache/qpid/server/exchange/DefaultDestination.java (original)
+++ qpid/branches/0.30/qpid/java/broker-core/src/main/java/org/apache/qpid/server/exchange/DefaultDestination.java Mon Sep 8 12:28:16 2014
@@ -50,11 +50,15 @@ public class DefaultDestination implemen
public final <M extends ServerMessage<? extends StorableMessageMetaData>> int send(final M message,
- final String routingAddress,
+ String routingAddress,
final InstanceProperties instanceProperties,
final ServerTransaction txn,
final Action<? super MessageInstance> postEnqueueAction)
{
+ if(routingAddress == null)
+ {
+ routingAddress = "";
+ }
final AMQQueue q = _virtualHost.getQueue(routingAddress);
if(q == null)
{
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org