static StreamingOperationOptions.StreamingOperationOptionsBuilder |
StreamingOperationOptions.builder() |
Creates a new StreamingOperationOptionsBuilder instance
|
StreamingOperationOptions.StreamingOperationOptionsBuilder |
StreamingOperationOptions.StreamingOperationOptionsBuilder.withIncomingPublishEventCallback(Consumer<IncomingPublishEvent> callback) |
Sets the callback function a streaming operation should invoke every time a publish message arrives on
the operation's topic.
|
StreamingOperationOptions.StreamingOperationOptionsBuilder |
StreamingOperationOptions.StreamingOperationOptionsBuilder.withSubscriptionStatusEventCallback(Consumer<SubscriptionStatusEvent> callback) |
Sets the callback function a streaming operation should invoke whenever the underlying subscription changes
status.
|
StreamingOperationOptions.StreamingOperationOptionsBuilder |
StreamingOperationOptions.StreamingOperationOptionsBuilder.withTopic(String topic) |
Sets the MQTT topic that a streaming operation will listen for messages on
|