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 #3295

This commit is contained in:
Justin Bertram 2021-02-11 20:52:31 -06:00
parent 21ee5985ea a75dce9577
commit 8ff072a4e8
3 changed files with 6 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
artemis-server/src/main/java/org/apache/activemq/artemis/core/paging/impl/PagingStoreImpl.java
View File

@ -570,11 +570,12 @@ public class PagingStoreImpl implements PagingStore {
SequentialFileFactory factory = null;
try {
factory = checkFileFactory();
SequentialFile file = factory.createSequentialFile(fileName);
return file.exists();
} catch (Exception ignored) {
logger.debug("PagingStoreFactory::checkPageFileExists never-throws assumption failed.", ignored);
return false;
}
SequentialFile file = factory.createSequentialFile(fileName);
return file.exists();
}
@Override

2
artemis-server/src/main/java/org/apache/activemq/artemis/core/replication/ReplicationEndpoint.java
View File

@ -405,7 +405,7 @@ public final class ReplicationEndpoint implements ChannelHandler, ActiveMQCompon
}
}
if (this.channel != null && outgoingInterceptors != null) {
if (channel != null && outgoingInterceptors != null) {
if (channel.getConnection() instanceof RemotingConnectionImpl) {
try {
RemotingConnectionImpl impl = (RemotingConnectionImpl) channel.getConnection();

2
artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/ActiveMQServerImpl.java
View File

@ -1335,7 +1335,7 @@ public class ActiveMQServerImpl implements ActiveMQServer {
try {
securityStore.stop();
} catch (Throwable t) {
ActiveMQServerLogger.LOGGER.errorStoppingComponent(t, managementService.getClass().getName());
ActiveMQServerLogger.LOGGER.errorStoppingComponent(t, securityStore.getClass().getName());
}
}