Basic Architecture Diagram


To provide event forwarding, the AMQP Events package requires:

  • AMQP endpoint configuration, where the following information about an existing AMQP endpoint must be entered:

    Endpoint alias - serving as reference for multiple event forwarding configurations

    Protocol version - showing the used version of the AMQP protocol

    Connection properties - indicating the version-specific location of the actual endpoint, e.g. URI or host, port, etc.

    Destination properties - providing information about the actual version-specific queue or topic on that location, i.e. name, routing key, etc.

  • AMQP event forwarding configuration - where the following information must be entered:

    Endpoint alias - linking to the endpoint where the events should be forwarded

    Event group - specifying the type of events to listen for

    Event format - specifying the format of the event's body

    Event properties - specifying properties by which the received events will be filtered (event group specific), as well as formatting properties (event format specific)

Additional Features

  • REST endpoints for management of forwarding configurations

    • Specific user role required ("Permission - REST AMQP - Event Forwarding Manager")

  • Additional preset configurations

    • Connection recovery interval

    • Unused connections cleanup interval

    • Preset AMQP endpoint configuration

  • Metrics for events

    • Messages count and size

    • Cumulative and rate per 1/5/15 minutes


Specific Information

  • Invalid configurations throw relevant exceptions and raise alerts. This provides a clear visibility for problems.

  • Requests which are unsuccessful due to potentially recoverable issues are put into "waitlists" and are automatically retried when the underlying problem is resolved. For example, an event forwarding configuration which relies on a not yet created AMQP endpoint configuration will be automatically activated when the relevant AMQP endpoint configuration is created.