You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ta...@apache.org on 2010/01/14 23:32:27 UTC
svn commit: r899446 -
/activemq/activemq-dotnet/Apache.NMS.Stomp/trunk/src/test/csharp/AsyncConsumeTest.cs
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))