com.ibm.streamsx.iot.spl

Class IotSPLStreams

java.lang.Object

com.ibm.streamsx.iot.spl.IotSPLStreams

public class IotSPLStreams
extends java.lang.Object

IBM Watson IoT Platform SPL streams. These streams using the microservice model promoted by the com.ibm.streamsx.iot toolkit. In order to interact with IoT Platform the SPL application com.ibm.streamsx.iot.watson.apps::IotfOrganization must be running.

Method Summary

Modifier and Type	Method and Description
static void	commandPublish(com.ibm.streamsx.topology.spl.SPLStream commandStream)
static com.ibm.streamsx.topology.spl.SPLStream	commandsSubscribe(com.ibm.streamsx.topology.TopologyElement te, java.lang.String[] typeIds, java.lang.String... cmdId) Subscribe to sent device commands as SPL tuples.
static com.ibm.streamsx.topology.spl.SPLStream	eventsSubscribe(com.ibm.streamsx.topology.TopologyElement te, java.lang.String[] typeIds, java.lang.String... eventId) Subscribe to device events as SPL tuples.
static com.ibm.streamsx.topology.spl.SPLStream	statusesSubscribe(com.ibm.streamsx.topology.TopologyElement te, java.lang.String... typeId)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

eventsSubscribe

public static com.ibm.streamsx.topology.spl.SPLStream eventsSubscribe(com.ibm.streamsx.topology.TopologyElement te,
                                                                      java.lang.String[] typeIds,
                                                                      java.lang.String... eventId)

Subscribe to device events as SPL tuples. Subscribes to all device events with event identifiers listed in eventId. If eventId is empty or passed as a null array then all device events are subscribed to. To receive device events the SPL application com.ibm.streamsx.iot.watson.apps::IotfOrganization must be running in the same Streams instance.

Parameters:

te - Topology to create this source in.

eventId - Event identifiers to subscribe to. If no event identf

Returns:

Stream containing device events.

See Also:

IotStreams.eventsSubscribe(TopologyElement, String...)

statusesSubscribe

public static com.ibm.streamsx.topology.spl.SPLStream statusesSubscribe(com.ibm.streamsx.topology.TopologyElement te,
                                                                        java.lang.String... typeId)

commandsSubscribe

public static com.ibm.streamsx.topology.spl.SPLStream commandsSubscribe(com.ibm.streamsx.topology.TopologyElement te,
                                                                        java.lang.String[] typeIds,
                                                                        java.lang.String... cmdId)

Subscribe to sent device commands as SPL tuples. Subscribes to all device commands with command identifiers listed in cmdId. If cmdId is empty or passed as a null array then all device commands are subscribed to. To receive device events the SPL application com.ibm.streamsx.iot.watson.apps::IotfOrganization must be running in the same Streams instance.

Parameters:

te - Topology to create this source in.

cmdId - Command identifiers to subscribe to. If no command identifier is passed then all commands are subscribed to.

Returns:

Stream containing device events.

See Also:

IotStreams.eventsSubscribe(TopologyElement, String...)

commandPublish

public static void commandPublish(com.ibm.streamsx.topology.spl.SPLStream commandStream)