[jira] [Commented] (ARTEMIS-550) Add support for virtual topic consumers

[Benjamin Graf (JIRA)]

    [ 
https://issues.apache.org/jira/browse/ARTEMIS-550?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16339220#comment-16339220
 ] 

Benjamin Graf commented on ARTEMIS-550:
---------------------------------------

Hi [~gtully]

I created a test case which only works if the queue is created explicitly 
before.
{code:java}
 @Test
    public void testVirtualTopicViaFQQN() throws Exception {
        ConnectionFactory factory = new 
org.apache.activemq.artemis.jms.client.ActiveMQConnectionFactory(urlString);
        server.createQueue(new SimpleString("TEST_TOPIC"),
                RoutingType.MULTICAST,
                new SimpleString("VirtualTopicConsumers.test"),
                null, true, false, -1, false, true);
        try (Connection connection = factory.createConnection()) {
            connection.start();
            Session session = connection.createSession(false, 
Session.AUTO_ACKNOWLEDGE);
            Topic topic = session.createTopic("TEST_TOPIC");
            Queue queue = 
session.createQueue("TEST_TOPIC::VirtualTopicConsumers.test");
            MessageConsumer consumer1 = session.createConsumer(queue);
            MessageProducer producer = session.createProducer(topic);
            producer.send(session.createMessage());
            Message m = consumer1.receive(2000);
            assertNotNull(m);
        }
    }
 {code}
 

> Add support for virtual topic consumers
> ---------------------------------------
>
>                 Key: ARTEMIS-550
>                 URL: https://issues.apache.org/jira/browse/ARTEMIS-550
>             Project: ActiveMQ Artemis
>          Issue Type: Improvement
>          Components: Broker
>    Affects Versions: 1.3.0
>            Reporter: Benjamin Graf
>            Assignee: Martyn Taylor
>            Priority: Major
>
> Artemis should support virtual topic consumers as alternative to topic 
> subscriptions as ActiveMQ itself does.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)