EDDIE Framework

Appearance

Outbound-connector for AMQP ​

The outbound-connector for AMQP offers functionality to connect EDDIE to an AMQP 1.0 compatible broker. It has been tested with RabbitMQ 4.0.

Topology ​

INFO

For information regarding the topic naming scheme see Topic Naming Scheme

The outbound-connector defines a basic topology for interacting with EDDIE. The following topics are created upon starting this outbound-connector:

  • ep.${outbound-connector.amqp.eddie-id}.agnostic.connection-status-message: Provides status change updates related to a permission request
  • ep.${outbound-connector.amqp.eddie-id}.agnostic.raw-data-message: Provides messages from the region connectors as is, with additional metadata
  • ep.${outbound-connector.amqp.eddie-id}.agnostic.opaque-envelope: Provides forwarded opaque envelopes
  • ep.${outbound-connector.amqp.eddie-id}.cim_0_82.permission-md: Provides permission market documents
  • ep.${outbound-connector.amqp.eddie-id}.cim_0_82.validated-historical-data-md: Provides validated historical data market documents
  • ep.${outbound-connector.amqp.eddie-id}.cim_1_12.near-real-time-data-md: Provides near real-time data market documents
  • ep.${outbound-connector.amqp.eddie-id}.cim_1_12.acknowledgement-md: Provides acknowledgement market documents
  • ep.${outbound-connector.amqp.eddie-id}.cim_1_12.min-max-envelope-md: Provides forwarded min-max envelopes
  • ep.${outbound-connector.amqp.eddie-id}.cim_0_82.accounting-point-md: Provides accounting point market documents
  • fw.${outbound-connector.amqp.eddie-id}.cim_0_82.termination-md: Allows the eligible party to send termination documents to terminate a permission request.
  • fw.${outbound-connector.amqp.eddie-id}.cim_0_91_08.retransmissions: Allows the eligible party to send redistribution transaction request documents to request validated historical data again.
  • fw.${outbound-connector.amqp.eddie-id}.cim_1_12.min-max-envelope-md: Allows the eligible party to send min-max envelopes.
  • ep.${outbound-connector.amqp.eddie-id}.cim_1_12.energy-sharing-reference-data-md: Provides the eligible party with Energy Sharing Reference Data Market Documents.
  • fw.${outbound-connector.amqp.eddie-id}.agnostic.permission-command: Allows the eligible party to send permission commands to remotely control an active permission (adjust the transmission schedule, enable/disable transmission, or terminate).
  • fw.${outbound-connector.amqp.eddie-id}.agnostic.opaque-envelope: Allows the eligible party to send opaque envelopes to a region connector.

Properties of messages ​

The following properties are set by EDDIE for outbound messages and can be used for further routing the messages between exchanges and queues.

  • permission-id: The permission ID that is related to this message
  • connection-id: The connection ID that is related to this and other messages provided by the eligible upon creation of the permission request
  • data-need-id: The data need ID related to this message

Configuration ​

The following configuration values are supported by the AMQP outbound-connector:

Configuration valuesTypeDefaultDescription
outbound-connector.amqp.enabledtrue or falsefalseEnables or disables the outbound-connector.
outbound-connector.amqp.formatxml or jsonjsonSets the format of the messages that are sent and received.
outbound-connector.amqp.uriURISets the URI of the AMQP 1.0 broker.
outbound-connector.amqp.eddie-idStringSets the ID of the eddie instance in relation to the amqp broker.

.properties file ​

Example configuration for an application.properties file:

properties
outbound-connector.amqp.enabled=true
outbound-connector.amqp.format=json
outbound-connector.amqp.uri=amqp://user:password@localhost:5672
outbound-connector.amqp.eddie-id=eddie
yaml
outbound-connector:
  amqp:
    enabled: true
    format: json
    uri: amqp://user:password@localhost:5672
    eddie-id: eddie
dotenv
OUTBOUND_CONNECTOR_AMQP_ENABLED=true
OUTBOUND_CONNECTOR_AMQP_FORMAT=json
OUTBOUND_CONNECTOR_AMQP_URI=amqp://user:password@localhost:5672
OUTBOUND_CONNECTOR_AMQP_EDDIE_ID=eddie