Uploaded image for project: 'ActiveMQ .Net'
  1. ActiveMQ .Net
  2. AMQNET-490

Stomp Client 1.5.4 error creating subscription to topic on JBoss HornetQ (Jboss 6.4.2 GA)



    • New Feature
    • Status: Reopened
    • Major
    • Resolution: Unresolved
    • 1.5.4
    • None
    • Stomp
    • None


      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)
      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);

      using (ISession session = connection.CreateSession())
      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); }





            Unassigned Unassigned
            harleybl Harley Blumenfeld
            0 Vote for this issue
            2 Start watching this issue