GitHub user dometec opened a pull request:
https://github.com/apache/nifi/pull/2241
NIFI-4463 New MQTT Consume logic
I've updated the Paho library used by this module and switch to AsyncClient
from the sync one.
I've changed the logic that manages the LinkedBlockedQueue: I use the "Max
Queue Size" parameter as an indication of how many messages the queue has to be
store, and not to set their size, since the MQTT callback method messageArrive
can be called many time after the client asks for disconnection.
I fixed the unit test for this plugin but when I tried to run mvn
-Pcontrib-check clean install in the project root the unit test is failing in
nifi-standard-processors.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/dometec/nifi mqtt-consume-new
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/nifi/pull/2241.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #2241
----
commit c9586b22dcd7ef3a263546d1e0665886439aa590
Author: Domenico Briganti <[email protected]>
Date: 2017-10-31T11:34:43Z
NIFI-4463 New MQTT Consume logic
----
---
