Support Questions

Find answers, ask questions, and share your expertise

How to use Notify and Wait in Apache Nifi version 2.0.0

avatar
Explorer

I am facing an issue with Notify and Wait starting from version 2.0.0. In order for them to listen to each other in version 1.28, I need to configure them with the MapCacheClientService 2.0.0 and MapCacheServer 2.0.0 services. However, in version 2.0.0, although I can still find both services in the documentation, in practice, the configuration only includes the MapCacheClientService 2.0.0 service, and I can no longer find the MapCacheServer 2.0.0 service.

DuyChan_0-1733304440018.png

Using Wait and Notify in version 2.0.0 seems much more difficult compared to previous versions. I spent two days trying to figure it out, but I haven't made any progress. If possible, could you please guide me on the correct configuration so that Wait and Notify can work properly, like they did in the older versions?

1 ACCEPTED SOLUTION

avatar
Explorer

@SAMSAL MapCacheClientService provides the ability to communicate with a MapCacheServer. I can find MapCacheServer in Add Controller Service

DuyChan_0-1733395091145.png

It seems like I have found a solution to my issue.

Thank you

View solution in original post

2 REPLIES 2

avatar
Super Guru

Hi @DuyChan ,

Have you tried using DistributedMapCacheClientService & DistributedMapCacheClientServer instead. Im not sure what is the difference with the MapCacheClientService but it should do the same job. Also be aware because of size limitation Nifi is not being published with all packages and in case you dont find services or processors that should be part of nifi , you probably need to download jar\nar pacakge from maven repositories and save to the Nifi Lib Folder:

https://mvnrepository.com/artifact/org.apache.nifi/nifi-hazelcast-services-api-nar/2.0.0

https://mvnrepository.com/artifact/org.apache.nifi/nifi-distributed-cache-client-service-api

If that helps please accept the solution.

Thanks

 

avatar
Explorer

@SAMSAL MapCacheClientService provides the ability to communicate with a MapCacheServer. I can find MapCacheServer in Add Controller Service

DuyChan_0-1733395091145.png

It seems like I have found a solution to my issue.

Thank you