[ https://issues.apache.org/jira/browse/NIFI-5825?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Firenz updated NIFI-5825: ------------------------- Attachment: amq_consume.JPG > ConsumeJMS - Not using Clientid / durable does not works > -------------------------------------------------------- > > Key: NIFI-5825 > URL: https://issues.apache.org/jira/browse/NIFI-5825 > Project: Apache NiFi > Issue Type: Bug > Components: Core Framework > Affects Versions: 1.8.0 > Reporter: Firenz > Priority: Major > Attachments: amq_consume.JPG, nifi_consumejms.JPG > > > I cannot make the ConsumeJMS 1.8.0 processor working as a durable. I set the > client id, but it half-used. I'm using ActiveMQ (AmazonMQ). > > I set : > * "sub" in Connection Client Id > * "true" in durable subscription > Result in ActiveMQ : > * NIFI creates in "Durable Topic Subscribers" "sub-<increment>" (like > "sub-4" instead of "sub"). > !image-2018-11-15-23-21-51-988.png!!image-2018-11-15-23-19-49-175.png! > I think the problem may be in AbstractJMSProcessor.java/buildTargetResource > and we should have something like that : > {code:java} > String clientId = > context.getProperty(CLIENT_ID).evaluateAttributeExpressions().getValue(); > if (clientId != null) { > if (!durable){ > // we have to generate a unique, dynamique, temp, client id > clientId = clientId + "-" + clientIdCounter.getAndIncrement(); > } > cachingFactory.setClientId(clientId); > } > {code} > > But dunno how to get this "durable" prop in the Abstract during the > "OnTrigger" stuff... > > -- This message was sent by Atlassian JIRA (v7.6.3#76005)