AMQP

AMQP is a standard wire-protocol for message queueing. Many systems implement AMQP endpoints for interoperability with multiple data sources. It is a standard wire-protocol rather than as standard API-protocol (such as JMS), making it a good choice as an endpoint implementation-agnostic method for reliably feeding data to remote systems.

While CxAnalytix does not feed data in real-time, sending record entries as messages to an AMQP endpoint allows for some advanced near-realtime and stream analytics applications. AMQP supports the concept of an Exchange which can be used to deliver records to different Queues based on header or topic routing criteria. The routing criteria can then be used, for example, to place messages in queues feeding applications covering disparate areas of concern.

Record feeds are compatible with pseudo transactions using the transactional publishing semantics. Headers and routing keys can be set with static values and/or values composed of fields from each record entry using a key format specifier.