Apache/activemq-artemis
1
0
Fork 0
mirror of https://github.com/apache/activemq-artemis.git synced 2025-02-23 18:57:14 +00:00
Code Issues Packages Projects Releases Wiki Activity

NO-JIRA fixing another test

Browse Source 
test failing: org.apache.activemq.artemis.tests.integration.management.AddressControlTest.testSendMessage
This commit is contained in:
Clebert Suconic 2019-03-12 20:21:03 -04:00
parent 564b75d66f
commit 3473618a06
2 changed files with 4 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
artemis-server/src/main/java/org/apache/activemq/artemis/core/management/impl/AddressControlImpl.java
View File

@ -307,6 +307,7 @@ public class AddressControlImpl extends AbstractControl implements AddressContro
try {
return sendMessage(addressInfo.getName(), server, headers, type, body, durable, user, password);
} catch (Exception e) {
e.printStackTrace();
throw new IllegalStateException(e.getMessage());
}
}

4
artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/ServerSessionImpl.java
View File

@ -435,7 +435,9 @@ public class ServerSessionImpl implements ServerSession, FailureListener {
private void sendSessionNotification(final CoreNotificationType type) throws Exception {
final TypedProperties props = new TypedProperties();
props.putSimpleStringProperty(ManagementHelper.HDR_CONNECTION_NAME, SimpleString.toSimpleString(this.getConnectionID().toString()));
if (this.getConnectionID() != null) {
props.putSimpleStringProperty(ManagementHelper.HDR_CONNECTION_NAME, SimpleString.toSimpleString(this.getConnectionID().toString()));
}
props.putSimpleStringProperty(ManagementHelper.HDR_USER, SimpleString.toSimpleString(this.getUsername()));
props.putSimpleStringProperty(ManagementHelper.HDR_SESSION_NAME, SimpleString.toSimpleString(this.getName()));