diff options
Diffstat (limited to 'qpid/java/broker-core/src/main/java/org/apache/qpid/server/exchange/DefaultDestination.java')
| -rw-r--r-- | qpid/java/broker-core/src/main/java/org/apache/qpid/server/exchange/DefaultDestination.java | 6 |
1 files changed, 5 insertions, 1 deletions
diff --git a/qpid/java/broker-core/src/main/java/org/apache/qpid/server/exchange/DefaultDestination.java b/qpid/java/broker-core/src/main/java/org/apache/qpid/server/exchange/DefaultDestination.java index e9e6bbd30a..127a8d9e52 100644 --- a/qpid/java/broker-core/src/main/java/org/apache/qpid/server/exchange/DefaultDestination.java +++ b/qpid/java/broker-core/src/main/java/org/apache/qpid/server/exchange/DefaultDestination.java @@ -50,11 +50,15 @@ public class DefaultDestination implements MessageDestination 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) { |