You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@activemq.apache.org by "Alistair Young (JIRA)" <ji...@apache.org> on 2009/08/20 15:50:35 UTC

[jira] Created: (AMQNET-181) ISession::CreateDurableConsumer does not work

ISession::CreateDurableConsumer does not work
---------------------------------------------

                 Key: AMQNET-181
                 URL: https://issues.apache.org/activemq/browse/AMQNET-181
             Project: ActiveMQ .Net
          Issue Type: Bug
          Components: Stomp
    Affects Versions: 1.1.0
         Environment: ActiveMQ .NET 1.1.0 Release
Windows XP
.NET 3.5
            Reporter: Alistair Young
            Assignee: Jim Gomes
             Fix For: 1.1.0


the following code results in a non durable subscription to the ActiveMQ topic with an ActiveMQ generated consumer ID. Using the normal 61616 port and connection works fine.

using Apache.NMS;
using Apache.NMS.ActiveMQ;
using Apache.NMS.ActiveMQ.Commands;

Uri connectURI = new Uri("activemq:tcp://host.com:61613?transport.wireformat=stomp");
ConnectionFactory connectionFactory = new ConnectionFactory(connectURI);
IConnection connection = connectionFactory.CreateConnection();
connection.ClientId = "DurableClientId";
connection.Start();
connection.ExceptionListener += new ExceptionListener(OnException);
ISession session = connection.CreateSession(AcknowledgementMode.DupsOkAcknowledge);
ActiveMQTopic topic = new ActiveMQTopic("test.t");
IMessageConsumer consumer = session.CreateDurableConsumer(topic, "DurableClientId", "2 > 1", false);
consumer.Listener += new MessageListener(OnMessage);
Console.WriteLine("Press any key to exit...");
Console.ReadKey();


-- 
This message is automatically generated by JIRA.
-
You can reply to this email to add a comment to the issue online.


[jira] Resolved: (AMQNET-181) ISession::CreateDurableConsumer does not work

Posted by "Timothy Bish (JIRA)" <ji...@apache.org>.
     [ https://issues.apache.org/activemq/browse/AMQNET-181?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Timothy Bish resolved AMQNET-181.
---------------------------------

    Resolution: Fixed

Sets the correct headers for durable subscriptions

> ISession::CreateDurableConsumer does not work
> ---------------------------------------------
>
>                 Key: AMQNET-181
>                 URL: https://issues.apache.org/activemq/browse/AMQNET-181
>             Project: ActiveMQ .Net
>          Issue Type: Bug
>          Components: ActiveMQ
>    Affects Versions: 1.1.0
>         Environment: ActiveMQ .NET 1.1.0 Release
> Windows XP
> .NET 3.5
>            Reporter: Alistair Young
>            Assignee: Timothy Bish
>            Priority: Minor
>             Fix For: 1.2.0
>
>
> the following code results in a non durable subscription to the ActiveMQ topic with an ActiveMQ generated consumer ID. Using the normal 61616 port and connection works fine.
> using Apache.NMS;
> using Apache.NMS.ActiveMQ;
> using Apache.NMS.ActiveMQ.Commands;
> Uri connectURI = new Uri("activemq:tcp://host.com:61613?transport.wireformat=stomp");
> ConnectionFactory connectionFactory = new ConnectionFactory(connectURI);
> IConnection connection = connectionFactory.CreateConnection();
> connection.ClientId = "DurableClientId";
> connection.Start();
> connection.ExceptionListener += new ExceptionListener(OnException);
> ISession session = connection.CreateSession(AcknowledgementMode.DupsOkAcknowledge);
> ActiveMQTopic topic = new ActiveMQTopic("test.t");
> IMessageConsumer consumer = session.CreateDurableConsumer(topic, "DurableClientId", "2 > 1", false);
> consumer.Listener += new MessageListener(OnMessage);
> Console.WriteLine("Press any key to exit...");
> Console.ReadKey();

-- 
This message is automatically generated by JIRA.
-
You can reply to this email to add a comment to the issue online.


[jira] Commented: (AMQNET-181) ISession::CreateDurableConsumer does not work

Posted by "Timothy Bish (JIRA)" <ji...@apache.org>.
    [ https://issues.apache.org/activemq/browse/AMQNET-181?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=54543#action_54543 ] 

Timothy Bish commented on AMQNET-181:
-------------------------------------

The problem here appears to be that the .NET client is setting the Subscription header in the Stomp command to "durable-subscriber-name" when the AMQ broker is expecting it to be "activemq.subscriptionName"

> ISession::CreateDurableConsumer does not work
> ---------------------------------------------
>
>                 Key: AMQNET-181
>                 URL: https://issues.apache.org/activemq/browse/AMQNET-181
>             Project: ActiveMQ .Net
>          Issue Type: Bug
>          Components: ActiveMQ
>    Affects Versions: 1.1.0
>         Environment: ActiveMQ .NET 1.1.0 Release
> Windows XP
> .NET 3.5
>            Reporter: Alistair Young
>            Assignee: Jim Gomes
>            Priority: Minor
>             Fix For: 1.2.0
>
>
> the following code results in a non durable subscription to the ActiveMQ topic with an ActiveMQ generated consumer ID. Using the normal 61616 port and connection works fine.
> using Apache.NMS;
> using Apache.NMS.ActiveMQ;
> using Apache.NMS.ActiveMQ.Commands;
> Uri connectURI = new Uri("activemq:tcp://host.com:61613?transport.wireformat=stomp");
> ConnectionFactory connectionFactory = new ConnectionFactory(connectURI);
> IConnection connection = connectionFactory.CreateConnection();
> connection.ClientId = "DurableClientId";
> connection.Start();
> connection.ExceptionListener += new ExceptionListener(OnException);
> ISession session = connection.CreateSession(AcknowledgementMode.DupsOkAcknowledge);
> ActiveMQTopic topic = new ActiveMQTopic("test.t");
> IMessageConsumer consumer = session.CreateDurableConsumer(topic, "DurableClientId", "2 > 1", false);
> consumer.Listener += new MessageListener(OnMessage);
> Console.WriteLine("Press any key to exit...");
> Console.ReadKey();

-- 
This message is automatically generated by JIRA.
-
You can reply to this email to add a comment to the issue online.


[jira] Assigned: (AMQNET-181) ISession::CreateDurableConsumer does not work

Posted by "Timothy Bish (JIRA)" <ji...@apache.org>.
     [ https://issues.apache.org/activemq/browse/AMQNET-181?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Timothy Bish reassigned AMQNET-181:
-----------------------------------

    Assignee: Timothy Bish  (was: Jim Gomes)

> ISession::CreateDurableConsumer does not work
> ---------------------------------------------
>
>                 Key: AMQNET-181
>                 URL: https://issues.apache.org/activemq/browse/AMQNET-181
>             Project: ActiveMQ .Net
>          Issue Type: Bug
>          Components: ActiveMQ
>    Affects Versions: 1.1.0
>         Environment: ActiveMQ .NET 1.1.0 Release
> Windows XP
> .NET 3.5
>            Reporter: Alistair Young
>            Assignee: Timothy Bish
>            Priority: Minor
>             Fix For: 1.2.0
>
>
> the following code results in a non durable subscription to the ActiveMQ topic with an ActiveMQ generated consumer ID. Using the normal 61616 port and connection works fine.
> using Apache.NMS;
> using Apache.NMS.ActiveMQ;
> using Apache.NMS.ActiveMQ.Commands;
> Uri connectURI = new Uri("activemq:tcp://host.com:61613?transport.wireformat=stomp");
> ConnectionFactory connectionFactory = new ConnectionFactory(connectURI);
> IConnection connection = connectionFactory.CreateConnection();
> connection.ClientId = "DurableClientId";
> connection.Start();
> connection.ExceptionListener += new ExceptionListener(OnException);
> ISession session = connection.CreateSession(AcknowledgementMode.DupsOkAcknowledge);
> ActiveMQTopic topic = new ActiveMQTopic("test.t");
> IMessageConsumer consumer = session.CreateDurableConsumer(topic, "DurableClientId", "2 > 1", false);
> consumer.Listener += new MessageListener(OnMessage);
> Console.WriteLine("Press any key to exit...");
> Console.ReadKey();

-- 
This message is automatically generated by JIRA.
-
You can reply to this email to add a comment to the issue online.


[jira] Commented: (AMQNET-181) ISession::CreateDurableConsumer does not work

Posted by "Timothy Bish (JIRA)" <ji...@apache.org>.
    [ https://issues.apache.org/activemq/browse/AMQNET-181?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=53689#action_53689 ] 

Timothy Bish commented on AMQNET-181:
-------------------------------------

Can you also provide information on the version of the Broker and JVM you are using?

> ISession::CreateDurableConsumer does not work
> ---------------------------------------------
>
>                 Key: AMQNET-181
>                 URL: https://issues.apache.org/activemq/browse/AMQNET-181
>             Project: ActiveMQ .Net
>          Issue Type: Bug
>          Components: Stomp
>    Affects Versions: 1.1.0
>         Environment: ActiveMQ .NET 1.1.0 Release
> Windows XP
> .NET 3.5
>            Reporter: Alistair Young
>            Assignee: Jim Gomes
>            Priority: Minor
>             Fix For: 1.2.0
>
>
> the following code results in a non durable subscription to the ActiveMQ topic with an ActiveMQ generated consumer ID. Using the normal 61616 port and connection works fine.
> using Apache.NMS;
> using Apache.NMS.ActiveMQ;
> using Apache.NMS.ActiveMQ.Commands;
> Uri connectURI = new Uri("activemq:tcp://host.com:61613?transport.wireformat=stomp");
> ConnectionFactory connectionFactory = new ConnectionFactory(connectURI);
> IConnection connection = connectionFactory.CreateConnection();
> connection.ClientId = "DurableClientId";
> connection.Start();
> connection.ExceptionListener += new ExceptionListener(OnException);
> ISession session = connection.CreateSession(AcknowledgementMode.DupsOkAcknowledge);
> ActiveMQTopic topic = new ActiveMQTopic("test.t");
> IMessageConsumer consumer = session.CreateDurableConsumer(topic, "DurableClientId", "2 > 1", false);
> consumer.Listener += new MessageListener(OnMessage);
> Console.WriteLine("Press any key to exit...");
> Console.ReadKey();

-- 
This message is automatically generated by JIRA.
-
You can reply to this email to add a comment to the issue online.


[jira] Updated: (AMQNET-181) ISession::CreateDurableConsumer does not work

Posted by "Timothy Bish (JIRA)" <ji...@apache.org>.
     [ https://issues.apache.org/activemq/browse/AMQNET-181?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Timothy Bish updated AMQNET-181:
--------------------------------

         Priority: Minor  (was: Major)
    Fix Version/s:     (was: 1.1.0)
                   1.2.0

> ISession::CreateDurableConsumer does not work
> ---------------------------------------------
>
>                 Key: AMQNET-181
>                 URL: https://issues.apache.org/activemq/browse/AMQNET-181
>             Project: ActiveMQ .Net
>          Issue Type: Bug
>          Components: Stomp
>    Affects Versions: 1.1.0
>         Environment: ActiveMQ .NET 1.1.0 Release
> Windows XP
> .NET 3.5
>            Reporter: Alistair Young
>            Assignee: Jim Gomes
>            Priority: Minor
>             Fix For: 1.2.0
>
>
> the following code results in a non durable subscription to the ActiveMQ topic with an ActiveMQ generated consumer ID. Using the normal 61616 port and connection works fine.
> using Apache.NMS;
> using Apache.NMS.ActiveMQ;
> using Apache.NMS.ActiveMQ.Commands;
> Uri connectURI = new Uri("activemq:tcp://host.com:61613?transport.wireformat=stomp");
> ConnectionFactory connectionFactory = new ConnectionFactory(connectURI);
> IConnection connection = connectionFactory.CreateConnection();
> connection.ClientId = "DurableClientId";
> connection.Start();
> connection.ExceptionListener += new ExceptionListener(OnException);
> ISession session = connection.CreateSession(AcknowledgementMode.DupsOkAcknowledge);
> ActiveMQTopic topic = new ActiveMQTopic("test.t");
> IMessageConsumer consumer = session.CreateDurableConsumer(topic, "DurableClientId", "2 > 1", false);
> consumer.Listener += new MessageListener(OnMessage);
> Console.WriteLine("Press any key to exit...");
> Console.ReadKey();

-- 
This message is automatically generated by JIRA.
-
You can reply to this email to add a comment to the issue online.


[jira] Commented: (AMQNET-181) ISession::CreateDurableConsumer does not work

Posted by "Alistair Young (JIRA)" <ji...@apache.org>.
    [ https://issues.apache.org/activemq/browse/AMQNET-181?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=53690#action_53690 ] 

Alistair Young commented on AMQNET-181:
---------------------------------------

Using the broker embedded in Camel:

Apache Camel 1.5.0
camel-jms 1.6.0
activemq-camel 5.2.0

machine:

OS X 10.5.8
java version "1.5.0_19"
Java(TM) 2 Runtime Environment, Standard Edition (build 1.5.0_19-b02-304)
Java HotSpot(TM) Client VM (build 1.5.0_19-137, mixed mode, sharing)


> ISession::CreateDurableConsumer does not work
> ---------------------------------------------
>
>                 Key: AMQNET-181
>                 URL: https://issues.apache.org/activemq/browse/AMQNET-181
>             Project: ActiveMQ .Net
>          Issue Type: Bug
>          Components: Stomp
>    Affects Versions: 1.1.0
>         Environment: ActiveMQ .NET 1.1.0 Release
> Windows XP
> .NET 3.5
>            Reporter: Alistair Young
>            Assignee: Jim Gomes
>            Priority: Minor
>             Fix For: 1.2.0
>
>
> the following code results in a non durable subscription to the ActiveMQ topic with an ActiveMQ generated consumer ID. Using the normal 61616 port and connection works fine.
> using Apache.NMS;
> using Apache.NMS.ActiveMQ;
> using Apache.NMS.ActiveMQ.Commands;
> Uri connectURI = new Uri("activemq:tcp://host.com:61613?transport.wireformat=stomp");
> ConnectionFactory connectionFactory = new ConnectionFactory(connectURI);
> IConnection connection = connectionFactory.CreateConnection();
> connection.ClientId = "DurableClientId";
> connection.Start();
> connection.ExceptionListener += new ExceptionListener(OnException);
> ISession session = connection.CreateSession(AcknowledgementMode.DupsOkAcknowledge);
> ActiveMQTopic topic = new ActiveMQTopic("test.t");
> IMessageConsumer consumer = session.CreateDurableConsumer(topic, "DurableClientId", "2 > 1", false);
> consumer.Listener += new MessageListener(OnMessage);
> Console.WriteLine("Press any key to exit...");
> Console.ReadKey();

-- 
This message is automatically generated by JIRA.
-
You can reply to this email to add a comment to the issue online.