[
https://issues.apache.org/jira/browse/NIFI-5825?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Firenz updated NIFI-5825:
-------------------------
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 :
{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...
was:
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...
> 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 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 :
> {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)
