search

IBMStreams / streamsx.iot

(Incubation) Provide the ability to have an IBM Streams application easily interact with IoTF, either in Bluemix (Streaming Analytics Service) or on-premises (IBM Streams).
http://ibmstreams.github.io/streamsx.iot
Apache License 2.0
7 stars 12 forks source link

Support Scalable Application model #23

Closed ddebrunner closed 8 years ago

ddebrunner commented 8 years ago

See the "Scalable Application" section of:

https://docs.internetofthings.ibmcloud.com/applications/mqtt.html

Thoughts are that if the IotfOrganization app (actually its composite) is parallelized using UDP then the MQTT source would use a client id starting with "A" so that the device events (etc.) are distributed between the N (UDP width) MQTTSource operators.

ddebrunner commented 8 years ago

using scalable applications requires non-durable connections, which is an issue here at streamsx.messaging.

https://github.com/IBMStreams/streamsx.messaging/issues/61