Author: tabish
Date: Wed Oct 20 13:38:18 2010
New Revision: 1025564
URL: http://svn.apache.org/viewvc?rev=1025564&view=rev
Log:
Bring the example code up to date with current APIs
Modified:
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/test/csharp/TestMain.cs
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/test/csharp/TestMainAsync.cs
Modified:
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/test/csharp/TestMain.cs
URL:
http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/test/csharp/TestMain.cs?rev=1025564&r1=1025563&r2=1025564&view=diff
==============================================================================
---
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/test/csharp/TestMain.cs
(original)
+++
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/test/csharp/TestMain.cs
Wed Oct 20 13:38:18 2010
@@ -79,8 +79,8 @@ public class TestMain
{
// Start the connection so that messages will be processed.
connection.Start();
- producer.Persistent = true;
-
+ producer.DeliveryMode =
MsgDeliveryMode.Persistent;
+
// Send a message
ITextMessage request = session.CreateTextMessage("Hello
World!");
request.NMSCorrelationID = "abc";
Modified:
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/test/csharp/TestMainAsync.cs
URL:
http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/test/csharp/TestMainAsync.cs?rev=1025564&r1=1025563&r2=1025564&view=diff
==============================================================================
---
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/test/csharp/TestMainAsync.cs
(original)
+++
activemq/activemq-dotnet/Apache.NMS.ActiveMQ/trunk/src/test/csharp/TestMainAsync.cs
Wed Oct 20 13:38:18 2010
@@ -84,7 +84,7 @@ public class TestMain
{
// Start the connection so that messages will be processed.
connection.Start();
- producer.Persistent = true;
+ producer.DeliveryMode =
MsgDeliveryMode.Persistent;
producer.RequestTimeout = receiveTimeout;
consumer.Listener += new MessageListener(OnMessage);