Date: Thu, 28 Mar 2024 22:08:52 +0100 (CET) Message-ID: <371558394.69.1711660132891@vmisdata19.uni-oldenburg.de> Subject: Exported From Confluence MIME-Version: 1.0 Content-Type: multipart/related; boundary="----=_Part_68_1447058466.1711660132890" ------=_Part_68_1447058466.1711660132890 Content-Type: text/html; charset=UTF-8 Content-Transfer-Encoding: quoted-printable Content-Location: file:///C:/exported.html
The WebsocketServer transport handler allows the propagation of = results over Websockets as a server. This transport handler can be used in = both directions, other client can connect to this server to receive data an= d to publish data.
port: The port to listen for connections
input = =3D ACCESS({ transport =3D 'websocketserver', wrapper =3D 'GenericPush', source =3D 'source', datahandler =3D 'keyvalueobject', options=3D[['port','3453']] =20 } =20 ) ) output =3D SENDER({ protocol =3D 'json', transport =3D 'websocketserver', sink =3D 'auction2_json', wrapper =3D 'GenericPush', options=3D[['port','3452']] =20 }, TOKEYVALUE(System.nexmark:auction2) =20 )
let ws = =3D new WebSocket("ws://localhost:3452"); ws.binaryType =3D 'arraybuffer'; let decoder =3D new TextDecoder('UTF-8'); ws.onmessage =3D function(m) { =09=09console.log(decoder.decode(m.data)) };