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/06 18:34:09 UTC
svn commit: r1622884 -
/qpid/trunk/qpid/java/broker-core/src/main/java/org/apache/qpid/server/exchange/DefaultDestination.java
Author: rgodfrey
Date: Sat Sep 6 16:34:09 2014
New Revision: 1622884
URL: http://svn.apache.org/r1622884
Log:
QPID-6076 : Sending a message with no routing key to the default exchange in the java broker results in an NPE
Modified:
qpid/trunk/qpid/java/broker-core/src/main/java/org/apache/qpid/server/exchange/DefaultDestination.java
Modified: qpid/trunk/qpid/java/broker-core/src/main/java/org/apache/qpid/server/exchange/DefaultDestination.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/broker-core/src/main/java/org/apache/qpid/server/exchange/DefaultDestination.java?rev=1622884&r1=1622883&r2=1622884&view=diff
==============================================================================
--- qpid/trunk/qpid/java/broker-core/src/main/java/org/apache/qpid/server/exchange/DefaultDestination.java (original)
+++ qpid/trunk/qpid/java/broker-core/src/main/java/org/apache/qpid/server/exchange/DefaultDestination.java Sat Sep 6 16:34:09 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