mirror of https://github.com/apache/activemq.git
check for null message in MessageDispatch
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@636281 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
parent
c6b88f1ecc
commit
a9ccf5623d
|
@ -564,7 +564,7 @@ public abstract class DemandForwardingBridgeSupport implements NetworkBridge {
|
|||
//localStartedLatch.await();
|
||||
final MessageDispatch md = (MessageDispatch)command;
|
||||
DemandSubscription sub = subscriptionMapByLocalId.get(md.getConsumerId());
|
||||
if (sub != null) {
|
||||
if (sub != null && md.getMessage()!=null) {
|
||||
Message message = configureMessage(md);
|
||||
if (trace) {
|
||||
LOG.trace("bridging " + configuration.getBrokerName() + " -> " + remoteBrokerName + ": " + message);
|
||||
|
|
Loading…
Reference in New Issue