Skip to content

Commit

Permalink
NIFI-11154 Removed Default Schedule from ConsumeMQTT
Browse files Browse the repository at this point in the history
Signed-off-by: Pierre Villard <[email protected]>

This closes apache#6936.
exceptionfactory authored and pvillard31 committed Feb 9, 2023

Verified

This commit was signed with the committer’s verified signature. The key has expired.
pvillard31 Pierre Villard
1 parent 8abfced commit 2e55498
Showing 1 changed file with 0 additions and 3 deletions.
Original file line number Diff line number Diff line change
@@ -24,7 +24,6 @@
import org.apache.nifi.annotation.behavior.TriggerSerially;
import org.apache.nifi.annotation.behavior.WritesAttribute;
import org.apache.nifi.annotation.behavior.WritesAttributes;
import org.apache.nifi.annotation.configuration.DefaultSchedule;
import org.apache.nifi.annotation.documentation.CapabilityDescription;
import org.apache.nifi.annotation.documentation.SeeAlso;
import org.apache.nifi.annotation.documentation.Tags;
@@ -47,7 +46,6 @@
import org.apache.nifi.processors.mqtt.common.MqttCallback;
import org.apache.nifi.processors.mqtt.common.MqttException;
import org.apache.nifi.processors.mqtt.common.ReceivedMqttMessage;
import org.apache.nifi.scheduling.SchedulingStrategy;
import org.apache.nifi.serialization.MalformedRecordException;
import org.apache.nifi.serialization.RecordReader;
import org.apache.nifi.serialization.RecordReaderFactory;
@@ -106,7 +104,6 @@
"on the topic.")})
@SystemResourceConsideration(resource = SystemResource.MEMORY, description = "The 'Max Queue Size' specifies the maximum number of messages that can be hold in memory by NiFi by a single "
+ "instance of this processor. A high value for this property could represent a lot of data being stored in memory.")
@DefaultSchedule(strategy = SchedulingStrategy.TIMER_DRIVEN, period = "1 min")
public class ConsumeMQTT extends AbstractMQTTProcessor implements MqttCallback {

public final static String RECORD_COUNT_KEY = "record.count";

0 comments on commit 2e55498

Please sign in to comment.