mirror of https://github.com/apache/activemq.git
Merge pull request #719 from jbonofre/AMQ-8395
[AMQ-8395] Avoid possible NPE when sending advisory message
This commit is contained in:
commit
9431585553
|
@ -540,7 +540,7 @@ public class Topic extends BaseDestination implements Task {
|
||||||
|
|
||||||
message.incrementReferenceCount();
|
message.incrementReferenceCount();
|
||||||
|
|
||||||
if (context.isInTransaction()) {
|
if (context.isInTransaction() && (context.getTransaction() != null)) {
|
||||||
context.getTransaction().addSynchronization(new Synchronization() {
|
context.getTransaction().addSynchronization(new Synchronization() {
|
||||||
@Override
|
@Override
|
||||||
public void afterCommit() throws Exception {
|
public void afterCommit() throws Exception {
|
||||||
|
|
Loading…
Reference in New Issue