activemq-dev mailing list archives

Craig Selbert wrote:
> 
> Jim,
> 
> Thanks for the information.  If you could please post the sample you
> talked about that would be great.  
> 
> Craig
> 

Hi Craig,

Here you go.  This is based on the changes that I am contributing.  Still
working through all of the legal due diligence, but I think the contribution
will be committed to the mainline soon.


using System;
using Apache.NMS;

namespace Apache.TibcoEMS.Test
{
	class TestTibco
	{
		static void Main(string[] args)
		{
			IConnectionFactory connectionFactory =
NMSFactory.CreateConnectionFactory("tibco:tcp://testmachine:7222",
"TestTibcoClient");
			if(null != connectionFactory)
			{
				using(IConnection connection =
connectionFactory.CreateConnection("guest", "guest"))
				using(ISession session =
connection.CreateSession(AcknowledgementMode.AutoAcknowledge))
				{
					IQueue publishQueue = session.GetQueue("TestQueue");
					using(IMessageProducer producer = session.CreateProducer(publishQueue))
					using(IMessageConsumer consumer = session.CreateConsumer(publishQueue))
					{
						// Send a message to the queue we are consuming on.
						ITextMessage message = producer.CreateTextMessage("Hello, NMS!");

						// Start receiving connection messages.
						connection.Start();
						producer.Send(message);

						ITextMessage reply = consumer.Receive() as ITextMessage;

						if(null != reply)
						{
							Console.WriteLine(reply.Text);
						}
						else
						{
							Console.WriteLine("You never write messages anymore!");
						}
					}
				}
			}
			else
			{
				Console.Write("Error creating connection factory.");
			}
		}
	}
}

-- 
View this message in context: http://www.nabble.com/NMS-implementation-for-Websphere-MQ-using-C--tf4557901s2354.html#a13147041
Sent from the ActiveMQ - Dev mailing list archive at Nabble.com.