[
https://issues.apache.org/jira/browse/NIFI-4463?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16226843#comment-16226843
]
ASF GitHub Bot commented on NIFI-4463:
--------------------------------------
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
----
> MQTT client disconnection in ConsumeMQTT Processor
> --------------------------------------------------
>
> Key: NIFI-4463
> URL: https://issues.apache.org/jira/browse/NIFI-4463
> Project: Apache NiFi
> Issue Type: Bug
> Components: Core Framework
> Affects Versions: 1.3.0
> Environment: OS: Centos /
> MQTT Borker: mosquitto
> Reporter: Stefano Melzi
> Priority: Minor
>
> When internal queue is full the messageArrived method throws an exception
> causing the MQTT client to disconnect. This event is managed creating a new
> client which try to reconnect to the broker.
> In our test using a mosquitto broker with a high mqtt traffic and a low value
> for "Max Queue Size" property we experiment broker disconnection when
> internal queue is full, but after this event MQTT Processor remains blocked
> without any attempt to reconnect.
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
