RabbitMQ

The RabbitMQ output can send messages to an externally accessible RabbitMQ broker. For real-time analytics, a message will be sent to RabbitMQ for each output feature sent to the output. For big data analytics, after processing completes, all messages will be sent to RabbitMQ, with one message for each record.

For more information on RabbitMQ, see RabbitMQ.

Example

  • An analyst configures a real-time analytic to process and analyze events ingested by a feed and then sends the resulting features to a RabbitMQ broker.
  • After performing analysis in a big data analytic, a researcher wants to send the output spatial or tabular features to a RabbitMQ broker.

Usage notes

  • The RabbitMQ broker must be externally accessible on the Internet.

Parameters

ParameterDescriptionData Type

Host

The hostname of the RabbitMQ broker.

String

Port

The port on which the RabbitMQ broker is available.

Integer

Use SSL

Specifies whether or not to use SSL in the connection.

Boolean

Virtual Host (optional)

The virtual host of the RabbitMQ broker.

Username (optional)

The username for the RabbitMQ broker.

Note:

This parameter is necessary if the RabbitMQ queue specified is secured.

String

Password (optional)

The password for the RabbitMQ broker.

Note:

This parameter is necessary if the RabbitMQ queue specified is secured.

Password

Exchange Name (optional)

Specifies the exchange the RabbitMQ output will connect to. The output can connect to either an exchange or a queue.

If both are specified, the exchange will be used.

String

Exchange Type

Specifies the RabbitMQ AMQP exchange type. Options include:

  • None
  • Direct
  • Fanout
  • Topic

String

Declare the exchange

Specifies whether or not to declare the exchange. Options include:

  • True - The exchange will be declared. If the exchange already exists, select the same exchange type and durability.
  • False - The exchange must already exist.

Boolean

Exchange Durability

Specifies whether the exchange will survive a restart.

Boolean

Routing Key (optional)

A comma-separated list of keys or topics used to bind a queue to the direct or topic exchanges.

String

Queue Name (optional)

Specifies the queue the RabbitMQ output will connect to. The output can connect to either an exchange or a queue.

If both are specified, the exchange will be used.

String

Declare the Queue

Specifies whether or not to declare the queue. Options include:

  • True - The queue will be declared. If the queue already exists, select the same queue attributes.
  • False - The queue must already exist.

Boolean

Queue Durability

Specifies whether the queue will survive a restart.

Boolean

Queue AutoDelete

Specifies whether the server will delete the queue when no longer in use.

Boolean

Queue Exclusive

Specifies whether the queue is restricted to this connection.

Boolean

Considerations and limitations

  • The RabbitMQ broker must be externally accessible on the Internet.