activemq-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Ari Tilli (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (ARTEMIS-535) Improve amqp protocol to support topics
Date Fri, 03 Jun 2016 12:26:59 GMT

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

Ari Tilli commented on ARTEMIS-535:
-----------------------------------

Now already spamming this JIRA entry :(:(  , but even with setting link -> durable : False
, which according to source should leave terminus-durability = 0,  still no sucess..

Added code clearly though checks values 1,2 -> durable , 0  -> temporary, so I think
I will have to check this later with Wireshark if this qpid-c++ bug, or something in proton
code in 
Artemis. 

if (isPubSub) {
 +               // if we are a subscription and durable create a durable queue using the
container id and link name
 +               if (TerminusDurability.UNSETTLED_STATE.equals(source.getDurable()) ||
 +                                TerminusDurability.CONFIGURATION.equals(source.getDurable()))
{
 +                  String clientId = connection.getRemoteContainer();
 +                  String pubId = sender.getName();
 +                  queue = clientId + ":" + pubId;
 +                  boolean exists = sessionSPI.queueQuery(queue);
 +                  if (!exists) {
 +                     sessionSPI.createDurableQueue(source.getAddress(), queue);
 +                  }
 +               }
 +               //otherwise we are a volatile subscription
 +               else {
 +                  queue = java.util.UUID.randomUUID().toString();
 +                  try {
 +                     sessionSPI.createTemporaryQueue(source.getAddress(), queue);
 +                  }
 +                  catch (Exception e) {
 +                     throw ActiveMQAMQPProtocolMessageBundle.BUNDLE.errorCreatingTemporaryQueue(e.getMessage());
 +                  }
 +                  source.setAddress(queue);
 +               }
 +
 +            }
 +            else {
 +               queue = source.getAddress();
 +            }

> Improve amqp protocol to support topics
> ---------------------------------------
>
>                 Key: ARTEMIS-535
>                 URL: https://issues.apache.org/jira/browse/ARTEMIS-535
>             Project: ActiveMQ Artemis
>          Issue Type: New Feature
>          Components: AMQP
>            Reporter: Andy Taylor
>            Assignee: Andy Taylor
>




--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

Mime
View raw message