Merge pull request #696 from jbonofre/AMQ-8138

[AMQ-8138] Set client IP address with Stomp host header
This commit is contained in:
Jean-Baptiste Onofré 2021-08-03 15:12:57 +02:00 committed by GitHub
commit 0348938952
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 2 additions and 0 deletions

View File

@ -752,6 +752,7 @@ public class ProtocolConverter {
String passcode = headers.get(Stomp.Headers.Connect.PASSCODE);
String clientId = headers.get(Stomp.Headers.Connect.CLIENT_ID);
String heartBeat = headers.get(Stomp.Headers.Connect.HEART_BEAT);
String host = headers.get(Stomp.Headers.Connect.HOST);
if (heartBeat == null) {
heartBeat = defaultHeartBeat;
@ -768,6 +769,7 @@ public class ProtocolConverter {
} else {
connectionInfo.setClientId("" + connectionInfo.getConnectionId().toString());
}
connectionInfo.setClientIp(host);
connectionInfo.setResponseRequired(true);
connectionInfo.setUserName(login);