Package software.amazon.awssdk.crt.iot
Class StreamingOperation
- java.lang.Object
-
- software.amazon.awssdk.crt.CrtResource
-
- software.amazon.awssdk.crt.iot.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.
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from class software.amazon.awssdk.crt.CrtResource
CrtResource.ResourceInstance
-
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
close()
void
open()
Triggers the streaming operation to start listening to the configured stream of events.-
Methods inherited from class software.amazon.awssdk.crt.CrtResource
addRef, addReferenceTo, collectNativeResource, collectNativeResources, decRef, getNativeHandle, getResourceLogDescription, isNull, logNativeResources, logNativeResources, removeReferenceTo, setDescription, waitForNoResources
-
-
-
-
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.
-
close
public void close()
- Specified by:
close
in interfaceAutoCloseable
- Overrides:
close
in classCrtResource
-
-