[
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)
