JarCastingSigma Event Engine
Quick start
Install
- Download event-engine-1.6-bin.tar.gz from releases page
- Extract
tar -xzf event-engine-1.6-bin.tar.gz
- Set the SIGMA_EVENTENGINE_HOME environment variable to point to extracted path
- Start service
cd event-engine-1.6/
./bin/eventengine-daemon.sh start
Starts websocket listener on port 8082 (ws://locahost:8082/event-stream)
Clients
Java
Using Maven:
<dependency>
<groupId>com.datarpm.sigma</groupId>
<artifactId>event-engine-core</artifactId>
<version>1.6</version>
</dependency>
Generate event:
// prepare event builder
// code identifies event (action)
// example: USER_LOGGED_IN, USER_LOGGED_OUT, AUTHENTICATION_FAILURE
String code = "<EVENT_CODE_ID>";
EventBuilder eventBuilder = new EventBuilder(code);
// Set headers
// Used for event filtering
eventBuilder.addHeader("<headerKey>", "<headerValue>");
// Marks it as system event
SystemEventDetail systemEventDetails = new SystemEventDetail();
eventBuilder.generateSystemEvent(systemEventDetails);
// Event parameters
eventBuilder.addParam("<paramKey>", "<paramValue>");
eventBuilder.fireEvent();
Listen for an event:
EventMatchFilter matchFilter = new EventMatchFilter() {
/*
* Tests if specified eventHeader should be used for callback
*/
@Override
public boolean allow(EventHeader eventHeader) {
// Write filter logic
return true;
}
};
EventEngine.INSTANCE.addListner(matchFilter, new EventCallBack() {
@Override
public void onEvent(Event event) {
// Do something
}
});
Javascript
Refer to sigma-events-client-js
