Author: gaohoward
Date: 2010-10-14 05:43:10 -0400 (Thu, 14 Oct 2010)
New Revision: 9786
Modified:
branches/hornetq-416/src/main/org/hornetq/core/protocol/core/impl/PacketDecoder.java
branches/hornetq-416/src/main/org/hornetq/core/protocol/core/impl/RemotingConnectionImpl.java
branches/hornetq-416/src/main/org/hornetq/core/protocol/core/impl/wireformat/ConnectionSetClientIDMessage.java
branches/hornetq-416/src/main/org/hornetq/jms/management/impl/JMSServerControlImpl.java
branches/hornetq-416/src/main/org/hornetq/spi/core/protocol/RemotingConnection.java
Log:
setClientID impl
Modified:
branches/hornetq-416/src/main/org/hornetq/core/protocol/core/impl/PacketDecoder.java
===================================================================
---
branches/hornetq-416/src/main/org/hornetq/core/protocol/core/impl/PacketDecoder.java 2010-10-14
00:45:50 UTC (rev 9785)
+++
branches/hornetq-416/src/main/org/hornetq/core/protocol/core/impl/PacketDecoder.java 2010-10-14
09:43:10 UTC (rev 9786)
@@ -78,10 +78,12 @@
import static org.hornetq.core.protocol.core.impl.PacketImpl.SESS_XA_SET_TIMEOUT_RESP;
import static org.hornetq.core.protocol.core.impl.PacketImpl.SESS_XA_START;
import static org.hornetq.core.protocol.core.impl.PacketImpl.SESS_XA_SUSPEND;
+import static org.hornetq.core.protocol.core.impl.PacketImpl.CONNECTION_SET_CLIENTID;
import org.hornetq.api.core.HornetQBuffer;
import org.hornetq.core.logging.Logger;
import org.hornetq.core.protocol.core.Packet;
+import org.hornetq.core.protocol.core.impl.wireformat.ConnectionSetClientIDMessage;
import org.hornetq.core.protocol.core.impl.wireformat.CreateQueueMessage;
import org.hornetq.core.protocol.core.impl.wireformat.CreateReplicationSessionMessage;
import org.hornetq.core.protocol.core.impl.wireformat.CreateSessionMessage;
@@ -486,6 +488,11 @@
packet = new SessionForceConsumerDelivery();
break;
}
+ case CONNECTION_SET_CLIENTID:
+ {
+ packet = new ConnectionSetClientIDMessage();
+ break;
+ }
default:
{
throw new IllegalArgumentException("Invalid type: " + packetType);
Modified:
branches/hornetq-416/src/main/org/hornetq/core/protocol/core/impl/RemotingConnectionImpl.java
===================================================================
---
branches/hornetq-416/src/main/org/hornetq/core/protocol/core/impl/RemotingConnectionImpl.java 2010-10-14
00:45:50 UTC (rev 9785)
+++
branches/hornetq-416/src/main/org/hornetq/core/protocol/core/impl/RemotingConnectionImpl.java 2010-10-14
09:43:10 UTC (rev 9786)
@@ -563,4 +563,9 @@
{
clientID = cID;
}
+
+ public String getClientID()
+ {
+ return clientID;
+ }
}
Modified:
branches/hornetq-416/src/main/org/hornetq/core/protocol/core/impl/wireformat/ConnectionSetClientIDMessage.java
===================================================================
---
branches/hornetq-416/src/main/org/hornetq/core/protocol/core/impl/wireformat/ConnectionSetClientIDMessage.java 2010-10-14
00:45:50 UTC (rev 9785)
+++
branches/hornetq-416/src/main/org/hornetq/core/protocol/core/impl/wireformat/ConnectionSetClientIDMessage.java 2010-10-14
09:43:10 UTC (rev 9786)
@@ -24,6 +24,11 @@
public class ConnectionSetClientIDMessage extends PacketImpl
{
private String clientID;
+
+ public ConnectionSetClientIDMessage()
+ {
+ super(PacketImpl.CONNECTION_SET_CLIENTID);
+ }
public ConnectionSetClientIDMessage(String cID)
{
Modified:
branches/hornetq-416/src/main/org/hornetq/jms/management/impl/JMSServerControlImpl.java
===================================================================
---
branches/hornetq-416/src/main/org/hornetq/jms/management/impl/JMSServerControlImpl.java 2010-10-14
00:45:50 UTC (rev 9785)
+++
branches/hornetq-416/src/main/org/hornetq/jms/management/impl/JMSServerControlImpl.java 2010-10-14
09:43:10 UTC (rev 9786)
@@ -742,6 +742,7 @@
obj.put("connectionID", connection.getID().toString());
obj.put("clientAddress", connection.getRemoteAddress());
obj.put("creationTime", connection.getCreationTime());
+ obj.put("clientID", connection.getClientID());
array.put(obj);
}
return array.toString();
Modified:
branches/hornetq-416/src/main/org/hornetq/spi/core/protocol/RemotingConnection.java
===================================================================
---
branches/hornetq-416/src/main/org/hornetq/spi/core/protocol/RemotingConnection.java 2010-10-14
00:45:50 UTC (rev 9785)
+++
branches/hornetq-416/src/main/org/hornetq/spi/core/protocol/RemotingConnection.java 2010-10-14
09:43:10 UTC (rev 9786)
@@ -13,6 +13,7 @@
package org.hornetq.spi.core.protocol;
+import java.util.Collection;
import java.util.List;
import org.hornetq.api.core.HornetQBuffer;
@@ -172,4 +173,10 @@
*/
void setClientID(String clientID);
+ /**
+ * get the client id
+ * @return the clientID
+ */
+ String getClientID();
+
}
Show replies by date