If I understand you correctly you are trying to do something that works with 
JMS and SQL in atomic fashion. Possibly (and that is purely a guess) you are 
having some XA transactional concerns. . .
If so, that may be a bit counter-intuitive to micro-services nature of NiFi 
processors where each processor is an independent service with queues in 
If that’s the case I would probably go with custom processor from scratch yet 
utilizing ControllerServices for JMS ConnectionFactory and SQL connection pool.

We can definitely help you with that, but I’ll stop right here just to see if 
you can clarify further


> On Sep 16, 2016, at 1:19 AM, Gunjan Dave <> wrote:
> Hi Oleg,
> Executesql is not the problem, but I am trying to achive something
> different here. Exevutesql was just an example.
> Based on following article,
> i was trying to export classes of my existing application onto nifi custom
> processor. Some classes have multiple database calls and i was thinking of
> how I can do it. Those classes also have mq connection, so extending only
> executesql will not help me.
> is there some other way I can use consumejms or publishjms and nifi
> sqlprocessors in my custom processor?
> I understand that I can create these functionalities by using process
> groups and specific processors on nifi ui, but was just being adventurous
> on using NiFi differently by creating business specific custom processor
> Anyone who has tried such a thing in past and give me some reference?
> Gunjan
> On Thu, Sep 15, 2016, 10:56 PM Gunjan Dave <>
> wrote:
>> Hi Nifi Team,
>> I want to create a custom processor in which I want to use the database
>> functionality.
>> Such as, i want to extract some information from database as part of
>> processor. I could Access the database controller service but how do I
>> reuse executesql processor in my custom processor?

Reply via email to