On Mon, 2012-09-24 at 22:36 -0700, maximus wrote: > Tim, > > Did you mean <transportConnector name="Stomp" uri="tcp://0.0.0.0:61613 > "/> ? >
No, you need to properly configure a STOMP transport connector in order to use the NMS.Stomp client. See the below link: http://activemq.apache.org/stomp.html > I will tell what i have been doing so far. Please help me with this setup > as i'm new to messaging > > 1. Downloaded ActiveMQ 5.6.0. Ran the ProducerTool and ConsumerTool > examples provided in the download with "openwire" as the transport > protocol. Works fine. > 2. Created another transportConnector for stomp as shown above. Changed > build.xml file to connect with the new protocol. Works fine. > 3. The above two were tested in java. My client is C# .NET CF. So i created > a consumer and producer sample in C# . I added Apache.NMS and Apache.Stomp > dlls for .NET 3.5 ( just wanted to test as desktop app) . > Running the same gives me the following error : > > ex = {"Unable to read data from the transport connection: An established > connection was aborted by the software in your host machine."} in > TcpTransport. > > Attaching the producer sample below > > using System; > using System.Collections.Generic; > using System.Text; > using Apache.NMS; > using Apache.NMS.Util; > using Apache.NMS.Stomp; > > namespace ActiveMQSample > { > class Program > { > static void Main(string[] args) > { > TestMain test = new TestMain(); > test.CallMe(null); > } > } > public class TestMain > { > public void CallMe(string[] args) > { > // Example connection strings: > // activemq:tcp://activemqhost:61616 > // stomp:tcp://activemqhost:61613 > // ems:tcp://tibcohost:7222 > // msmq://localhost > > Uri connecturi = new Uri("tcp://172.26.37.64:61613"); > //connecturi.Scheme = " "; > > Console.WriteLine("About to connect to " + connecturi); > > // NOTE: ensure the nmsprovider-activemq.config file exists in > the executable folder. > //string broker = > Apache.NMS.Stomp.ConnectionFactory.GetDefaultBrokerUrl(); > IConnectionFactory factory = new ConnectionFactory(connecturi); > > IConnection connection = factory.CreateConnection(); > ISession session = connection.CreateSession(); > // Examples for getting a destination: > // > // Hard coded destinations: > // IDestination destination = session.GetQueue("FOO.BAR"); > // Debug.Assert(destination is IQueue); > // IDestination destination = session.GetTopic("FOO.BAR"); > // Debug.Assert(destination is ITopic); > // > // Embedded destination type in the name: > // IDestination destination = SessionUtil.GetDestination > (session, "queue://FOO.BAR"); > // Debug.Assert(destination is IQueue); > // IDestination destination = SessionUtil.GetDestination > (session, "topic://FOO.BAR"); > // Debug.Assert(destination is ITopic); > // > // Defaults to queue if type is not specified: > // IDestination destination = SessionUtil.GetDestination > (session, "FOO.BAR"); > // Debug.Assert(destination is IQueue); > // > // .NET 3.5 Supports Extension methods for a simplified syntax: > // IDestination destination = session.GetDestination > ("queue://FOO.BAR"); > // Debug.Assert(destination is IQueue); > // IDestination destination = session.GetDestination > ("topic://FOO.BAR"); > // Debug.Assert(destination is ITopic); > > IDestination destination = SessionUtil.GetDestination(session, > "queue://FOO.BAR"); > Console.WriteLine("Using destination: " + destination); > // Create a consumer and producer > //IMessageConsumer consumer = session.CreateConsumer > (destination); > IMessageProducer producer = session.CreateProducer > (destination); > // Start the connection so that messages will be processed. > connection.Start(); > //producer.Persistent = true; > > // Send a message > ITextMessage request = session.CreateTextMessage("Hello > World!"); > request.NMSCorrelationID = "abc"; > request.Properties["NMSXGroupID"] = "cheese"; > request.Properties["myHeader"] = "Cheddar"; > > producer.Send(request); > > // Consume a message > //ITextMessage message = consumer.Receive() as ITextMessage; > //if (message == null) > { > Console.WriteLine("No message received!"); > } > //else > { > // Console.WriteLine("Received message with ID: " + > message.NMSMessageId); > // Console.WriteLine("Received message with text: " + > message.Text); > } > } > } > } > > Regards, > Sujith > > > > > From: "tabish...@gmail.com [via ActiveMQ]" <ml-node > +s2283324n4656848...@n4.nabble.com> > To: maximus <sujith.me...@oatsystems.com> > Date: 09/24/2012 07:14 PM > Subject: Re: Connection Error to Apache > > > > On Fri, 2012-09-21 at 02:59 -0700, sujithmenono wrote: > > > Hi, > > > > I'm trying to write sample code for client/server communication using > > Apache.NMS.Stomp. > > > > Uri connecturi = new Uri("tcp://0.0.0.0:61616"); > > > > Console.WriteLine("About to connect to " + connecturi); > > > > // NOTE: ensure the nmsprovider-activemq.config file exists in the > > executable folder. > > *IConnectionFactory factory = > > NMSConnectionFactory.CreateConnectionFactory(connecturi,null); > > * > > I get the following error while creating the connection factory. > > * > > "No IConnectionFactory implementation found for connection URI: > > tcp://0.0.0.0:61616/"* > > > > This is my setting in activemq.xml > > <transportConnectors> > > <transportConnector name="default" > uri="tcp://0.0.0.0:61616"/> > > </transportConnectors> > > > > You have configured an openwire transport connector on port 61616. You > need to configure a STOMP transport connector. > > <transportConnector name="Stomp" uri="stomp://0.0.0.0:61613"/> > > > > > > > -- > > View this message in context: > http://activemq.2283324.n4.nabble.com/Connection-Error-to-Apache-tp4656810.html > > > Sent from the ActiveMQ - User mailing list archive at Nabble.com. > > -- > Tim Bish > Sr Software Engineer | FuseSource Corp > [hidden email] | www.fusesource.com > skype: tabish121 | twitter: @tabish121 > blog: http://timbish.blogspot.com/ > > > > > If you reply to this email, your message will be added to the discussion > below: > http://activemq.2283324.n4.nabble.com/Connection-Error-to-Apache-tp4656810p4656848.html > > To unsubscribe from Connection Error to Apache, click here. > NAML > > > > > > > -- > View this message in context: > http://activemq.2283324.n4.nabble.com/Connection-Error-to-Apache-tp4656810p4656886.html > Sent from the ActiveMQ - User mailing list archive at Nabble.com. -- Tim Bish Sr Software Engineer | RedHat.com tim.b...@fusesource.com | www.fusesource.com | www.redhat.com skype: tabish121 | twitter: @tabish121 blog: http://timbish.blogspot.com/
