Author: rupertlssmith
Date: Wed Jan 23 03:45:13 2008
New Revision: 614504
URL: http://svn.apache.org/viewvc?rev=614504&view=rev
Log:
Qpid-756, client id is now set.
Modified:
incubator/qpid/branches/M2.1/dotnet/Qpid.Client/Client/Handler/ConnectionStartMethodHandler.cs
incubator/qpid/branches/M2.1/dotnet/Qpid.Client/Client/Protocol/AMQProtocolSession.cs
Modified:
incubator/qpid/branches/M2.1/dotnet/Qpid.Client/Client/Handler/ConnectionStartMethodHandler.cs
URL:
http://svn.apache.org/viewvc/incubator/qpid/branches/M2.1/dotnet/Qpid.Client/Client/Handler/ConnectionStartMethodHandler.cs?rev=614504&r1=614503&r2=614504&view=diff
==============================================================================
---
incubator/qpid/branches/M2.1/dotnet/Qpid.Client/Client/Handler/ConnectionStartMethodHandler.cs
(original)
+++
incubator/qpid/branches/M2.1/dotnet/Qpid.Client/Client/Handler/ConnectionStartMethodHandler.cs
Wed Jan 23 03:45:13 2008
@@ -76,6 +76,7 @@
clientProperties["product"] = "Apache.Qpid.NET";
clientProperties["version"] = "1.0";
clientProperties["platform"] = GetFullSystemInfo();
+ clientProperties["instance"] = ps.ClientID;
AMQFrame frame = ConnectionStartOkBody.CreateAMQFrame(
evt.ChannelId, clientProperties, selectedMechanism,
saslResponse, selectedLocale);
Modified:
incubator/qpid/branches/M2.1/dotnet/Qpid.Client/Client/Protocol/AMQProtocolSession.cs
URL:
http://svn.apache.org/viewvc/incubator/qpid/branches/M2.1/dotnet/Qpid.Client/Client/Protocol/AMQProtocolSession.cs?rev=614504&r1=614503&r2=614504&view=diff
==============================================================================
---
incubator/qpid/branches/M2.1/dotnet/Qpid.Client/Client/Protocol/AMQProtocolSession.cs
(original)
+++
incubator/qpid/branches/M2.1/dotnet/Qpid.Client/Client/Protocol/AMQProtocolSession.cs
Wed Jan 23 03:45:13 2008
@@ -59,6 +59,8 @@
private AMQConnection _connection;
+ public string ClientID { get { return _connection.ClientID; } }
+
public AMQProtocolSession(IProtocolWriter protocolWriter,
IConnectionCloser connectionCloser, AMQConnection connection)
{
_protocolWriter = protocolWriter;