You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
With the MQTT operators, we used to be support the blob format for a message.
So, the schema of the stream is this:
schema BlockMsg
So, code like this would work:
() as MQTTSink_7 = MQTTSink(BlockMsg as inPort0Alias)
{
param
topic : "data" ;
serverURI : "tcp://server:16102" ;
}
With the introduction of dataAttributeName, this code will no longer compile because we either require the attribute, or have an attribute that is named "data" on the stream.
This breaks source compatibility. In the case where we only have a single attribute, we should simply assume that the attribute is the data attribute.
The text was updated successfully, but these errors were encountered:
With the MQTT operators, we used to be support the blob format for a message.
So, the schema of the stream is this:
schema BlockMsg
So, code like this would work:
() as MQTTSink_7 = MQTTSink(BlockMsg as inPort0Alias)
{
param
topic : "data" ;
serverURI : "tcp://server:16102" ;
}
With the introduction of dataAttributeName, this code will no longer compile because we either require the attribute, or have an attribute that is named "data" on the stream.
This breaks source compatibility. In the case where we only have a single attribute, we should simply assume that the attribute is the data attribute.
The text was updated successfully, but these errors were encountered: