Interfaces and Adapters

Integration of system components should be as painless as possible. In most cases, the Coral8 Engine and the Aleri Streaming Platform can be non-intrusively integrated with existing systems. As long as there's a way to get data out of your existing system, you can stream it or load it into Aleri. Similarly, an Aleri CEP engine can output data in whatever format and via whatever mechanism (in some cases via adapters) you need to make it easy to get the results to where you need them.

The CEP server needs to be integrated with data sources and data consumers. Data sources provide data into the CEP server – whether it’s streaming event data or data that’s loaded from databases or files. The data flows through the business logic running on the server to produce results. The results are typically streamed out to one or more data consumers, either directly or via a message bus. Results are also available on-demand via SQL queries.

Integrating with Data Sources and Data Consumers

Both the Coral8 and Aleri platforms provide a range of built-in connectors (aka adapters) to connect to common data producers and consumers. These built-in connectors are included in the standard product package.
Aleri also offers range of optional add-on adapters that extend the connectivity options. These adapters are sold and installed separately. Aleri is constantly adding new connectors and adapters, so if you don’t see what you need here, check with us. We might already have it, have plans to have it soon, or else we’d be happy to build it for you. Alternatively you can use our pub/sub API (publish/subscribe) to build your own connectors.

Input adapters include:

Coral8 Platform

Aleri Platform

Socket: with XML, CSV and FIX parsing

Built-in

Built-in

JMS: with support for data in CSV, XML, FIX and JMS Object Array formats

Built-in

Built-in

Database - JDBC (one time and periodically polled)

Built-in

Built-in

File: with XML, CSV and FIX parsing

Built-in

Built-in

Aleri Platform (receive an output stream from another Aleri server)

Built-in

Built-in

Reuters Marketfeed

n/a

Add-on

Reuters OMM (Market Price, Market-by-Order, and Market-by-Price)

Add-on

Add-on

ACTIV Financial

n/a

Add-on

Wombat

Third party

Add-on

FIX 4.2/4.4

n/a

Add-on

Trading Technologies

n/a

Add-on

OpenAdapter™ (openadapter.org)

n/a

Add-on

IBM Websphere MQ 6.0.1 (both input and output)

Add-on

Add-on

TIBCO Rendezvous 7.4.1 (both input and output)

Add-on

Add-on

SWIFT

n/a

Add-on

Atlas

n/a

Add-on

SOAP

Built-in

Add-on

Regular Expression parsing

Built-in

Add-on

Windows Event Log

Built-in

--

Log files (including Web Logs)

Built-in

--

SNMP

Built-in

--

Ganglia

Built-in

--

RSS feeds

Built-in

--

ATOM feeds

Built-in

--

RTI DDS

Third party

--

Tealeaf CX

Third party

--

Radware Inflight

Third party

--

IBM RFID Info. Center

Third party

--

Output adapters include:

Corel8 Platform

Aleri Platform

Streaming output via socket in XML, CSV, or FIX

Built-in

Built-in

Publish output via JMS – data in CSV, XML, FIX or JMS Object Array format

Built-in

Built-in

Capture output in RDBMS via JDBC connection

Built-in

Built-in

Output to file in XML, CSV or FIX

Built-in

Built-in

Stream output to another Aleri server

Built-in (see note

Built-in

Generate email: Mail server (SMTP)

above)

Built-in

Reuters RMDS Publisher (Marketfeed and OMM)

Built-in

Add-on

OpenAdapter™ (openadapter.org)

n/a

Add-on

IBM Websphere MQ 6.0.1 (both input and output)

 

--

TIBCO Rendezvous 7.4.1 (both input and output)

Add-on

--

Regular Expression parsing

Add-on

--

Sybase RAP

Built-in

Built-in

Wombat

Built-in

--

RTI DDS

Third party

--

IBM RFID Info. Center

Third party

--

Database Connectors for:

Corel8 Platform

Aleri Platform

Sybase

Built-in

Add-on

Oracle

Built-in

Add-on

Microsoft SQL Server

Built-in

Add-on

Netezza

Built-in

Add-on

Teradata

Built-in

Add-on

kdb+

Built-in

Add-on

Generic RPC

Built-in

--

Programming Interfaces:

  • Publish-Subscribe API – used to stream event data into the CEP server, and to subscribe to output streams from the CEP server. Available for C++, Java and .NET. The Coral8 platform also includes SDKs for Perl and Python.
  • User Defined Function Interface – used to link external function libraries that can be called from within expressions in an event model running on the CEP server.
  • On-Demand Query Interface – allows you to run SQL queries against retained data sets (windows) in the CEP server. Delivers a snapshot as a response (SQL queries for an image followed by updates can be issued using the pub/sub API). Available as ODBC and JDBC.