Apache
/
activemq
mirror of https://github.com/apache/activemq.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

[AMQ-7401] This closes #447

This commit is contained in:
jbonofre 2020-02-10 19:08:14 +01:00
parent 78826c9c73 dac97e6294
commit ff02246478
2 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
activemq-client/src/main/java/org/apache/activemq/ActiveMQConnection.java
View File

@ -199,7 +199,7 @@ public class ActiveMQConnection implements Connection, TopicConnection, QueueCon
private boolean useDedicatedTaskRunner;
protected AtomicInteger transportInterruptionProcessingComplete = new AtomicInteger(0);
private long consumerFailoverRedeliveryWaitPeriod;
private Scheduler scheduler;
private volatile Scheduler scheduler;
private boolean messagePrioritySupported = false;
private boolean transactedIndividualAck = false;
private boolean nonBlockingRedelivery = false;

6
activemq-jms-pool/src/main/java/org/apache/activemq/jms/pool/SessionHolder.java
View File

@ -33,9 +33,9 @@ import javax.jms.TopicSession;
public class SessionHolder {
private final Session session;
private MessageProducer producer;
private TopicPublisher publisher;
private QueueSender sender;
private volatile MessageProducer producer;
private volatile TopicPublisher publisher;
private volatile QueueSender sender;
public SessionHolder(Session session) {
this.session = session;