Event Engine Assembly

Event Processing Engine project

License	The Apache Software License, Version 2.0
Categories	Data
GroupId	com.datarpm.sigma
ArtifactId	event-engine-assembly
Last Version	1.6.1
Release Date	Jan 11, 2018
Type	tar.gz
Description	Event Engine Assembly Event Processing Engine project

Download event-engine-assembly

Filename	Size
event-engine-assembly-1.6.1.pom	1 KB
event-engine-assembly-1.6.1-bin.tar.gz	90 MB

Dependencies

There are no dependencies for this project. It is a standalone project that does not depend on any other jars.

Project Modules

There are no modules declared in this project.

Sigma Event Engine

Quick start

Install

1. Download event-engine-1.6-bin.tar.gz from releases page
2. Extract

tar -xzf event-engine-1.6-bin.tar.gz

3. Set the SIGMA_EVENTENGINE_HOME environment variable to point to extracted path
4. 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

DataRPM

Versions

Version
1.6.1 Jan 11, 2018
1.6 Jan 8, 2018