diff --git a/activemq-core/src/main/java/org/apache/activemq/transport/stomp/StompWireFormat.java b/activemq-core/src/main/java/org/apache/activemq/transport/stomp/StompWireFormat.java index 8499ac7500..cd35b2c085 100644 --- a/activemq-core/src/main/java/org/apache/activemq/transport/stomp/StompWireFormat.java +++ b/activemq-core/src/main/java/org/apache/activemq/transport/stomp/StompWireFormat.java @@ -140,7 +140,8 @@ public class StompWireFormat implements WireFormat { MessageDispatch md = (MessageDispatch)packet; Message message = md.getMessage(); Subscription sub = (Subscription) subscriptionsByConsumerId.get(md.getConsumerId()); - sub.receive(md, out); + if (sub != null) + sub.receive(md, out); } return null; } diff --git a/maven.xml b/maven.xml index d7bc5aa90a..d8925302e7 100755 --- a/maven.xml +++ b/maven.xml @@ -181,6 +181,7 @@ + There are test failures in the following modules: ${failedProj}