activemq-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "ASF GitHub Bot (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (ARTEMIS-550) Add support for virtual topic consumers
Date Fri, 26 Jan 2018 16:52:02 GMT

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

ASF GitHub Bot commented on ARTEMIS-550:
----------------------------------------

Github user gtully commented on a diff in the pull request:

    https://github.com/apache/activemq-artemis/pull/1820#discussion_r164162902
  
    --- Diff: artemis-jms-client/src/main/java/org/apache/activemq/artemis/jms/client/ActiveMQSession.java
---
    @@ -698,8 +699,17 @@ private ActiveMQMessageConsumer createConsumer(final ActiveMQDestination
dest,
                  */
                 if (!response.isExists() || !response.getQueueNames().contains(dest.getSimpleAddress()))
{
                    if (response.isAutoCreateQueues()) {
    +                  SimpleString queueNameToUse = dest.getSimpleAddress();
    +                  SimpleString addressToUse = queueNameToUse;
    +                  RoutingType routingTypeToUse = RoutingType.ANYCAST;
    +                  if (CompositeAddress.isFullyQualified(queueNameToUse.toString())) {
    +                     CompositeAddress compositeAddress = CompositeAddress.getQueueName(queueNameToUse.toString());
    +                     addressToUse = new SimpleString(compositeAddress.getAddress());
    +                     queueNameToUse = new SimpleString(compositeAddress.getQueueName());
    +                     routingTypeToUse = RoutingType.MULTICAST;
    --- End diff --
    
    The original test case that I added to, had both artemis and openwire jms clients in the
mix, a parameterised test. It may be that the vt use case needs to be constrained to openwire
because I think your expectation is correct. I guess in the case that the address already
existed I may be able to find the routing type there. 
    But when both address and queue need to be created core would be out of luck.



> 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
>         Attachments: image-2018-01-26-09-02-08-192.png
>
>
> 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)

Mime
View raw message