Class StreamingOperation

  • All Implemented Interfaces:
    AutoCloseable

    public class StreamingOperation
    extends CrtResource
    An AWS MQTT service streaming operation. A streaming operation listens to messages on a particular topic, deserializes them using a service model, and emits the modeled data by invoking a callback.
    • Method Detail

      • open

        public void open()
        Triggers the streaming operation to start listening to the configured stream of events. Has no effect on an already-open operation. It is an error to attempt to re-open a closed streaming operation.