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

[AMQ-8138] Set client IP address with Stomp host header 

(cherry picked from commit 2e169f0bc3)
This commit is contained in:
Jean-Baptiste Onofré 2021-08-03 11:08:54 +02:00
parent 6c4c94bb8d
commit 6bb09feed5
1 changed files with 2 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
activemq-stomp/src/main/java/org/apache/activemq/transport/stomp/ProtocolConverter.java
View File

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