Thanks Tim. Got it working on desktop sample but when i try deploying the
sample on the device emulator the same sample fails. I'm using CF v2.0
binaries that i downloaded.
// msmq://localhost
Uri connecturi = new Uri("tcp://172.17.254.86:61613");
Console.WriteLine("About to connect to " + connecturi);
// NOTE: ensure the nmsprovider-activemq.config file exists in
the executable folder.
IConnectionFactory factory = new
Apache.NMS.Stomp.ConnectionFactory(connecturi);
using (IConnection connection = factory.CreateConnection())
It throws up and NMSConnectionException "Error Connecting to ..." Looks
like the socket could not be created. Any ideas?
regards,
Sujith
From: "[email protected] [via ActiveMQ]" <ml-node
[email protected]>
To: maximus <[email protected]>
Date: 09/25/2012 04:06 PM
Subject: Re: Connection Error to Apache
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: "[hidden email] [via ActiveMQ]" <ml-node
> +[hidden email]>
> To: maximus <[hidden email]>
> 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
[hidden email] | www.fusesource.com | www.redhat.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-tp4656810p4656903.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-tp4656810p4656938.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
