[
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)
