qpid-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ai...@apache.org
Subject svn commit: r886962 [4/5] - in /qpid/trunk/qpid/dotnet/client-010: ./ addins/ExcelAddIn/ addins/ExcelAddInMessageProcessor/ addins/ExcelAddInProducer/ client/ client/client/ client/transport/ client/transport/codec/ client/transport/exception/ client/t...
Date Thu, 03 Dec 2009 22:31:17 GMT
Modified: qpid/trunk/qpid/dotnet/client-010/examples/direct/example-direct-producer/default.build
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/dotnet/client-010/examples/direct/example-direct-producer/default.build?rev=886962&r1=886961&r2=886962&view=diff
==============================================================================
--- qpid/trunk/qpid/dotnet/client-010/examples/direct/example-direct-producer/default.build (original)
+++ qpid/trunk/qpid/dotnet/client-010/examples/direct/example-direct-producer/default.build Thu Dec  3 22:31:12 2009
@@ -39,7 +39,8 @@
          </sources>
          <references>
             <include name="${build.dir}/log4net.dll" />	
-            <include name="${build.dir}/qpid.client.dll" />	
+            <include name="${build.dir}/qpid.client.dll" />
+	    <include name="System.Configuration.dll" />	    
          </references>
         </csc>
     </target>

Modified: qpid/trunk/qpid/dotnet/client-010/examples/direct/example-direct-producer/example-direct-producer.csproj
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/dotnet/client-010/examples/direct/example-direct-producer/example-direct-producer.csproj?rev=886962&r1=886961&r2=886962&view=diff
==============================================================================
--- qpid/trunk/qpid/dotnet/client-010/examples/direct/example-direct-producer/example-direct-producer.csproj (original)
+++ qpid/trunk/qpid/dotnet/client-010/examples/direct/example-direct-producer/example-direct-producer.csproj Thu Dec  3 22:31:12 2009
@@ -3,7 +3,7 @@
   <PropertyGroup>
     <Configuration Condition=" '$(Configuration)' == '' ">Debug</Configuration>
     <Platform Condition=" '$(Platform)' == '' ">AnyCPU</Platform>
-    <ProductVersion>8.0.50727</ProductVersion>
+    <ProductVersion>9.0.30729</ProductVersion>
     <SchemaVersion>2.0</SchemaVersion>
     <ProjectGuid>{96FCB250-8142-40EE-9BDD-CA839EE21021}</ProjectGuid>
     <OutputType>Exe</OutputType>
@@ -35,6 +35,7 @@
   </PropertyGroup>
   <ItemGroup>
     <Reference Include="System" />
+    <Reference Include="System.configuration" />
     <Reference Include="System.Data" />
     <Reference Include="System.Xml" />
   </ItemGroup>
@@ -48,6 +49,11 @@
       <Name>Client</Name>
     </ProjectReference>
   </ItemGroup>
+  <ItemGroup>
+    <None Include="..\..\..\App.config">
+      <Link>App.config</Link>
+    </None>
+  </ItemGroup>
   <Import Project="$(MSBuildBinPath)\Microsoft.CSharp.targets" />
   <!-- To modify your build process, add your task inside one of the targets below and uncomment it. 
        Other similar extension points exist, see Microsoft.Common.targets.
@@ -56,4 +62,4 @@
   <Target Name="AfterBuild">
   </Target>
   -->
-</Project>
\ No newline at end of file
+</Project>

Modified: qpid/trunk/qpid/dotnet/client-010/examples/fanout/example-fanout-Listener/Listener.cs
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/dotnet/client-010/examples/fanout/example-fanout-Listener/Listener.cs?rev=886962&r1=886961&r2=886962&view=diff
==============================================================================
--- qpid/trunk/qpid/dotnet/client-010/examples/fanout/example-fanout-Listener/Listener.cs (original)
+++ qpid/trunk/qpid/dotnet/client-010/examples/fanout/example-fanout-Listener/Listener.cs Thu Dec  3 22:31:12 2009
@@ -18,6 +18,7 @@
 */
 
 using System;
+using System.Configuration;
 using System.IO;
 using System.Text;
 using System.Threading;
@@ -43,13 +44,17 @@
     {
         private static void Main(string[] args)
         {
-            string host = args.Length > 0 ? args[0] : "localhost";
-            int port = args.Length > 1 ? Convert.ToInt32(args[1]) : 5672;
+            string host = ConfigurationManager.AppSettings["Host"];
+            int port = int.Parse(ConfigurationManager.AppSettings["Port"]);
+            string virtualhost = ConfigurationManager.AppSettings["VirtualHost"];
+            string username = ConfigurationManager.AppSettings["Username"];
+            string password = ConfigurationManager.AppSettings["Password"];
+
             Client connection = new Client();
             try
             {
-                connection.connect(host, port, "test", "guest", "guest");
-                ClientSession session = connection.createSession(50000);
+                connection.Connect(host, port, virtualhost, username, password);
+                IClientSession session = connection.CreateSession(50000);
 
                 //--------- Main body of program --------------------------------------------
                 // Each client creates its own private queue, using the 
@@ -63,23 +68,23 @@
                 // messages and routing in logs.
 
                 string myQueue = session.Name;
-                session.queueDeclare(myQueue, Option.EXCLUSIVE, Option.AUTO_DELETE);
-                session.exchangeBind(myQueue, "amq.fanout", "my-key");
+                session.QueueDeclare(myQueue, Option.EXCLUSIVE, Option.AUTO_DELETE);
+                session.ExchangeBind(myQueue, "amq.fanout", "my-key");
 
                 lock (session)
                 {
                     Console.WriteLine("Listening");
                     // Create a listener and subscribe it to my queue.
                     IMessageListener listener = new MessageListener(session);
-                    session.attachMessageListener(listener, myQueue);
-                    session.messageSubscribe(myQueue);
+                    session.AttachMessageListener(listener, myQueue);
+                    session.MessageSubscribe(myQueue);
                     // Receive messages until all messages are received
                     Monitor.Wait(session);
                 }
 
                 //---------------------------------------------------------------------------
 
-                connection.close();
+                connection.Close();
             }
             catch (Exception e)
             {
@@ -90,14 +95,14 @@
 
     public class MessageListener : IMessageListener
     {
-        private readonly ClientSession _session;
+        private readonly IClientSession _session;
         private readonly RangeSet _range = new RangeSet();
-        public MessageListener(ClientSession session)
+        public MessageListener(IClientSession session)
         {
             _session = session;
         }
 
-        public void messageTransfer(IMessage m)
+        public void MessageTransfer(IMessage m)
         {
             BinaryReader reader = new BinaryReader(m.Body, Encoding.UTF8);
             byte[] body = new byte[m.Body.Length - m.Body.Position];
@@ -106,11 +111,11 @@
             string message = enc.GetString(body);
             Console.WriteLine("Message: " + message);
             // Add this message to the list of message to be acknowledged 
-            _range.add(m.Id);
+            _range.Add(m.Id);
             if (message.Equals("That's all, folks!"))
             {
                 // Acknowledge all the received messages 
-                _session.messageAccept(_range);
+                _session.MessageAccept(_range);
                 lock (_session)
                 {
                     Monitor.Pulse(_session);

Modified: qpid/trunk/qpid/dotnet/client-010/examples/fanout/example-fanout-Listener/default.build
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/dotnet/client-010/examples/fanout/example-fanout-Listener/default.build?rev=886962&r1=886961&r2=886962&view=diff
==============================================================================
--- qpid/trunk/qpid/dotnet/client-010/examples/fanout/example-fanout-Listener/default.build (original)
+++ qpid/trunk/qpid/dotnet/client-010/examples/fanout/example-fanout-Listener/default.build Thu Dec  3 22:31:12 2009
@@ -40,6 +40,7 @@
          <references>
             <include name="${build.dir}/log4net.dll" />	
             <include name="${build.dir}/qpid.client.dll" />	
+	    <include name="System.Configuration.dll" />
          </references>
         </csc>
     </target>

Modified: qpid/trunk/qpid/dotnet/client-010/examples/fanout/example-fanout-Listener/example-fanout-Listener.csproj
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/dotnet/client-010/examples/fanout/example-fanout-Listener/example-fanout-Listener.csproj?rev=886962&r1=886961&r2=886962&view=diff
==============================================================================
--- qpid/trunk/qpid/dotnet/client-010/examples/fanout/example-fanout-Listener/example-fanout-Listener.csproj (original)
+++ qpid/trunk/qpid/dotnet/client-010/examples/fanout/example-fanout-Listener/example-fanout-Listener.csproj Thu Dec  3 22:31:12 2009
@@ -3,7 +3,7 @@
   <PropertyGroup>
     <Configuration Condition=" '$(Configuration)' == '' ">Debug</Configuration>
     <Platform Condition=" '$(Platform)' == '' ">AnyCPU</Platform>
-    <ProductVersion>8.0.50727</ProductVersion>
+    <ProductVersion>9.0.30729</ProductVersion>
     <SchemaVersion>2.0</SchemaVersion>
     <ProjectGuid>{18A0792B-DC3A-4EC5-93D6-DB8A111D8F15}</ProjectGuid>
     <OutputType>Exe</OutputType>
@@ -35,6 +35,7 @@
   </PropertyGroup>
   <ItemGroup>
     <Reference Include="System" />
+    <Reference Include="System.configuration" />
     <Reference Include="System.Data" />
     <Reference Include="System.Xml" />
   </ItemGroup>
@@ -48,6 +49,11 @@
       <Name>Client</Name>
     </ProjectReference>
   </ItemGroup>
+  <ItemGroup>
+    <None Include="..\..\..\App.config">
+      <Link>App.config</Link>
+    </None>
+  </ItemGroup>
   <Import Project="$(MSBuildBinPath)\Microsoft.CSharp.targets" />
   <!-- To modify your build process, add your task inside one of the targets below and uncomment it. 
        Other similar extension points exist, see Microsoft.Common.targets.
@@ -56,4 +62,4 @@
   <Target Name="AfterBuild">
   </Target>
   -->
-</Project>
\ No newline at end of file
+</Project>

Modified: qpid/trunk/qpid/dotnet/client-010/examples/fanout/example-fanout-Producer/Producer.cs
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/dotnet/client-010/examples/fanout/example-fanout-Producer/Producer.cs?rev=886962&r1=886961&r2=886962&view=diff
==============================================================================
--- qpid/trunk/qpid/dotnet/client-010/examples/fanout/example-fanout-Producer/Producer.cs (original)
+++ qpid/trunk/qpid/dotnet/client-010/examples/fanout/example-fanout-Producer/Producer.cs Thu Dec  3 22:31:12 2009
@@ -18,6 +18,7 @@
 */
 
 using System;
+using System.Configuration;
 using System.Text;
 using org.apache.qpid.client;
 
@@ -42,13 +43,17 @@
     {
         static void Main(string[] args)
         {
-            string host = args.Length > 0 ? args[0] : "localhost";
-            int port = args.Length > 1 ? Convert.ToInt32(args[1]) : 5672;
+            string host = ConfigurationManager.AppSettings["Host"];
+            int port = int.Parse(ConfigurationManager.AppSettings["Port"]);
+            string virtualhost = ConfigurationManager.AppSettings["VirtualHost"];
+            string username = ConfigurationManager.AppSettings["Username"];
+            string password = ConfigurationManager.AppSettings["Password"];
+
             Client connection = new Client();
             try
             {
-                connection.connect(host, port, "test", "guest", "guest");
-                ClientSession session = connection.createSession(50000);
+                connection.Connect(host, port, virtualhost, username, password);
+                IClientSession session = connection.CreateSession(50000);
 
                 //--------- Main body of program --------------------------------------------
 
@@ -60,20 +65,20 @@
                 // possible without waiting for confirmation.
                 for (int i = 0; i < 10; i++)
                 {
-                    message.clearData();
-                    message.appendData(Encoding.UTF8.GetBytes("Message " + i));
-                    session.messageTransfer("amq.fanout", message);
+                    message.ClearData();
+                    message.AppendData(Encoding.UTF8.GetBytes("Message " + i));
+                    session.MessageTransfer("amq.fanout", message);
                 }
 
                 // And send a syncrhonous final message to indicate termination.
-                message.clearData();
-                message.appendData(Encoding.UTF8.GetBytes("That's all, folks!"));
-                session.messageTransfer("amq.fanout", message);
-                session.sync();
+                message.ClearData();
+                message.AppendData(Encoding.UTF8.GetBytes("That's all, folks!"));
+                session.MessageTransfer("amq.fanout", message);
+                session.Sync();
 
                 //-----------------------------------------------------------------------------
 
-                connection.close();
+                connection.Close();
             }
             catch (Exception e)
             {

Modified: qpid/trunk/qpid/dotnet/client-010/examples/fanout/example-fanout-Producer/default.build
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/dotnet/client-010/examples/fanout/example-fanout-Producer/default.build?rev=886962&r1=886961&r2=886962&view=diff
==============================================================================
--- qpid/trunk/qpid/dotnet/client-010/examples/fanout/example-fanout-Producer/default.build (original)
+++ qpid/trunk/qpid/dotnet/client-010/examples/fanout/example-fanout-Producer/default.build Thu Dec  3 22:31:12 2009
@@ -40,6 +40,7 @@
          <references>
             <include name="${build.dir}/log4net.dll" />	
             <include name="${build.dir}/qpid.client.dll" />	
+	    <include name="System.Configuration.dll" />
          </references>
         </csc>
     </target>

Modified: qpid/trunk/qpid/dotnet/client-010/examples/fanout/example-fanout-Producer/example-fanout-Producer.csproj
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/dotnet/client-010/examples/fanout/example-fanout-Producer/example-fanout-Producer.csproj?rev=886962&r1=886961&r2=886962&view=diff
==============================================================================
--- qpid/trunk/qpid/dotnet/client-010/examples/fanout/example-fanout-Producer/example-fanout-Producer.csproj (original)
+++ qpid/trunk/qpid/dotnet/client-010/examples/fanout/example-fanout-Producer/example-fanout-Producer.csproj Thu Dec  3 22:31:12 2009
@@ -3,7 +3,7 @@
   <PropertyGroup>
     <Configuration Condition=" '$(Configuration)' == '' ">Debug</Configuration>
     <Platform Condition=" '$(Platform)' == '' ">AnyCPU</Platform>
-    <ProductVersion>8.0.50727</ProductVersion>
+    <ProductVersion>9.0.30729</ProductVersion>
     <SchemaVersion>2.0</SchemaVersion>
     <ProjectGuid>{4513BF94-D54A-42FE-8506-FE2CD57B2C51}</ProjectGuid>
     <OutputType>Exe</OutputType>
@@ -35,6 +35,7 @@
   </PropertyGroup>
   <ItemGroup>
     <Reference Include="System" />
+    <Reference Include="System.configuration" />
     <Reference Include="System.Data" />
     <Reference Include="System.Xml" />
   </ItemGroup>
@@ -48,6 +49,11 @@
       <Name>Client</Name>
     </ProjectReference>
   </ItemGroup>
+  <ItemGroup>
+    <None Include="..\..\..\App.config">
+      <Link>App.config</Link>
+    </None>
+  </ItemGroup>
   <Import Project="$(MSBuildBinPath)\Microsoft.CSharp.targets" />
   <!-- To modify your build process, add your task inside one of the targets below and uncomment it. 
        Other similar extension points exist, see Microsoft.Common.targets.
@@ -56,4 +62,4 @@
   <Target Name="AfterBuild">
   </Target>
   -->
-</Project>
\ No newline at end of file
+</Project>

Modified: qpid/trunk/qpid/dotnet/client-010/examples/pub-sub/example-pub-sub-Listener/Listener.cs
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/dotnet/client-010/examples/pub-sub/example-pub-sub-Listener/Listener.cs?rev=886962&r1=886961&r2=886962&view=diff
==============================================================================
--- qpid/trunk/qpid/dotnet/client-010/examples/pub-sub/example-pub-sub-Listener/Listener.cs (original)
+++ qpid/trunk/qpid/dotnet/client-010/examples/pub-sub/example-pub-sub-Listener/Listener.cs Thu Dec  3 22:31:12 2009
@@ -18,6 +18,7 @@
 */
 
 using System;
+using System.Configuration;
 using System.IO;
 using System.Text;
 using System.Threading;
@@ -45,13 +46,17 @@
 
         private static void Main(string[] args)
         {
-            string host = args.Length > 0 ? args[0] : "localhost";
-            int port = args.Length > 1 ? Convert.ToInt32(args[1]) : 5672;
+            string host = ConfigurationManager.AppSettings["Host"];
+            int port = int.Parse(ConfigurationManager.AppSettings["Port"]);
+            string virtualhost = ConfigurationManager.AppSettings["VirtualHost"];
+            string username = ConfigurationManager.AppSettings["Username"];
+            string password = ConfigurationManager.AppSettings["Password"];
+
             Client connection = new Client();
             try
             {
-                connection.connect(host, port, "test", "guest", "guest");
-                ClientSession session = connection.createSession(50000);
+                connection.Connect(host, port, virtualhost, username, password);
+                IClientSession session = connection.CreateSession(50000);
 
                 //--------- Main body of program --------------------------------------------
 
@@ -71,7 +76,7 @@
 
                 //---------------------------------------------------------------------------
 
-                connection.close();
+                connection.Close();
             }
             catch (Exception e)
             {
@@ -79,12 +84,12 @@
             }
         }
 
-        private static void prepareQueue(string queue, string routing_key, ClientSession session)
+        private static void prepareQueue(string queue, string routing_key, IClientSession session)
         {
             // Create a unique queue name for this consumer by concatenating
             // the queue name parameter with the Session ID.     
             Console.WriteLine("Declaring queue: " + queue);
-            session.queueDeclare(queue, Option.EXCLUSIVE, Option.AUTO_DELETE);
+            session.QueueDeclare(queue, Option.EXCLUSIVE, Option.AUTO_DELETE);
 
             // Route messages to the new queue if they match the routing key.
             // Also route any messages to with the "control" routing key to
@@ -92,27 +97,27 @@
             // a message with the content "That's all, Folks!", using the
             // "control" routing key, when it is finished.
 
-            session.exchangeBind(queue, "amq.topic", routing_key);
-            session.exchangeBind(queue, "amq.topic", "control");
+            session.ExchangeBind(queue, "amq.topic", routing_key);
+            session.ExchangeBind(queue, "amq.topic", "control");
 
             // subscribe the listener to the queue
             IMessageListener listener = new MessageListener(session);
-            session.attachMessageListener(listener, queue);
-            session.messageSubscribe(queue);
+            session.AttachMessageListener(listener, queue);
+            session.MessageSubscribe(queue);
         }
     }
 
     public class MessageListener : IMessageListener
     {
-        private readonly ClientSession _session;
+        private readonly IClientSession _session;
         private readonly RangeSet _range = new RangeSet();
 
-        public MessageListener(ClientSession session)
+        public MessageListener(IClientSession session)
         {
             _session = session;
         }
 
-        public void messageTransfer(IMessage m)
+        public void MessageTransfer(IMessage m)
         {
             BinaryReader reader = new BinaryReader(m.Body, Encoding.UTF8);
             byte[] body = new byte[m.Body.Length - m.Body.Position];
@@ -121,13 +126,13 @@
             string message = enc.GetString(body);
             Console.WriteLine("Message: " + message + " from " + m.Destination);
             // Add this message to the list of message to be acknowledged 
-            _range.add(m.Id);
+            _range.Add(m.Id);
             if (message.Equals("That's all, folks!"))
             {
-                Console.WriteLine("Shutting down listener for " + m.DeliveryProperties.getRoutingKey());
+                Console.WriteLine("Shutting down listener for " + m.DeliveryProperties.GetRoutingKey());
                 Listener._count--;
                 // Acknowledge all the received messages 
-                _session.messageAccept(_range);
+                _session.MessageAccept(_range);
                 lock (_session)
                 {
                     Monitor.Pulse(_session);

Modified: qpid/trunk/qpid/dotnet/client-010/examples/pub-sub/example-pub-sub-Listener/default.build
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/dotnet/client-010/examples/pub-sub/example-pub-sub-Listener/default.build?rev=886962&r1=886961&r2=886962&view=diff
==============================================================================
--- qpid/trunk/qpid/dotnet/client-010/examples/pub-sub/example-pub-sub-Listener/default.build (original)
+++ qpid/trunk/qpid/dotnet/client-010/examples/pub-sub/example-pub-sub-Listener/default.build Thu Dec  3 22:31:12 2009
@@ -40,6 +40,7 @@
          <references>
             <include name="${build.dir}/log4net.dll" />	
             <include name="${build.dir}/qpid.client.dll" />	
+	    <include name="System.Configuration.dll" />
          </references>
         </csc>
     </target>

Modified: qpid/trunk/qpid/dotnet/client-010/examples/pub-sub/example-pub-sub-Listener/example-pub-sub-Listener.csproj
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/dotnet/client-010/examples/pub-sub/example-pub-sub-Listener/example-pub-sub-Listener.csproj?rev=886962&r1=886961&r2=886962&view=diff
==============================================================================
--- qpid/trunk/qpid/dotnet/client-010/examples/pub-sub/example-pub-sub-Listener/example-pub-sub-Listener.csproj (original)
+++ qpid/trunk/qpid/dotnet/client-010/examples/pub-sub/example-pub-sub-Listener/example-pub-sub-Listener.csproj Thu Dec  3 22:31:12 2009
@@ -3,7 +3,7 @@
   <PropertyGroup>
     <Configuration Condition=" '$(Configuration)' == '' ">Debug</Configuration>
     <Platform Condition=" '$(Platform)' == '' ">AnyCPU</Platform>
-    <ProductVersion>8.0.50727</ProductVersion>
+    <ProductVersion>9.0.30729</ProductVersion>
     <SchemaVersion>2.0</SchemaVersion>
     <ProjectGuid>{2BCDC2CC-5BDA-4CC7-944D-2899AD8A53C7}</ProjectGuid>
     <OutputType>Exe</OutputType>
@@ -35,6 +35,7 @@
   </PropertyGroup>
   <ItemGroup>
     <Reference Include="System" />
+    <Reference Include="System.configuration" />
     <Reference Include="System.Data" />
     <Reference Include="System.Xml" />
   </ItemGroup>
@@ -48,6 +49,11 @@
       <Name>Client</Name>
     </ProjectReference>
   </ItemGroup>
+  <ItemGroup>
+    <None Include="..\..\..\App.config">
+      <Link>App.config</Link>
+    </None>
+  </ItemGroup>
   <Import Project="$(MSBuildBinPath)\Microsoft.CSharp.targets" />
   <!-- To modify your build process, add your task inside one of the targets below and uncomment it. 
        Other similar extension points exist, see Microsoft.Common.targets.
@@ -56,4 +62,4 @@
   <Target Name="AfterBuild">
   </Target>
   -->
-</Project>
\ No newline at end of file
+</Project>

Modified: qpid/trunk/qpid/dotnet/client-010/examples/pub-sub/example-pub-sub-Publisher/Publisher.cs
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/dotnet/client-010/examples/pub-sub/example-pub-sub-Publisher/Publisher.cs?rev=886962&r1=886961&r2=886962&view=diff
==============================================================================
--- qpid/trunk/qpid/dotnet/client-010/examples/pub-sub/example-pub-sub-Publisher/Publisher.cs (original)
+++ qpid/trunk/qpid/dotnet/client-010/examples/pub-sub/example-pub-sub-Publisher/Publisher.cs Thu Dec  3 22:31:12 2009
@@ -18,6 +18,7 @@
 */
 
 using System;
+using System.Configuration;
 using System.Text;
 using org.apache.qpid.client;
 
@@ -40,13 +41,17 @@
     {
         private static void Main(string[] args)
         {
-            string host = args.Length > 0 ? args[0] : "localhost";
-            int port = args.Length > 1 ? Convert.ToInt32(args[1]) : 5672;
+            string host = ConfigurationManager.AppSettings["Host"];
+            int port = int.Parse(ConfigurationManager.AppSettings["Port"]);
+            string virtualhost = ConfigurationManager.AppSettings["VirtualHost"];
+            string username = ConfigurationManager.AppSettings["Username"];
+            string password = ConfigurationManager.AppSettings["Password"];
+
             Client connection = new Client();
             try
             {
-                connection.connect(host, port, "test", "guest", "guest");
-                ClientSession session = connection.createSession(50000);
+                connection.Connect(host, port, virtualhost, username, password);
+                IClientSession session = connection.CreateSession(50000);
 
                 //--------- Main body of program --------------------------------------------
 
@@ -59,7 +64,7 @@
 
                 //-----------------------------------------------------------------------------
 
-                connection.close();
+                connection.Close();
             }
             catch (Exception e)
             {
@@ -67,27 +72,27 @@
             }
         }
 
-        private static void publishMessages(ClientSession session, string routing_key)
+        private static void publishMessages(IClientSession session, string routing_key)
         {
             IMessage message = new Message();
             // Asynchronous transfer sends messages as quickly as
             // possible without waiting for confirmation.
             for (int i = 0; i < 10; i++)
             {
-                message.clearData();
-                message.appendData(Encoding.UTF8.GetBytes("Message " + i));
-                session.messageTransfer("amq.topic", routing_key, message);
+                message.ClearData();
+                message.AppendData(Encoding.UTF8.GetBytes("Message " + i));
+                session.MessageTransfer("amq.topic", routing_key, message);
             }
         }
 
-        private static void noMoreMessages(ClientSession session)
+        private static void noMoreMessages(IClientSession session)
         {
             IMessage message = new Message();
             // And send a syncrhonous final message to indicate termination.
-            message.clearData();
-            message.appendData(Encoding.UTF8.GetBytes("That's all, folks!"));
-            session.messageTransfer("amq.topic", "control", message);
-            session.sync();
+            message.ClearData();
+            message.AppendData(Encoding.UTF8.GetBytes("That's all, folks!"));
+            session.MessageTransfer("amq.topic", "control", message);
+            session.Sync();
         }
     }
 }

Modified: qpid/trunk/qpid/dotnet/client-010/examples/pub-sub/example-pub-sub-Publisher/default.build
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/dotnet/client-010/examples/pub-sub/example-pub-sub-Publisher/default.build?rev=886962&r1=886961&r2=886962&view=diff
==============================================================================
--- qpid/trunk/qpid/dotnet/client-010/examples/pub-sub/example-pub-sub-Publisher/default.build (original)
+++ qpid/trunk/qpid/dotnet/client-010/examples/pub-sub/example-pub-sub-Publisher/default.build Thu Dec  3 22:31:12 2009
@@ -40,6 +40,7 @@
          <references>
             <include name="${build.dir}/log4net.dll" />	
             <include name="${build.dir}/qpid.client.dll" />	
+	    <include name="System.Configuration.dll" />
          </references>
         </csc>
     </target>

Modified: qpid/trunk/qpid/dotnet/client-010/examples/pub-sub/example-pub-sub-Publisher/example-pub-sub-Publisher.csproj
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/dotnet/client-010/examples/pub-sub/example-pub-sub-Publisher/example-pub-sub-Publisher.csproj?rev=886962&r1=886961&r2=886962&view=diff
==============================================================================
--- qpid/trunk/qpid/dotnet/client-010/examples/pub-sub/example-pub-sub-Publisher/example-pub-sub-Publisher.csproj (original)
+++ qpid/trunk/qpid/dotnet/client-010/examples/pub-sub/example-pub-sub-Publisher/example-pub-sub-Publisher.csproj Thu Dec  3 22:31:12 2009
@@ -3,7 +3,7 @@
   <PropertyGroup>
     <Configuration Condition=" '$(Configuration)' == '' ">Debug</Configuration>
     <Platform Condition=" '$(Platform)' == '' ">AnyCPU</Platform>
-    <ProductVersion>8.0.50727</ProductVersion>
+    <ProductVersion>9.0.30729</ProductVersion>
     <SchemaVersion>2.0</SchemaVersion>
     <ProjectGuid>{F8857634-A134-44E7-A953-F2B22688C599}</ProjectGuid>
     <OutputType>Exe</OutputType>
@@ -35,6 +35,7 @@
   </PropertyGroup>
   <ItemGroup>
     <Reference Include="System" />
+    <Reference Include="System.configuration" />
     <Reference Include="System.Data" />
     <Reference Include="System.Xml" />
   </ItemGroup>
@@ -48,6 +49,11 @@
       <Name>Client</Name>
     </ProjectReference>
   </ItemGroup>
+  <ItemGroup>
+    <None Include="..\..\..\App.config">
+      <Link>App.config</Link>
+    </None>
+  </ItemGroup>
   <Import Project="$(MSBuildBinPath)\Microsoft.CSharp.targets" />
   <!-- To modify your build process, add your task inside one of the targets below and uncomment it. 
        Other similar extension points exist, see Microsoft.Common.targets.
@@ -56,4 +62,4 @@
   <Target Name="AfterBuild">
   </Target>
   -->
-</Project>
\ No newline at end of file
+</Project>

Copied: qpid/trunk/qpid/dotnet/client-010/examples/request-response/example-request-response-Client/RequestResponseClient.cs (from r886946, qpid/trunk/qpid/dotnet/client-010/examples/request-response/example-request-response-Client/Client.cs)
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/dotnet/client-010/examples/request-response/example-request-response-Client/RequestResponseClient.cs?p2=qpid/trunk/qpid/dotnet/client-010/examples/request-response/example-request-response-Client/RequestResponseClient.cs&p1=qpid/trunk/qpid/dotnet/client-010/examples/request-response/example-request-response-Client/Client.cs&r1=886946&r2=886962&rev=886962&view=diff
==============================================================================
--- qpid/trunk/qpid/dotnet/client-010/examples/request-response/example-request-response-Client/Client.cs (original)
+++ qpid/trunk/qpid/dotnet/client-010/examples/request-response/example-request-response-Client/RequestResponseClient.cs Thu Dec  3 22:31:12 2009
@@ -18,6 +18,7 @@
 */
 
 using System;
+using System.Configuration;
 using System.IO;
 using System.Text;
 using System.Threading;
@@ -38,40 +39,44 @@
     ///    return it as a response.
     ///
     /// </summary>
-    internal class Client
+    internal class RequestResponseClient
     {
         private static void Main(string[] args)
         {
-            string host = args.Length > 0 ? args[0] : "localhost";
-            int port = args.Length > 1 ? Convert.ToInt32(args[1]) : 5672;
-            client.Client connection = new client.Client();
+            string host = ConfigurationManager.AppSettings["Host"];
+            int port = int.Parse(ConfigurationManager.AppSettings["Port"]);
+            string virtualhost = ConfigurationManager.AppSettings["VirtualHost"];
+            string username = ConfigurationManager.AppSettings["Username"];
+            string password = ConfigurationManager.AppSettings["Password"];
+
+            Client connection = new Client();
             try
             {
-                connection.connect(host, port, "test", "guest", "guest");
-                ClientSession session = connection.createSession(50000);
+                connection.Connect(host, port, virtualhost, username, password);
+                IClientSession session = connection.CreateSession(50000);
                 IMessage request = new Message();
 
                 //--------- Main body of program --------------------------------------------
                 // Create a response queue so the server can send us responses
                 // to our requests. Use the client's session ID as the name
                 // of the response queue.
-                string response_queue = "client" + session.getName();
+                string response_queue = "client" + session.GetName();
                 // Use the name of the response queue as the routing key
-                session.queueDeclare(response_queue);
-                session.exchangeBind(response_queue, "amq.direct", response_queue);
+                session.QueueDeclare(response_queue);
+                session.ExchangeBind(response_queue, "amq.direct", response_queue);
 
                 // Each client sends the name of their own response queue so
                 // the service knows where to route messages.
-                request.DeliveryProperties.setRoutingKey("request");
-                request.MessageProperties.setReplyTo(new ReplyTo("amq.direct", response_queue));
+                request.DeliveryProperties.SetRoutingKey("request");
+                request.MessageProperties.SetReplyTo(new ReplyTo("amq.direct", response_queue));
 
                 lock (session)
                 {
                     // Create a listener for the response queue and listen for response messages.
                     Console.WriteLine("Activating response queue listener for: " + response_queue);
                     IMessageListener listener = new ClientMessageListener(session);
-                    session.attachMessageListener(listener, response_queue);
-                    session.messageSubscribe(response_queue);
+                    session.AttachMessageListener(listener, response_queue);
+                    session.MessageSubscribe(response_queue);
 
                     // Now send some requests ...
                     string[] strs = {
@@ -83,16 +88,16 @@
                                     };
                     foreach (string s in strs)
                     {
-                        request.clearData();
-                        request.appendData(Encoding.UTF8.GetBytes(s));
-                        session.messageTransfer("amq.direct", request);
+                        request.ClearData();
+                        request.AppendData(Encoding.UTF8.GetBytes(s));
+                        session.MessageTransfer("amq.direct", request);
                     }
                     Console.WriteLine("Waiting for all responses to arrive ...");
                     Monitor.Wait(session);
                 }
                 //---------------------------------------------------------------------------
 
-                connection.close();
+                connection.Close();
             }
             catch (Exception e)
             {
@@ -103,15 +108,15 @@
 
     public class ClientMessageListener : IMessageListener
     {
-        private readonly ClientSession _session;
+        private readonly IClientSession _session;
         private readonly RangeSet _range = new RangeSet();
         private int _counter;
-        public ClientMessageListener(ClientSession session)
+        public ClientMessageListener(IClientSession session)
         {
             _session = session;
         }
 
-        public void messageTransfer(IMessage m)
+        public void MessageTransfer(IMessage m)
         {
             _counter++;
             BinaryReader reader = new BinaryReader(m.Body, Encoding.UTF8);
@@ -121,12 +126,12 @@
             string message = enc.GetString(body);
             Console.WriteLine("Response: " + message);
             // Add this message to the list of message to be acknowledged 
-            _range.add(m.Id);
+            _range.Add(m.Id);
             if (_counter == 4)
             {
-                Console.WriteLine("Shutting down listener for " + m.DeliveryProperties.getRoutingKey());              
+                Console.WriteLine("Shutting down listener for " + m.DeliveryProperties.GetRoutingKey());              
                 // Acknowledge all the received messages 
-                _session.messageAccept(_range);
+                _session.MessageAccept(_range);
                 lock (_session)
                 {
                     Monitor.Pulse(_session);

Modified: qpid/trunk/qpid/dotnet/client-010/examples/request-response/example-request-response-Client/default.build
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/dotnet/client-010/examples/request-response/example-request-response-Client/default.build?rev=886962&r1=886961&r2=886962&view=diff
==============================================================================
--- qpid/trunk/qpid/dotnet/client-010/examples/request-response/example-request-response-Client/default.build (original)
+++ qpid/trunk/qpid/dotnet/client-010/examples/request-response/example-request-response-Client/default.build Thu Dec  3 22:31:12 2009
@@ -39,7 +39,8 @@
          </sources>
          <references>
             <include name="${build.dir}/log4net.dll" />	
-            <include name="${build.dir}/qpid.client.dll" />	
+            <include name="${build.dir}/qpid.client.dll" />
+	    <include name="System.Configuration.dll" />
          </references>
         </csc>
     </target>

Modified: qpid/trunk/qpid/dotnet/client-010/examples/request-response/example-request-response-Client/example-request-response-Client.csproj
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/dotnet/client-010/examples/request-response/example-request-response-Client/example-request-response-Client.csproj?rev=886962&r1=886961&r2=886962&view=diff
==============================================================================
--- qpid/trunk/qpid/dotnet/client-010/examples/request-response/example-request-response-Client/example-request-response-Client.csproj (original)
+++ qpid/trunk/qpid/dotnet/client-010/examples/request-response/example-request-response-Client/example-request-response-Client.csproj Thu Dec  3 22:31:12 2009
@@ -3,7 +3,7 @@
   <PropertyGroup>
     <Configuration Condition=" '$(Configuration)' == '' ">Debug</Configuration>
     <Platform Condition=" '$(Platform)' == '' ">AnyCPU</Platform>
-    <ProductVersion>8.0.50727</ProductVersion>
+    <ProductVersion>9.0.30729</ProductVersion>
     <SchemaVersion>2.0</SchemaVersion>
     <ProjectGuid>{1BC63815-4029-4039-9207-35E7E06ECC99}</ProjectGuid>
     <OutputType>Exe</OutputType>
@@ -35,11 +35,12 @@
   </PropertyGroup>
   <ItemGroup>
     <Reference Include="System" />
+    <Reference Include="System.configuration" />
     <Reference Include="System.Data" />
     <Reference Include="System.Xml" />
   </ItemGroup>
   <ItemGroup>
-    <Compile Include="Client.cs" />
+    <Compile Include="RequestResponseClient.cs" />
     <Compile Include="Properties\AssemblyInfo.cs" />
   </ItemGroup>
   <ItemGroup>
@@ -48,6 +49,11 @@
       <Name>Client</Name>
     </ProjectReference>
   </ItemGroup>
+  <ItemGroup>
+    <None Include="..\..\..\App.config">
+      <Link>App.config</Link>
+    </None>
+  </ItemGroup>
   <Import Project="$(MSBuildBinPath)\Microsoft.CSharp.targets" />
   <!-- To modify your build process, add your task inside one of the targets below and uncomment it. 
        Other similar extension points exist, see Microsoft.Common.targets.
@@ -56,4 +62,4 @@
   <Target Name="AfterBuild">
   </Target>
   -->
-</Project>
\ No newline at end of file
+</Project>

Modified: qpid/trunk/qpid/dotnet/client-010/examples/request-response/example-request-response-Server/Server.cs
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/dotnet/client-010/examples/request-response/example-request-response-Server/Server.cs?rev=886962&r1=886961&r2=886962&view=diff
==============================================================================
--- qpid/trunk/qpid/dotnet/client-010/examples/request-response/example-request-response-Server/Server.cs (original)
+++ qpid/trunk/qpid/dotnet/client-010/examples/request-response/example-request-response-Server/Server.cs Thu Dec  3 22:31:12 2009
@@ -18,6 +18,7 @@
 */
 
 using System;
+using System.Configuration;
 using System.IO;
 using System.Text;
 using System.Threading;
@@ -42,28 +43,32 @@
     {
         static void Main(string[] args)
         {
-            string host = args.Length > 0 ? args[0] : "localhost";
-            int port = args.Length > 1 ? Convert.ToInt32(args[1]) : 5672;
-            client.Client connection = new client.Client();
+            string host = ConfigurationManager.AppSettings["Host"];
+            int port = int.Parse(ConfigurationManager.AppSettings["Port"]);
+            string virtualhost = ConfigurationManager.AppSettings["VirtualHost"];
+            string username = ConfigurationManager.AppSettings["Username"];
+            string password = ConfigurationManager.AppSettings["Password"];
+
+            Client connection = new Client();
             try
             {
-                connection.connect(host, port, "test", "guest", "guest");
-                ClientSession session = connection.createSession(50000);
+                connection.Connect(host, port, virtualhost, username, password);
+                IClientSession session = connection.CreateSession(50000);
 
                 //--------- Main body of program --------------------------------------------
                 // Create a request queue for clients to use when making
                 // requests.
                 const string request_queue = "request";
                 // Use the name of the request queue as the routing key
-                session.queueDeclare(request_queue);
-                session.exchangeBind(request_queue, "amq.direct", request_queue);
+                session.QueueDeclare(request_queue);
+                session.ExchangeBind(request_queue, "amq.direct", request_queue);
 
                 lock (session)
                 {
                     // Create a listener and subscribe it to the request_queue      
                     IMessageListener listener = new MessageListener(session);
-                    session.attachMessageListener(listener, request_queue);
-                    session.messageSubscribe(request_queue);
+                    session.AttachMessageListener(listener, request_queue);
+                    session.MessageSubscribe(request_queue);
                     // Receive messages until all messages are received
                     Console.WriteLine("Waiting for requests");
                     Monitor.Wait(session);
@@ -71,7 +76,7 @@
 
                 //---------------------------------------------------------------------------
 
-                connection.close();
+                connection.Close();
             }
             catch (Exception e)
             {
@@ -82,22 +87,22 @@
 
     public class MessageListener : IMessageListener
     {
-        private readonly ClientSession _session;
+        private readonly IClientSession _session;
         private readonly RangeSet _range = new RangeSet();
-        public MessageListener(ClientSession session)
+        public MessageListener(IClientSession session)
         {
             _session = session;
         }
 
-        public void messageTransfer(IMessage request)
+        public void MessageTransfer(IMessage request)
         {
             IMessage response = new Message();
 
             // Get routing key for response from the request's replyTo property
             string routingKey;
-            if( request.MessageProperties.hasReplyTo() )
+            if( request.MessageProperties.HasReplyTo() )
             {
-                routingKey = request.MessageProperties.getReplyTo().getRoutingKey();
+                routingKey = request.MessageProperties.GetReplyTo().GetRoutingKey();
             }
             else
             {
@@ -116,16 +121,16 @@
             string responseBody = message.ToUpper();
 
             // Send it back to the user
-            response.clearData();
-            response.appendData(Encoding.UTF8.GetBytes(responseBody));
-            _session.messageTransfer("amq.direct", routingKey, response);
+            response.ClearData();
+            response.AppendData(Encoding.UTF8.GetBytes(responseBody));
+            _session.MessageTransfer("amq.direct", routingKey, response);
 
             // Add this message to the list of message to be acknowledged 
-            _range.add(request.Id);
+            _range.Add(request.Id);
             if (message.Equals("That's all, folks!"))
             {
                 // Acknowledge all the received messages 
-                _session.messageAccept(_range);
+                _session.MessageAccept(_range);
                 lock (_session)
                 {
                     Monitor.Pulse(_session);

Modified: qpid/trunk/qpid/dotnet/client-010/examples/request-response/example-request-response-Server/default.build
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/dotnet/client-010/examples/request-response/example-request-response-Server/default.build?rev=886962&r1=886961&r2=886962&view=diff
==============================================================================
--- qpid/trunk/qpid/dotnet/client-010/examples/request-response/example-request-response-Server/default.build (original)
+++ qpid/trunk/qpid/dotnet/client-010/examples/request-response/example-request-response-Server/default.build Thu Dec  3 22:31:12 2009
@@ -40,7 +40,8 @@
          <references>
             <include name="${build.dir}/log4net.dll" />	
             <include name="${build.dir}/qpid.client.dll" />	
-         </references>
+	    <include name="System.Configuration.dll" />
+	 </references>
         </csc>
     </target>
 </project>

Modified: qpid/trunk/qpid/dotnet/client-010/examples/request-response/example-request-response-Server/example-request-response-Server.csproj
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/dotnet/client-010/examples/request-response/example-request-response-Server/example-request-response-Server.csproj?rev=886962&r1=886961&r2=886962&view=diff
==============================================================================
--- qpid/trunk/qpid/dotnet/client-010/examples/request-response/example-request-response-Server/example-request-response-Server.csproj (original)
+++ qpid/trunk/qpid/dotnet/client-010/examples/request-response/example-request-response-Server/example-request-response-Server.csproj Thu Dec  3 22:31:12 2009
@@ -3,7 +3,7 @@
   <PropertyGroup>
     <Configuration Condition=" '$(Configuration)' == '' ">Debug</Configuration>
     <Platform Condition=" '$(Platform)' == '' ">AnyCPU</Platform>
-    <ProductVersion>8.0.50727</ProductVersion>
+    <ProductVersion>9.0.30729</ProductVersion>
     <SchemaVersion>2.0</SchemaVersion>
     <ProjectGuid>{922FBA9C-E483-4AEF-ABE8-AC87421E829B}</ProjectGuid>
     <OutputType>Exe</OutputType>
@@ -35,6 +35,7 @@
   </PropertyGroup>
   <ItemGroup>
     <Reference Include="System" />
+    <Reference Include="System.configuration" />
     <Reference Include="System.Data" />
     <Reference Include="System.Xml" />
   </ItemGroup>
@@ -48,6 +49,11 @@
       <Name>Client</Name>
     </ProjectReference>
   </ItemGroup>
+  <ItemGroup>
+    <None Include="..\..\..\App.config">
+      <Link>App.config</Link>
+    </None>
+  </ItemGroup>
   <Import Project="$(MSBuildBinPath)\Microsoft.CSharp.targets" />
   <!-- To modify your build process, add your task inside one of the targets below and uncomment it. 
        Other similar extension points exist, see Microsoft.Common.targets.
@@ -56,4 +62,4 @@
   <Target Name="AfterBuild">
   </Target>
   -->
-</Project>
\ No newline at end of file
+</Project>

Copied: qpid/trunk/qpid/dotnet/client-010/gentool/IInvoker.tpl (from r886946, qpid/trunk/qpid/dotnet/client-010/management/console/SchemaStatistic.cs)
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/dotnet/client-010/gentool/IInvoker.tpl?p2=qpid/trunk/qpid/dotnet/client-010/gentool/IInvoker.tpl&p1=qpid/trunk/qpid/dotnet/client-010/management/console/SchemaStatistic.cs&r1=886946&r2=886962&rev=886962&view=diff
==============================================================================
--- qpid/trunk/qpid/dotnet/client-010/management/console/SchemaStatistic.cs (original)
+++ qpid/trunk/qpid/dotnet/client-010/gentool/IInvoker.tpl Thu Dec  3 22:31:12 2009
@@ -7,9 +7,9 @@
  * to you under the Apache License, Version 2.0 (the
  * "License"); you may not use this file except in compliance
  * with the License.  You may obtain a copy of the License at
- * 
+ *
  *   http://www.apache.org/licenses/LICENSE-2.0
- * 
+ *
  * Unless required by applicable law or agreed to in writing,
  * software distributed under the License is distributed on an
  * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
@@ -20,35 +20,38 @@
  */
 
 using System;
-using System.Collections.Generic ;
-using org.apache.qpid.transport.codec ;
+using System.Collections.Generic;
+using System.IO;
 
-namespace org.apache.qpid.console
+namespace org.apache.qpid.transport
 {
-	
-	/**
-	 * Metadata that describes the mapping of an object Statistic
-	 */			
-	public class SchemaStatistic
-	{
-	
-		public string Name {get;set;}
-		public short Type {get;set;}
-		public string Description {get;set;}		
-		public string Unit {get;set;}		
-		
-		public SchemaStatistic(Decoder dec)
-		{
-			Dictionary<string, Object> map = dec.readMap() ;							
-			Name = (string)  map["name"] ;
-			Type = (short) short.Parse(""+map["type"]) ;
-				
-			if (map.ContainsKey("unit")) {
-				Unit = (string) map["unit"] ;			
-			}
-			if (map.ContainsKey("description")) {			
-				Description = (string) map["description"] ;			
-			}			
-		}
-	}
+
+public interface IInvoker {
+
+    IFuture Invoke(Method method, IFuture resultClass);
+
+${
+from dotnetgenutil import *
+
+for c in composites:
+  name = cname(c)
+  fields = get_fields(c)
+  params = get_dotnetparameters(c, fields)
+  args = get_arguments(c, fields)
+  result = c["result"]
+  if result:
+    if not result["@type"]:
+      rname = cname(result["struct"])
+    else:
+      rname = cname(result, "@type")
+    jresult = "IFuture" 
+  else:
+    jresult = "void"
+
+  out("""
+    $jresult $(name)($(", ".join(params)));
+""")
+}
+
+}
 }

Modified: qpid/trunk/qpid/dotnet/client-010/management/console/Agent.cs
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/dotnet/client-010/management/console/Agent.cs?rev=886962&r1=886961&r2=886962&view=diff
==============================================================================
--- qpid/trunk/qpid/dotnet/client-010/management/console/Agent.cs (original)
+++ qpid/trunk/qpid/dotnet/client-010/management/console/Agent.cs Thu Dec  3 22:31:12 2009
@@ -61,12 +61,12 @@
 			return String.Format("agent.{0}.{1}", BrokerBank, AgentBank)  ;		
 		}		
 		
-		public static long getBrokerBank(string routingKey) {
+		public static long GetBrokerBank(string routingKey) {
 			string delim = "." ;
 			return long.Parse(routingKey.Split(delim.ToCharArray())[2]) ;
 		}
 		
-		public static long getAgentBank(string routingKey) {
+		public static long GetAgentBank(string routingKey) {
 			string delim = "." ;
 			return long.Parse(routingKey.Split(delim.ToCharArray())[3]) ;		
 		}		

Modified: qpid/trunk/qpid/dotnet/client-010/management/console/Broker.cs
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/dotnet/client-010/management/console/Broker.cs?rev=886962&r1=886961&r2=886962&view=diff
==============================================================================
--- qpid/trunk/qpid/dotnet/client-010/management/console/Broker.cs (original)
+++ qpid/trunk/qpid/dotnet/client-010/management/console/Broker.cs Thu Dec  3 22:31:12 2009
@@ -42,10 +42,10 @@
 		public BrokerURL url ;
 		public Dictionary<string, Agent> Agents = new Dictionary<string, Agent>() ;	
 		
-		private Client client ;
-		private ClientSession clientSession ;
+		private IClient client ;
+		private IClientSession clientSession ;
 		//FIXME This second session should not be needed. There is a bug in the underlieing code.
-		private ClientSession outSession ;		
+		private IClientSession outSession ;		
 		private int timeout = 50000 ;
 		private string replyName ;
 		private string topicName ;
@@ -84,40 +84,40 @@
 			Agent newAgent = new Agent(this,0,"BrokerAgent") ;
 			Agents.Add(newAgent.AgentKey(), newAgent) ;
 			client = new Client() ;
-			client.connect(url.Hostname, url.Port, null, url.AuthName, url.AuthPassword) ;
-			clientSession = client.createSession(timeout) ;		
-			//clientSession.setAutoSync(false) ;
-			string name = System.Text.Encoding.UTF8.GetString(clientSession.getName()) ;
+			client.Connect(url.Hostname, url.Port, null, url.AuthName, url.AuthPassword) ;
+			clientSession = client.CreateSession(timeout) ;		
+			//clientSession.SetAutoSync(false) ;
+			string name = System.Text.Encoding.UTF8.GetString(clientSession.GetName()) ;
 			replyName = "reply-" + name ;
 			topicName = "topic-" + name ;
-			clientSession.setAutoSync(true) ;
+			clientSession.SetAutoSync(true) ;
 			Option[] options = new Option[] {Option.EXCLUSIVE, Option.AUTO_DELETE} ;
 		
 			// This queue is used for responses to messages which are sent.	
-			clientSession.queueDeclare(replyName,options) ;
-			clientSession.exchangeBind(replyName,"amq.direct",replyName) ;
-			clientSession.attachMessageListener(this, "rdest") ;			
-			clientSession.messageSubscribe(replyName,"rdest",MessageAcceptMode.NONE,MessageAcquireMode.PRE_ACQUIRED,null,0,null) ;			  			  						
-            clientSession.messageSetFlowMode("rdest", MessageFlowMode.WINDOW);
-            clientSession.messageFlow("rdest", MessageCreditUnit.BYTE, ClientSession.MESSAGE_FLOW_MAX_BYTES);
-            clientSession.messageFlow("rdest", MessageCreditUnit.MESSAGE, ClientSession.MESSAGE_FLOW_MAX_BYTES);  			
+			clientSession.QueueDeclare(replyName,options) ;
+			clientSession.ExchangeBind(replyName,"amq.direct",replyName) ;
+			clientSession.AttachMessageListener(this, "rdest") ;			
+			clientSession.MessageSubscribe(replyName,"rdest",MessageAcceptMode.NONE,MessageAcquireMode.PRE_ACQUIRED,null,0,null) ;			  			  						
+            clientSession.MessageSetFlowMode("rdest", MessageFlowMode.WINDOW);
+            clientSession.MessageFlow("rdest", MessageCreditUnit.BYTE, ClientSession.MESSAGE_FLOW_MAX_BYTES);
+            clientSession.MessageFlow("rdest", MessageCreditUnit.MESSAGE, ClientSession.MESSAGE_FLOW_MAX_BYTES);  			
 		
 			// This queue is used for unsolicited messages sent to this class.
-			clientSession.queueDeclare(topicName, options) ;
-			clientSession.attachMessageListener(this, "tdest") ;			
-			clientSession.messageSubscribe(topicName,"tdest",MessageAcceptMode.NONE,MessageAcquireMode.PRE_ACQUIRED,null,0,null) ;							  									
-            clientSession.messageSetFlowMode("tdest", MessageFlowMode.WINDOW);
-            clientSession.messageFlow("tdest", MessageCreditUnit.BYTE, ClientSession.MESSAGE_FLOW_MAX_BYTES);
-            clientSession.messageFlow("tdest", MessageCreditUnit.MESSAGE, ClientSession.MESSAGE_FLOW_MAX_BYTES);  				
+			clientSession.QueueDeclare(topicName, options) ;
+			clientSession.AttachMessageListener(this, "tdest") ;			
+			clientSession.MessageSubscribe(topicName,"tdest",MessageAcceptMode.NONE,MessageAcquireMode.PRE_ACQUIRED,null,0,null) ;							  									
+            clientSession.MessageSetFlowMode("tdest", MessageFlowMode.WINDOW);
+            clientSession.MessageFlow("tdest", MessageCreditUnit.BYTE, ClientSession.MESSAGE_FLOW_MAX_BYTES);
+            clientSession.MessageFlow("tdest", MessageCreditUnit.MESSAGE, ClientSession.MESSAGE_FLOW_MAX_BYTES);  				
 			
-			outSession = client.createSession(timeout) ;	
-			outSession.exchangeBind(replyName,"amq.direct",replyName) ;
+			outSession = client.CreateSession(timeout) ;	
+			outSession.ExchangeBind(replyName,"amq.direct",replyName) ;
 			
 			connected = true ;
 			consoleSession.HandleBrokerConnect(this) ;		
 				
 			
-			Encoder encoder = CreateEncoder() ;
+			IEncoder encoder = CreateEncoder() ;
 			this.SetHeader(encoder, 'B', 0) ;
 			this.Send(encoder) ;
 		}
@@ -125,10 +125,10 @@
 		public void Shutdown() {
 			if (connected) {
 				this.WaitForStable() ;
-				clientSession.messageStop("rdest") ;
-				clientSession.messageStop("tdest") ;
-				clientSession.close() ;
-				client.close() ;
+				clientSession.MessageStop("rdest") ;
+				clientSession.MessageStop("tdest") ;
+				clientSession.Close() ;
+				client.Close() ;
 				this.connected = false ;
 			}
 		}
@@ -153,87 +153,87 @@
 			}
 		}
 		
-		public Encoder CreateEncoder() {
+		public IEncoder CreateEncoder() {
 			return new MSEncoder(1000) ;	
 		}
 		
 		
-		public Encoder CreateEncoder(char opcode, long sequence) {
+		public IEncoder CreateEncoder(char opcode, long sequence) {
 			return SetHeader(this.CreateEncoder(), opcode, sequence) ;
 		}
 		
-		public Encoder SetHeader(Encoder enc, char opcode, long sequence) {
-			enc.writeUint8((short)'A') ;
-			enc.writeUint8((short)'M') ;
-			enc.writeUint8((short)'3') ;
-	        enc.writeUint8((short)opcode) ;
-			enc.writeUint32(sequence) ;
+		public IEncoder SetHeader(IEncoder enc, char opcode, long sequence) {
+			enc.WriteUint8((short)'A') ;
+			enc.WriteUint8((short)'M') ;
+			enc.WriteUint8((short)'3') ;
+	        enc.WriteUint8((short)opcode) ;
+			enc.WriteUint32(sequence) ;
 			return enc ;
 		}		
 		
-		public Message CreateMessage(Encoder enc) {
+		public Message CreateMessage(IEncoder enc) {
 			return this.CreateMessage(enc, "broker", -1)  ;
 		}		
 		
-		public Message CreateMessage(Encoder enc, string routingKey) {
+		public Message CreateMessage(IEncoder enc, string routingKey) {
 			return this.CreateMessage(enc, routingKey, -1) ;
 		}
 		
-		public Message CreateMessage(Encoder enc, string routingKey, long ttl) {
+		public Message CreateMessage(IEncoder enc, string routingKey, long ttl) {
 			Message msg = new Message() ;
-			msg.Body = ((MSEncoder)enc).segment() ;
-			msg.DeliveryProperties.setRoutingKey(routingKey) ;
+			msg.Body = ((MSEncoder)enc).Segment() ;
+			msg.DeliveryProperties.SetRoutingKey(routingKey) ;
 			if (-1 != ttl) {
-				msg.DeliveryProperties.setTtl(ttl) ;
+				msg.DeliveryProperties.SetTtl(ttl) ;
 			}
-			msg.MessageProperties.setContentType("x-application/qmf") ;
-			msg.MessageProperties.setReplyTo(new ReplyTo("amq.direct", replyName)) ;
+			msg.MessageProperties.SetContentType("x-application/qmf") ;
+			msg.MessageProperties.SetReplyTo(new ReplyTo("amq.direct", replyName)) ;
 			return msg ;
 		}
 		
-		public void Send(Encoder enc) {
+		public void Send(IEncoder enc) {
 			this.Send(this.CreateMessage(enc)) ;
 		}
 		
 		public void Send(Message msg) {
 	
 			lock (lockObject) {
-				log.Debug(String.Format("Sending message to routing key '{0}'", msg.DeliveryProperties.getRoutingKey())) ;
+				log.Debug(String.Format("Sending message to routing key '{0}'", msg.DeliveryProperties.GetRoutingKey())) ;
 				//log.Debug(System.Text.Encoding.UTF8.GetString(msg.Body.ToArray())) ;			
-				outSession.messageTransfer("qpid.management", msg) ;
+				outSession.MessageTransfer("qpid.management", msg) ;
 				//clientSession.sync() ;
 			}
 		}
 		
-		protected bool CheckHeader(Decoder decoder, out char opcode, out long sequence) {
+		protected bool CheckHeader(IDecoder decoder, out char opcode, out long sequence) {
 			bool returnValue = false ;		
 			opcode = 'x' ;
 			sequence = -1 ;
-			if(decoder.hasRemaining()) {
-				char character = (char) decoder.readUint8() ;
+			if(decoder.HasRemaining()) {
+				char character = (char) decoder.ReadUint8() ;
 				if (character != 'A') {
 					return returnValue ;
 				}
-				character = (char) decoder.readUint8() ;			
+				character = (char) decoder.ReadUint8() ;			
 				if (character != 'M') {
 					return returnValue ;
 				}
-				character = (char) decoder.readUint8() ;			
+				character = (char) decoder.ReadUint8() ;			
 				if (character != '3') {
 					return returnValue ;
 				}	
 				returnValue = true ;
-				opcode = (char) decoder.readUint8() ;
-				sequence = decoder.readUint32() ;
+				opcode = (char) decoder.ReadUint8() ;
+				sequence = decoder.ReadUint32() ;
 			}
 			return returnValue ;
 		}
 		
-		public void messageTransfer(IMessage msg) {
+		public void MessageTransfer(IMessage msg) {
 			MSDecoder decoder = new MSDecoder() ;
-			decoder.init(msg.Body) ;
+			decoder.Init(msg.Body) ;
 			RangeSet rangeSet = new RangeSet() ;
-			rangeSet.add(msg.Id) ;
+			rangeSet.Add(msg.Id) ;
 			char opcode = 'x' ;
 			long seq = -1 ;
 			while (this.CheckHeader(decoder, out opcode, out seq)) {
@@ -279,7 +279,7 @@
 				}		
 			} 
 			lock (lockObject) {
-				outSession.messageAccept(rangeSet) ;
+				outSession.MessageAccept(rangeSet) ;
 			}
 		}
 		
@@ -294,9 +294,9 @@
 				this.reqsOutstanding -= 1 ;	
 				if ((reqsOutstanding == 0) & !topicBound) {
 					foreach (string key in consoleSession.BindingKeys()) {
-						//this.clientSession.exchangeBind(topicName, "qpid.mannagement", key) ;
+						//this.clientSession.ExchangeBind(topicName, "qpid.mannagement", key) ;
 						log.Debug("Setting Topic Binding " + key) ;						
-						this.outSession.exchangeBind(topicName, "qpid.management", key) ;
+						this.outSession.ExchangeBind(topicName, "qpid.management", key) ;
 					}
 					topicBound = true ;
 				}
@@ -348,4 +348,4 @@
 			} 
 		}
 	}
-}
\ No newline at end of file
+}

Modified: qpid/trunk/qpid/dotnet/client-010/management/console/BrokerURL.cs
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/dotnet/client-010/management/console/BrokerURL.cs?rev=886962&r1=886961&r2=886962&view=diff
==============================================================================
--- qpid/trunk/qpid/dotnet/client-010/management/console/BrokerURL.cs (original)
+++ qpid/trunk/qpid/dotnet/client-010/management/console/BrokerURL.cs Thu Dec  3 22:31:12 2009
@@ -20,7 +20,6 @@
  */
 
 using System;
-using System.Net ;
 
 namespace org.apache.qpid.console
 {

Modified: qpid/trunk/qpid/dotnet/client-010/management/console/ClassKey.cs
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/dotnet/client-010/management/console/ClassKey.cs?rev=886962&r1=886961&r2=886962&view=diff
==============================================================================
--- qpid/trunk/qpid/dotnet/client-010/management/console/ClassKey.cs (original)
+++ qpid/trunk/qpid/dotnet/client-010/management/console/ClassKey.cs Thu Dec  3 22:31:12 2009
@@ -55,13 +55,13 @@
 			Hash[3] = long.Parse(bytes[3], NumberStyles.HexNumber) ;
 		}
 		
-		public ClassKey(Decoder dec) {
-			PackageName = dec.readStr8() ;
-			ClassName = dec.readStr8() ;
-			Hash[0] = dec.readUint32() ;
-			Hash[1] = dec.readUint32() ;	
-			Hash[2] = dec.readUint32() ;
-			Hash[3] = dec.readUint32() ;
+		public ClassKey(IDecoder dec) {
+			PackageName = dec.ReadStr8() ;
+			ClassName = dec.ReadStr8() ;
+			Hash[0] = dec.ReadUint32() ;
+			Hash[1] = dec.ReadUint32() ;	
+			Hash[2] = dec.ReadUint32() ;
+			Hash[3] = dec.ReadUint32() ;
 			
 		}
 		
@@ -74,13 +74,13 @@
 			return String.Format("{0:x8}-{1:x8}-{2:x8}-{3:x8}", (long) Hash[0],Hash[1], Hash[2],Hash[3]) ;
 		}
 		
-		public void encode(Encoder enc) {
-			enc.writeStr8(PackageName) ;
-			enc.writeStr8(ClassName) ;					
-			enc.writeUint32(Hash[0]) ;
-			enc.writeUint32(Hash[1]) ;
-			enc.writeUint32(Hash[2]) ;
-			enc.writeUint32(Hash[3]) ;			
+		public void encode(IEncoder enc) {
+			enc.WriteStr8(PackageName) ;
+			enc.WriteStr8(ClassName) ;					
+			enc.WriteUint32(Hash[0]) ;
+			enc.WriteUint32(Hash[1]) ;
+			enc.WriteUint32(Hash[2]) ;
+			enc.WriteUint32(Hash[3]) ;			
 		}
 		
 		override public string ToString() {

Modified: qpid/trunk/qpid/dotnet/client-010/management/console/ObjectID.cs
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/dotnet/client-010/management/console/ObjectID.cs?rev=886962&r1=886961&r2=886962&view=diff
==============================================================================
--- qpid/trunk/qpid/dotnet/client-010/management/console/ObjectID.cs (original)
+++ qpid/trunk/qpid/dotnet/client-010/management/console/ObjectID.cs Thu Dec  3 22:31:12 2009
@@ -37,10 +37,10 @@
 		public ObjectID() {
 		}
 		
-		public ObjectID(Decoder dec)
+		public ObjectID(IDecoder dec)
 		{
-			first = (long)dec.readUint64() ;
-			second = (long)dec.readUint64() ;			
+			first = (long)dec.ReadUint64() ;
+			second = (long)dec.ReadUint64() ;			
 		}
 		
 		public ObjectID(long first, long second) {
@@ -72,9 +72,9 @@
     		return Sequence() == 0 ;
     	}
 
-		public void encode(Encoder enc) {
-			enc.writeUint64((long)first) ;
-			enc.writeUint64((long)second) ;
+		public void encode(IEncoder enc) {
+			enc.WriteUint64((long)first) ;
+			enc.WriteUint64((long)second) ;
 		}
 
 		override public string ToString() {

Modified: qpid/trunk/qpid/dotnet/client-010/management/console/QMFEvent.cs
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/dotnet/client-010/management/console/QMFEvent.cs?rev=886962&r1=886961&r2=886962&view=diff
==============================================================================
--- qpid/trunk/qpid/dotnet/client-010/management/console/QMFEvent.cs (original)
+++ qpid/trunk/qpid/dotnet/client-010/management/console/QMFEvent.cs Thu Dec  3 22:31:12 2009
@@ -49,12 +49,12 @@
 		public EventSeverity Severity {get;set;}
 		public Dictionary<string, object> Arguments {get;set;} 
 		
-		public QMFEvent(Session session, Decoder dec)
+		public QMFEvent(Session session, IDecoder dec)
 		{
 			Session = session ;
 			ClassKey = new ClassKey(dec) ;
-			Timestamp = dec.readInt64() ;
-			Severity = (EventSeverity) dec.readUint8() ;
+			Timestamp = dec.ReadInt64() ;
+			Severity = (EventSeverity) dec.ReadUint8() ;
 			SchemaClass sClass = Session.GetSchema(ClassKey) ;
 			Arguments = new Dictionary<string, object>() ;
 			

Modified: qpid/trunk/qpid/dotnet/client-010/management/console/QMFObject.cs
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/dotnet/client-010/management/console/QMFObject.cs?rev=886962&r1=886961&r2=886962&view=diff
==============================================================================
--- qpid/trunk/qpid/dotnet/client-010/management/console/QMFObject.cs (original)
+++ qpid/trunk/qpid/dotnet/client-010/management/console/QMFObject.cs Thu Dec  3 22:31:12 2009
@@ -92,7 +92,7 @@
  		
  		// This constructor is used by the session to create an object based on a data 
  		// stream by the agent.
-		public QMFObject(Session session, SchemaClass schema, Decoder dec, bool hasProperties, bool hasStats , bool isManaged)
+		public QMFObject(Session session, SchemaClass schema, IDecoder dec, bool hasProperties, bool hasStats , bool isManaged)
 		{
 			Session = session ;
 			Schema = schema ;
@@ -100,9 +100,9 @@
 			
 			if (Managed) {
 			    // FIXME DateTime or Uint64??
-				CurrentTime = new DateTime(dec.readDatetime()) ;
-				CreateTime = new DateTime(dec.readDatetime()) ;				
-				DeleteTime = new DateTime(dec.readDatetime()) ;				
+				CurrentTime = new DateTime(dec.ReadDatetime()) ;
+				CreateTime = new DateTime(dec.ReadDatetime()) ;				
+				DeleteTime = new DateTime(dec.ReadDatetime()) ;				
 				ObjectID = new ObjectID(dec) ;
 			}
 			
@@ -129,7 +129,7 @@
 			
 		}
 
-		protected List<string> ProcessPresenceMasks(Decoder dec, SchemaClass schema) {
+		protected List<string> ProcessPresenceMasks(IDecoder dec, SchemaClass schema) {
 			List<string> excludes = new List<string> () ;
 			short bit = 0 ;
 			short mask = 0 ;
@@ -137,7 +137,7 @@
 				if (prop.Optional) {
 					//log.Debug(String.Format("Property named {0} is optional", prop.Name)) ;				
 					if (bit == 0) {
-						mask=dec.readUint8() ;
+						mask=dec.ReadUint8() ;
 						bit = 1 ;
 					}
 
@@ -234,13 +234,13 @@
 			return Session.InvokeMethod(this, name, args, synchronous, timeToLive) ;
 		}
 		
-		public void Encode (Encoder enc) {
+		public void Encode (IEncoder enc) {
 			int mask = 0 ;
 			int bit = 0 ;
 			List<SchemaProperty> propsToEncode = new List<SchemaProperty>() ;
 			log.Debug(String.Format("Encoding class {0}:{1}", Schema.PackageName, Schema.ClassName)) ;
 					
-			enc.writeUint8(20) ;
+			enc.WriteUint8(20) ;
 			Schema.Key.encode(enc) ;
 			
 			foreach (SchemaProperty prop in Schema.GetAllProperties()) {
@@ -256,7 +256,7 @@
 					bit = bit << 1 ;
 					if (bit == 256) {
 						bit = 0 ;
-						enc.writeUint8((short)mask) ;
+						enc.WriteUint8((short)mask) ;
 						mask = 0 ;
 					}
 				} else {
@@ -264,7 +264,7 @@
 				}
 			}
 			if (bit != 0) {
-				enc.writeUint8((short)mask) ;
+				enc.WriteUint8((short)mask) ;
 			}		
 			
 			foreach (SchemaProperty prop in propsToEncode) {
@@ -291,4 +291,4 @@
 				 
 		
 	}
-}
\ No newline at end of file
+}

Modified: qpid/trunk/qpid/dotnet/client-010/management/console/SchemaArgument.cs
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/dotnet/client-010/management/console/SchemaArgument.cs?rev=886962&r1=886961&r2=886962&view=diff
==============================================================================
--- qpid/trunk/qpid/dotnet/client-010/management/console/SchemaArgument.cs (original)
+++ qpid/trunk/qpid/dotnet/client-010/management/console/SchemaArgument.cs Thu Dec  3 22:31:12 2009
@@ -34,9 +34,9 @@
 
 		public string Direction {get;set;}	
 		
-		public SchemaArgument(Decoder dec, bool methodArg)
+		public SchemaArgument(IDecoder dec, bool methodArg)
 		{
-			Dictionary<string, Object> map = dec.readMap() ;	
+			Dictionary<string, Object> map = dec.ReadMap() ;	
 			base.PopulateData(map) ;					
 				
 			if (map.ContainsKey("dir")) {

Modified: qpid/trunk/qpid/dotnet/client-010/management/console/SchemaClass.cs
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/dotnet/client-010/management/console/SchemaClass.cs?rev=886962&r1=886961&r2=886962&view=diff
==============================================================================
--- qpid/trunk/qpid/dotnet/client-010/management/console/SchemaClass.cs (original)
+++ qpid/trunk/qpid/dotnet/client-010/management/console/SchemaClass.cs Thu Dec  3 22:31:12 2009
@@ -54,18 +54,18 @@
 		
 		protected Session Session {get;set;}				
 		
-		public SchemaClass(int kind, ClassKey key, Decoder dec, Session session)
+		public SchemaClass(int kind, ClassKey key, IDecoder dec, Session session)
 		{
 			log.Debug(String.Format("New schema class {0}", key)) ;
 		    Kind = kind ;
 		    Session = session ;
 		    this.Key = key ;   
-		    bool hasSupertype = !(dec.readUint8().Equals(0)) ;	
+		    bool hasSupertype = !(dec.ReadUint8().Equals(0)) ;	
 		 
 		 	if (kind == CLASS_KIND_TABLE) {
-				int propCount = dec.readUint16() ;
-				int statCount = dec.readUint16() ;
-				int methodCount = dec.readUint16() ;
+				int propCount = dec.ReadUint16() ;
+				int statCount = dec.ReadUint16() ;
+				int methodCount = dec.ReadUint16() ;
 				
 				if (hasSupertype) {		
 			 		SuperType = new ClassKey(dec) ;
@@ -83,7 +83,7 @@
 			}
 			
 			if (kind == CLASS_KIND_EVENT) {			
-				int argCount = dec.readUint16() ;		
+				int argCount = dec.ReadUint16() ;		
 				if (hasSupertype) {
 			 		SuperType = new ClassKey(dec) ;
 			 	}				

Modified: qpid/trunk/qpid/dotnet/client-010/management/console/SchemaMethod.cs
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/dotnet/client-010/management/console/SchemaMethod.cs?rev=886962&r1=886961&r2=886962&view=diff
==============================================================================
--- qpid/trunk/qpid/dotnet/client-010/management/console/SchemaMethod.cs (original)
+++ qpid/trunk/qpid/dotnet/client-010/management/console/SchemaMethod.cs Thu Dec  3 22:31:12 2009
@@ -40,9 +40,9 @@
 		public string Description {get;set;}
 		public List<SchemaArgument> Arguments = new List<SchemaArgument>();
 		
-		public SchemaMethod(Decoder dec)
+		public SchemaMethod(IDecoder dec)
 		{
-			Dictionary<string, Object> map = dec.readMap() ;
+			Dictionary<string, Object> map = dec.ReadMap() ;
 			Name = (string)  map["name"] ;
 			ArgCount = (int) map["argCount"] ;
 			if (map.ContainsKey("desc")) {

Modified: qpid/trunk/qpid/dotnet/client-010/management/console/SchemaProperty.cs
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/dotnet/client-010/management/console/SchemaProperty.cs?rev=886962&r1=886961&r2=886962&view=diff
==============================================================================
--- qpid/trunk/qpid/dotnet/client-010/management/console/SchemaProperty.cs (original)
+++ qpid/trunk/qpid/dotnet/client-010/management/console/SchemaProperty.cs Thu Dec  3 22:31:12 2009
@@ -35,9 +35,9 @@
 		public bool Index {get;set;}	
 		public bool Optional {get;set;}		
 				
-		public SchemaProperty(Decoder dec)
+		public SchemaProperty(IDecoder dec)
 		{
-			Dictionary<string, Object> map = dec.readMap() ;
+			Dictionary<string, Object> map = dec.ReadMap() ;
 			base.PopulateData(map) ;
 			Name = (string)  map["name"] ;
 			

Modified: qpid/trunk/qpid/dotnet/client-010/management/console/SchemaStatistic.cs
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/dotnet/client-010/management/console/SchemaStatistic.cs?rev=886962&r1=886961&r2=886962&view=diff
==============================================================================
--- qpid/trunk/qpid/dotnet/client-010/management/console/SchemaStatistic.cs (original)
+++ qpid/trunk/qpid/dotnet/client-010/management/console/SchemaStatistic.cs Thu Dec  3 22:31:12 2009
@@ -37,9 +37,9 @@
 		public string Description {get;set;}		
 		public string Unit {get;set;}		
 		
-		public SchemaStatistic(Decoder dec)
+		public SchemaStatistic(IDecoder dec)
 		{
-			Dictionary<string, Object> map = dec.readMap() ;							
+			Dictionary<string, Object> map = dec.ReadMap() ;							
 			Name = (string)  map["name"] ;
 			Type = (short) short.Parse(""+map["type"]) ;
 				



---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project:      http://qpid.apache.org
Use/Interact: mailto:commits-subscribe@qpid.apache.org


Mime
View raw message