WebSocket local event publisher is an internal event publisher that comes with WSO2 products by default. You can configure it with XML, text, and JSON output mapping types.
The websocket-local event publisher should be used when the CEP publishes to a websocket client. Websocket clients need to connect to the inbuilt websocket server of WSO2 CEP for the events to be published. However, when the CEP publishes to a web socket server, the CEP should connect to the websocket server in order to publish events. In such scenarios, use the WebSocket Event Publisher.
Creating a WebSocket local event publisher
For instructions on creating a WebSocket local event publisher, see Configuring CEP to Create Alerts.
Configuring global properties
The following global properties can be set for WebSocket local event publisher type in the <CEP_HOME>/repository/conf/input-event-adapters.xml file. These properties apply to all the publishers of the web socket-local type. If a global property available by default is removed, the default value of the property is considered.
Custom properties cannot be added as global properties.
| Property Key | Description | Data Type | Default Value |
|---|---|---|---|
minThread | The minimum number of threads (including idle threads) that should be available in the thread pool at a given time. | Integer | 8 |
maxThread | The maximum number of threads (including idle threads) that should be available in the thread pool at a given time. | Integer | 100 |
keepAliveTimeInMillis | The maximum number of milliseconds that idle threads should be kept alive when the total number of threads in the pool exceeds the number of cores in the machine. | Integer | 20000 |
jobQueueSize | The maximum number of milliseconds that idle threads should be kept alive when the total number of threads in the pool exceeds the number of cores in the machine. | Integer | 10000
|
Configuring adapter properties
There are not any adapter-specific properties for the WebSocket local event publisher as shown below.
Related samples
For more information on websocket-local event publisher type, see the following sample.