Apache/activemq-artemis
1
0
Fork 0
mirror of https://github.com/apache/activemq-artemis.git synced 2025-02-08 11:05:34 +00:00
Code Issues Packages Projects Releases Wiki Activity

This closes #3182

Browse Source
This commit is contained in:
Clebert Suconic 2020-06-15 09:28:43 -04:00
commit 8fe1bb1c83
2 changed files with 11 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
artemis-server/src/main/java/org/apache/activemq/artemis/core/server/ActiveMQServerLogger.java
View File

@ -1687,6 +1687,11 @@ public interface ActiveMQServerLogger extends BasicLogger {
format = Message.Format.MESSAGE_FORMAT) format = Message.Format.MESSAGE_FORMAT)
void noMatchingBindingsOnDLAWithAutoCreateDLAResources(SimpleString address, String message); void noMatchingBindingsOnDLAWithAutoCreateDLAResources(SimpleString address, String message);
@LogMessage(level = Logger.Level.WARN)
@Message(id = 222290, value = "Failed to find cluster-connection when handling cluster-connect packet. Ignoring: {0}",
format = Message.Format.MESSAGE_FORMAT)
void failedToFindClusterConnection(String packet);
@LogMessage(level = Logger.Level.ERROR) @LogMessage(level = Logger.Level.ERROR)
@Message(id = 224000, value = "Failure in initialisation", format = Message.Format.MESSAGE_FORMAT) @Message(id = 224000, value = "Failure in initialisation", format = Message.Format.MESSAGE_FORMAT)
void initializationError(@Cause Throwable e); void initializationError(@Cause Throwable e);

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

@ -359,6 +359,12 @@ public class ClusterController implements ActiveMQComponent {
clusterConnection = server.getClusterManager().getDefaultConnection(null); clusterConnection = server.getClusterManager().getDefaultConnection(null);
} }
//if there is no default cluster connection then just ignore the packet with a log message
if (clusterConnection == null) {
ActiveMQServerLogger.LOGGER.failedToFindClusterConnection(packet.toString());
return;
}
ClusterConnectMessage msg = (ClusterConnectMessage) packet; ClusterConnectMessage msg = (ClusterConnectMessage) packet;
if (server.getConfiguration().isSecurityEnabled() && !clusterConnection.verify(msg.getClusterUser(), msg.getClusterPassword())) { if (server.getConfiguration().isSecurityEnabled() && !clusterConnection.verify(msg.getClusterUser(), msg.getClusterPassword())) {