[
https://issues.apache.org/jira/browse/AMQNET-490?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14151946#comment-14151946
]
Harley Blumenfeld commented on AMQNET-490:
------------------------------------------
Thanks for the quick reply. I did some searching around but don't see anything
on changing the destination name passing.
Do you have an example you can point me to on how to do this for the clients?
> Stomp Client 1.5.4 error creating subscription to topic on JBoss HornetQ
> (Jboss 6.4.2 GA)
> -----------------------------------------------------------------------------------------
>
> Key: AMQNET-490
> URL: https://issues.apache.org/jira/browse/AMQNET-490
> Project: ActiveMQ .Net
> Issue Type: Bug
> Components: ActiveMQ, Stomp
> Affects Versions: 1.5.4
> Reporter: Harley Blumenfeld
> Assignee: Jim Gomes
>
> Maybe I am doing something dumb, but using a simple example I cannot seem to
> get a topic subscription working using the Apache.NMS.Stomp version 1.5.4
> (http://activemq.apache.org/nms/apachenmsstomp-v154.html).
> I am compiling the Stomp source code and project under .Net 4.0. I have
> created a console application in the Apache.NMS.Stomp solution. My program
> fails when it attempts to create a subscription to the topic. The same
> example works fine with the 1.5.3 version of the DLL so this seems like it
> could be a bug.
> <b>Here is the result of my simple program:</b>
> About to connect to stomp:tcp://myjboss:61613
> Using destination: topic://jms.topic.test.topic
> Connection Error: : Error creating subscription
> IDcSTHBLUMENF-50514-635475847768724525-1:0c1:1
> Connection Error:
> Error: : Error creating subscription
> IDcSTHBLUMENF-50514-635475847768724525-1:0c1:1
> Error: at Apache.NMS.Stomp.Connection.SyncRequest(Command command, TimeSpan
> requestTimeout) in
> C:\dev\Apache.NMS.Stomp\source\branches\1.5.4\src\main\csharp\Connection.cs:line
> 525
> at Apache.NMS.Stomp.Connection.SyncRequest(Command command) in
> C:\dev\Apache.NMS.Stomp\source\branches\1.5.4\src\main\csharp\Connection.cs:line
> 505
> at Apache.NMS.Stomp.Session.CreateConsumer(IDestination destination,
> String selector, Boolean noLocal) in
> C:\dev\Apache.NMS.Stomp\source\branches\1.5.4\src\main\csharp\Session.cs:line
> 425
> at Apache.NMS.Stomp.Session.CreateConsumer(IDestination destination) in
> C:\dev\Apache.NMS.Stomp\source\branches\1.5.4\src\main\csharp\Session.cs:line
> 379
> at TopicSubscriberTest.Program.Main(String[] args) in
> C:\dev\Apache.NMS.Stomp\source\branches\1.5.4\TopicSubscribeTest\Program.cs:line
> 31
> <b>Here is the code:</b>
> class Program
> {
> private static void Main(string[] args)
> {
> try
> {
> var connecturi = new Uri("stomp:tcp://myjboss:61613");
> Console.WriteLine("About to connect to " + connecturi);
> IConnectionFactory factory = new
> NMSConnectionFactory(connecturi);
> <b>using (IConnection connection =
> factory.CreateConnection("testuser", "test"))</b>
> {
> connection.ExceptionListener += new
> ExceptionListener(OnConnectionException);
> connection.Start();
> using (ISession session =
> connection.CreateSession())
> {
> connection.Start();
>
> IDestination destination =
> SessionUtil.GetDestination(session,"topic://jms.topic.test.topic");
> Console.WriteLine("Using destination: "
> + destination);
> using (IMessageConsumer consumer =
> session.CreateConsumer(destination))
> {
>
> consumer.Listener += OnMessage;
> while (true)
> {
> Thread.Sleep(5000);
> Console.WriteLine(".");
> }
> }
> }
> }
> }
> catch (Exception e)
> {
> Console.WriteLine("Error:" + e.Message);
> Console.WriteLine("Error:" + e.StackTrace);
> Console.ReadLine();
> }
> }
> private static void OnConnectionException(Exception e)
> {
> Console.WriteLine("Connection Error:" + e.Message);
> Console.WriteLine("Connection Error:" + e.StackTrace);
> }
> protected static void OnMessage(IMessage receivedMsg)
> {
> var message = receivedMsg as ITextMessage;
> Console.WriteLine(message.Text);
> }
> }
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
