[NIFI-5825] ConsumeJMS - Not using Clientid / durable does not works

• Type: Bug
• Status: Open
• Priority: Major
• Resolution: Unresolved
• Affects Version/s: 1.8.0
• Component/s: Core Framework
• Assignee: Unassigned
• Reporter: Mermillod
• Created: 15/Nov/18 22:23
• Updated: 15/Nov/18 22:27

Description

I cannot make the ConsumeJMS 1.8.0 processor work as a "durable consumer". I set the client id, but it mis-used. I'm using ActiveMQ (AmazonMQ).

 

I set (check pictures for full details) : 

• "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").

 

 

I think the problem may be in AbstractJMSProcessor.java/buildTargetResource and we should have something like that : 

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);
}

 
But dunno how to get this "durable" prop in the Abstract during the "OnTrigger" stuff...