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

This closes #3312

This commit is contained in:
Clebert Suconic 2020-10-22 12:44:42 -04:00
parent 2491bafcce b5753a0000
commit eea95e4a5a
2 changed files with 7 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/ChannelImpl.java
View File

@ -643,6 +643,10 @@ public final class ChannelImpl implements Channel {
unlock();
}
closed = true;
// unblock any blocked call:
// don't move this one before closed = true, because
// unblocked calls need to check if (closed) to "gracefully" shutdown.
returnBlocking();
}
@Override

6
artemis-server/src/main/java/org/apache/activemq/artemis/core/server/cluster/BackupManager.java
View File

@ -192,9 +192,9 @@ public class BackupManager implements ActiveMQComponent {
private TransportConfiguration connector;
protected long retryInterval;
private ClusterManager clusterManager;
private boolean stopping = false;
private boolean announcingBackup;
private boolean backupAnnounced = false;
private volatile boolean stopping = false;
private volatile boolean announcingBackup;
private volatile boolean backupAnnounced = false;
@Override
public String toString() {