[
https://issues.apache.org/jira/browse/AMQNET-490?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14151840#comment-14151840
]
Timothy Bish commented on AMQNET-490:
-------------------------------------
HornetQ uses different destination names then the default one's used by
NMS.Stomp which are ActiveMQ compatible. You can change them using wireFormat
options on the client or change then in HornetQ configuration.
> 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)
