You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@streampipes.apache.org by "Patrick Wiener (Jira)" <ji...@apache.org> on 2021/03/15 09:47:00 UTC
[jira] [Comment Edited] (STREAMPIPES-299) Add more advanced
configuration option to MQTT Sink
[ https://issues.apache.org/jira/browse/STREAMPIPES-299?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17295968#comment-17295968 ]
Patrick Wiener edited comment on STREAMPIPES-299 at 3/15/21, 9:46 AM:
----------------------------------------------------------------------
There is a problem when using default single value selections such that default selections are rendered in the UI, however not set when user has configured the MQTT sink.
This happened on the "last will" configuration alternative.
Thus, on invocation the MQTT sink receives a null, e.g. for will option leading to a NullPointerException
{code:java}
java.lang.NullPointerExceptionjava.lang.NullPointerException at org.apache.streampipes.sdk.extractor.AbstractParameterExtractor$$Lambda$709/000000006C5DC8D0.test(Unknown Source) at java.util.stream.ReferencePipeline$2$1.accept(ReferencePipeline.java:174) at java.util.ArrayList$ArrayListSpliterator.tryAdvance(ArrayList.java:1359) at java.util.stream.ReferencePipeline.forEachWithCancel(ReferencePipeline.java:126) at java.util.stream.AbstractPipeline.copyIntoWithCancel(AbstractPipeline.java:514) at java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:501) at java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:487) at java.util.stream.FindOps$FindOp.evaluateSequential(FindOps.java:152) at java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:241) at java.util.stream.ReferencePipeline.findFirst(ReferencePipeline.java:531) at org.apache.streampipes.sdk.extractor.AbstractParameterExtractor.selectedAlternativeInternalId(AbstractParameterExtractor.java:469) at org.apache.streampipes.sinks.brokers.jvm.mqtt.common.MqttOptions.<init>(MqttOptions.java:77) at org.apache.streampipes.sinks.brokers.jvm.mqtt.MqttClient.<init>(MqttClient.java:39) at org.apache.streampipes.sinks.brokers.jvm.mqtt.MqttPublisherSink.onInvocation(MqttPublisherSink.java:136) at org.apache.streampipes.sinks.brokers.jvm.mqtt.MqttPublisherSink.onInvocation(MqttPublisherSink.java:35)
{code}
was (Author: wiener):
There is a problem when using default single value selections such that default selections are rendered in the UI, however not set when user has configured the MQTT sink.
Thus, on invocation the MQTT sink receives a null, e.g. for will option leading to a NullPointerException
{code:java}
java.lang.NullPointerExceptionjava.lang.NullPointerException at org.apache.streampipes.sdk.extractor.AbstractParameterExtractor$$Lambda$709/000000006C5DC8D0.test(Unknown Source) at java.util.stream.ReferencePipeline$2$1.accept(ReferencePipeline.java:174) at java.util.ArrayList$ArrayListSpliterator.tryAdvance(ArrayList.java:1359) at java.util.stream.ReferencePipeline.forEachWithCancel(ReferencePipeline.java:126) at java.util.stream.AbstractPipeline.copyIntoWithCancel(AbstractPipeline.java:514) at java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:501) at java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:487) at java.util.stream.FindOps$FindOp.evaluateSequential(FindOps.java:152) at java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:241) at java.util.stream.ReferencePipeline.findFirst(ReferencePipeline.java:531) at org.apache.streampipes.sdk.extractor.AbstractParameterExtractor.selectedAlternativeInternalId(AbstractParameterExtractor.java:469) at org.apache.streampipes.sinks.brokers.jvm.mqtt.common.MqttOptions.<init>(MqttOptions.java:77) at org.apache.streampipes.sinks.brokers.jvm.mqtt.MqttClient.<init>(MqttClient.java:39) at org.apache.streampipes.sinks.brokers.jvm.mqtt.MqttPublisherSink.onInvocation(MqttPublisherSink.java:136) at org.apache.streampipes.sinks.brokers.jvm.mqtt.MqttPublisherSink.onInvocation(MqttPublisherSink.java:35)
{code}
> Add more advanced configuration option to MQTT Sink
> ---------------------------------------------------
>
> Key: STREAMPIPES-299
> URL: https://issues.apache.org/jira/browse/STREAMPIPES-299
> Project: StreamPipes
> Issue Type: Improvement
> Components: Pipeline Elements
> Reporter: Patrick Wiener
> Assignee: Patrick Wiener
> Priority: Major
> Fix For: 0.68.0
>
>
> Add more advanced configuration options to MQTT publisher, e.g. retain, QoS, will etc.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)