activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tab...@apache.org
Subject svn commit: r899446 - /activemq/activemq-dotnet/Apache.NMS.Stomp/trunk/src/test/csharp/AsyncConsumeTest.cs
Date Thu, 14 Jan 2010 22:32:27 GMT
Author: tabish
Date: Thu Jan 14 22:32:27 2010
New Revision: 899446

URL: http://svn.apache.org/viewvc?rev=899446&view=rev
Log:
Switch to using a temp queue, leaves broker clean when test completes.

Modified:
    activemq/activemq-dotnet/Apache.NMS.Stomp/trunk/src/test/csharp/AsyncConsumeTest.cs

Modified: activemq/activemq-dotnet/Apache.NMS.Stomp/trunk/src/test/csharp/AsyncConsumeTest.cs
URL: http://svn.apache.org/viewvc/activemq/activemq-dotnet/Apache.NMS.Stomp/trunk/src/test/csharp/AsyncConsumeTest.cs?rev=899446&r1=899445&r2=899446&view=diff
==============================================================================
--- activemq/activemq-dotnet/Apache.NMS.Stomp/trunk/src/test/csharp/AsyncConsumeTest.cs (original)
+++ activemq/activemq-dotnet/Apache.NMS.Stomp/trunk/src/test/csharp/AsyncConsumeTest.cs Thu
Jan 14 22:32:27 2010
@@ -65,7 +65,7 @@
                 connection.Start();
                 using(ISession session = connection.CreateSession(AcknowledgementMode.AutoAcknowledge))
                 {
-                    IDestination destination = SessionUtil.GetDestination(session, DESTINATION_NAME);
+                    IDestination destination = session.CreateTemporaryQueue();
                     using(IMessageConsumer consumer = session.CreateConsumer(destination))
                     using(IMessageProducer producer = session.CreateProducer(destination))
                     {
@@ -95,7 +95,7 @@
                 connection.Start();
                 using(ISession session = connection.CreateSession(AcknowledgementMode.AutoAcknowledge))
                 {
-                    IDestination destination = SessionUtil.GetDestination(session, DESTINATION_NAME);
+                    IDestination destination = session.CreateTemporaryQueue();
                     using(IMessageProducer producer = session.CreateProducer(destination))
                     {
                         producer.DeliveryMode = deliveryMode;
@@ -127,7 +127,7 @@
                 connection.Start();
                 using(ISession session = connection.CreateSession(AcknowledgementMode.AutoAcknowledge))
                 {
-                    IDestination destination = SessionUtil.GetDestination(session, DESTINATION_NAME);
+                    IDestination destination = session.CreateTemporaryQueue();
                     using(IMessageConsumer consumer = session.CreateConsumer(destination))
                     using(IMessageProducer producer = session.CreateProducer(destination))
                     {
@@ -158,7 +158,7 @@
                 connection.Start();
                 using(ISession session = connection.CreateSession(AcknowledgementMode.AutoAcknowledge))
                 {
-                    IDestination destination = SessionUtil.GetDestination(session, DESTINATION_NAME);
+                    IDestination destination = session.CreateTemporaryQueue();
                     using(IMessageConsumer consumer = session.CreateConsumer(destination))
                     {
                         consumer.Listener += new MessageListener(OnMessage);
@@ -195,7 +195,7 @@
                 connection.Start();
                 using(ISession session = connection.CreateSession(AcknowledgementMode.AutoAcknowledge))
                 {
-                    IDestination destination = SessionUtil.GetDestination(session, DESTINATION_NAME);
+                    IDestination destination = session.CreateTemporaryQueue();
                     ITemporaryQueue tempReplyDestination = session.CreateTemporaryQueue();
 
                     using(IMessageConsumer consumer = session.CreateConsumer(destination))



Mime
View raw message