From eac597346ca2d5d3fab8c890c24902f744892460 Mon Sep 17 00:00:00 2001 From: James Strachan Date: Fri, 30 Dec 2005 15:55:20 +0000 Subject: [PATCH] allows for the specifying of ActiveMQ specific connection headers git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@360111 13f79535-47bb-0310-9956-ffa450edef68 --- .../java/org/apache/activemq/transport/stomp/Connect.java | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/activemq-core/src/main/java/org/apache/activemq/transport/stomp/Connect.java b/activemq-core/src/main/java/org/apache/activemq/transport/stomp/Connect.java index 35260669c2..3bc29f0ff8 100644 --- a/activemq-core/src/main/java/org/apache/activemq/transport/stomp/Connect.java +++ b/activemq-core/src/main/java/org/apache/activemq/transport/stomp/Connect.java @@ -25,6 +25,7 @@ import org.apache.activemq.command.ConnectionInfo; import org.apache.activemq.command.ProducerInfo; import org.apache.activemq.command.Response; import org.apache.activemq.command.SessionInfo; +import org.apache.activemq.util.IntrospectionSupport; class Connect implements StompCommand { private HeaderParser headerParser = new HeaderParser(); @@ -45,6 +46,9 @@ class Connect implements StompCommand { String clientId = headers.getProperty(Stomp.Headers.Connect.CLIENT_ID); final ConnectionInfo connectionInfo = new ConnectionInfo(); + + IntrospectionSupport.setProperties(connectionInfo, headers, "activemq."); + connectionInfo.setConnectionId(format.getConnectionId()); if( clientId!=null ) connectionInfo.setClientId(clientId);