Operator WebSocketSend

IBMStreams streamsx.inetserver Toolkit > com.ibm.streamsx.inetserver 4.3.4 > com.ibm.streamsx.inet.wsserver > WebSocketSend

Operator transmits tuples recieved on the input port via WebSocket protocol to connected clients. Upon startup, this operator is registered to the common pe-wide jetty web server. Clients may connect to the websocket context under /input/0/wssend. The prefix for the URLs is:
  • context path/base operator name - When the context parameter is set.
  • full operator name - When the context parameter is not set.

As tuple arrives on the input port a message is triggered and transmitted to all currently connected clients. Clients can connect and disconnect at anytime.

HTTPS Support and Sharing the Jetty Server

see also namespace:com.ibm.streamsx.inet

Summary

Ports
This operator has 1 input port and 0 output ports.
Windowing
This operator does not accept any windowing configurations.
Parameters
This operator supports 14 parameters.

Optional: binaryMessageAttributeName, certificateAlias, context, contextResourceBase, enableConnectionControlMessages, host, keyPassword, keyStore, keyStorePassword, port, sslAppConfigName, textMessage, trustStore, trustStorePassword

Metrics
This operator reports 4 metrics.

Properties

Implementation
Java

Input Ports

Ports (0)

Input port: Tuples received on this port generate a message to be transmitted over to all connected websocket clients. The content of the transmitted message is determined with parameter textMessage or binaryMessageAttributeName. If both parameters are absend, the input tuple is converted into a JSON formatted messages and transmitted to all currently connected clients

Properties

Parameters

This operator supports 14 parameters.

Optional: binaryMessageAttributeName, certificateAlias, context, contextResourceBase, enableConnectionControlMessages, host, keyPassword, keyStore, keyStorePassword, port, sslAppConfigName, textMessage, trustStore, trustStorePassword

binaryMessageAttributeName

The input attribute name which is used as binary message. The type of this attribute must be blob. If this parameter is set, parameter textMessage is not allowed.

Properties
certificateAlias

Alias of the certificate to use in the key store. When this parameter is set all connections use HTTPS and parameters keyStore and keyPassword are required.

Properties
context

Define a URL context path that maps to the resources defined by contextResourceBase. This allows a composite that invokes this operator in a toolkit to provide resources regardless of the value of the application's data directory. For example setting it to maps would result in the URL /maps/index.html mapping to the file index.html in the directory defined by contextResourceBase. Requires the parameter contextResourceBase to be set. If when the operator is initialized the context already exists then no action is taken. This allows multiple independent composites in the same toolkit to have common context and contextResourceBase settings, typically to point to a single set of HTML and Javascript resources for the toolkit.

If the operator provides URLs for its input or output ports then they are placed in the this context when this parameter is set. This then provides fixed locations for the URLs regardless of the depth of the operator invocation in the main composite.

Only a single context per invocation is supported.

Properties
contextResourceBase

Directory location of resources that will be available through the the URL context defined by the parameter context. Typically used to allow a toolkit to provide a set of resources in a fixed location. The set of resources is recommended to be stored in the application_dir/opt directory, which is automatically included in the bundle by default. Path of this directory can be absolute or relative, if relative path is specified then it is relative to the application directory. A set of default resources is included in the toolkit directory under ToolkitDir/opt/resources and will be loaded by the operator. This default resources can be viewed at http://hostname:8080/streamsx.inet.resources. A path within the application is obtained using the SPL function getThisToolkitDir(). Thus a composite in the file maps.spl in the namespace directory com.acme.streams.apps.map might have the following setting to map http://127.0.0.1:8080/maps to opt/resources/mapinfo in the application.

param
  context: “maps”
  contextResourceBase: getThisToolkitDir() + “/opt/resources/mapinfo”

If this parameter is applied parameter contextResourceBase is required too.

Properties
enableConnectionControlMessages

If this parameteter is true, the operator sends out a connection control message to all connected websocket clients, when a client gets connected or disconnected. Default is true.

Properties
host

You can configure a host either as a host name or IP address to identify a specific network interface on which to listen. If not set, or set to the value of 0.0.0.0, the integrated jetty server listens on all local interfaces.

Properties
keyPassword

Password to the private key.

Properties
keyStore

URL to the key store containing the certificate. If a relative file path then it is taken as relative to the application directory.

Properties
keyStorePassword

Password to the key store.

Properties
port

Port number for the embedded Jetty HTTP server, default: "8080". If the port is set to 0, the jetty server uses a free tcp port, and the metric serverPort delivers the actual value.

Properties
sslAppConfigName
The operator can get the SSL server key/certificate and the client trust material from Streams application configuration with this name. If this parameter is present, certificateAlias, keyStore, keyPassword, trustStore and trustStorePassword are not allowed. The application configuration must contain the folowing properties:
  • server.jks - Base 64 encoded representation of the Java key store with one key-certificate pair to be used as server key and certitficate.
  • server.pass -Password for server.jks (and its key) and cacerts.jks.
The app configuration may contain property:
  • cacerts.jks - Base 64 encoded representation of the Java trust store with the client trust material.
If the property cacerts.jks is present, the operator requests client certificates. To create the Streams application configuration you may use a comand like:
streamtool mkappconfig --description 'server cert and trust store' --property "server.jks=$(base64 --wrap=0 etc/keystore.jks)" --property "server.pass=password" --property "cacerts.jks=$(base64 --wrap=0 etc/cacerts.jks)" streams-certs
Properties
textMessage

The input attribute which is used as text message. The attribute must be of type rstring or ustring. If this parameter is set, parameter binaryMessageAttributeName is not allowed.

Properties
trustStore

URL to the trust store containing client certificates. If a relative file path then it is taken as relative to the application directory. When this parameter is set, client authentication is required.

Properties
trustStorePassword

Password to the trust store.

Properties

Metrics

https - Gauge

Jetty SSL/TLS status: 0=HTTP, 1=HTTPS.

nClientsConnected - Gauge

Number of clients currently connected to the operators WebSocket context.

nMessagesSent - Counter

Number of messages sent using WebSocket (cumulative sum for all connected clients)

serverPort - Gauge

Jetty (HTTP/HTTPS) server port if the operator hosts the server, 0 otherwise

Libraries

Operator class library
Library Path: ../../impl/lib/com.ibm.streamsx.inetserver.jar