Note on Update

Changes that have been made to this repository since the fork:

• Modified timestamp so that milliseconds are used instead of seconds.

Desired modifications necessary before pull-request can be issued:

• Allow for configuring timestamp resolution via RabbitMQ configuration file.

RabbitMQ Message Timestamp Plugin

This plugin fills the timestamp property of a message as it enters RabbitMQ with the current (server node) timestamp value.

Supported RabbitMQ Versions

This plugin targets RabbitMQ 3.6.0 and later versions.

Installing

Clone the repo and then build it with make:

cd rabbitmq-message-timestamp
make
# [snip]
make dist
# [snip]
ls plugins/*

Build artefacts then can be found under the plugins directory.

Finally copy plugins/rabbitmq_message_timestamp.ez to the $RABBITMQ_HOME/plugins folder.

Usage

Just enable the plugin with the following command:

rabbitmq-plugins enable rabbitmq_message_timestamp

The plugin will then hook into the basic.publish process in order to add the current timestamp as seen by the broker.

Limitations

The plugin hooks into the basic.publish path, so expect a small throughput reduction when using this plugin, since it has to modify every message that crosses RabbitMQ.

This plugin should not be enabled at the same time as any other interceptors that hook into the basic.publish process, such as the rabbitmq-routing-node-stamp plugin. Enabling more than one interceptor that is registered to the basic.publish process will cause all AMQP 0-9-1 connections to fail when creating a new channel.

If there's enough demand, we could add in the future a way for only time-stamping messages that crosses certain exchanges, say by applying policies.

LICENSE

See the LICENSE file