[prev in list] [next in list] [prev in thread] [next in thread]
List: activemq-dev
Subject: [jira] [Commented] (AMQNET-490) Stomp Client 1.5.4 error creating subscription to topic on JBoss Hor
From: "Timothy Bish (JIRA)" <jira+amqnet () apache ! org>
Date: 2014-09-29 18:24:35
Message-ID: JIRA.12744695.1412003703000.147147.1412015075052 () Atlassian ! JIRA
[Download RAW message or body]
[ https://issues.apache.org/jira/browse/AMQNET-490?page=com.atlassian.jira.plugin. \
system.issuetabpanels:comment-tabpanel&focusedCommentId=14152011#comment-14152011 ]
Timothy Bish commented on AMQNET-490:
-------------------------------------
Questions like that should go to the Apache ActiveMQ Users list.
> 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)
[prev in list] [next in list] [prev in thread] [next in thread]
Configure |
About |
News |
Add a list |
Sponsored by KoreLogic