Difference between revisions of "Plugin:AMQP"
From collectd Wiki
(→See also: Add links to Git repositories.) |
(→Synopsis: Adapt to new configuration schema.) |
||
| Line 14: | Line 14: | ||
<Plugin "amqp"> | <Plugin "amqp"> | ||
| − | Host "localhost" | + | # Send values to an AMQP broker |
| − | + | <Publish "some_name"> | |
| − | + | Host "localhost" | |
| − | + | Port "5672" | |
| − | Password " | + | VHost "/" |
| − | + | User "guest" | |
| − | # RoutingKey " | + | Password "guest" |
| − | # Persistent false | + | Exchange "amq.fanout" |
| − | # StoreRates false | + | # RoutingKey "collectd" |
| + | # Persistent false | ||
| + | # StoreRates false | ||
| + | </Publish> | ||
| + | |||
| + | # Receive values from an AMQP broker (work in progress) | ||
| + | <Subscribe "some_name"> | ||
| + | Host "localhost" | ||
| + | Port "5672" | ||
| + | VHost "/" | ||
| + | User "guest" | ||
| + | Password "guest" | ||
| + | Exchange "amq.fanout" | ||
| + | # ExchangeType "fanout" | ||
| + | # Queue "queue_name" | ||
| + | # RoutingKey "collectd" | ||
| + | # Persistent false | ||
| + | # StoreRates false | ||
| + | </Subscribe> | ||
</Plugin> | </Plugin> | ||
Revision as of 09:55, 6 August 2010
| AMQP plugin | |
|---|---|
| Type: | write |
| Callbacks: | config, shutdown, write |
| Status: | in development |
| First version: | 5.0 |
| Copyright: | 2009 Sebastien Pahl 2010 Florian Forster |
| License: | MIT license |
| Manpage: | collectd.conf(5) |
| List of Plugins | |
The AMQP plugin sends the values collected by collectd via the Advanced Message Queuing Protocol (AMQP) to a "message broker" – a daemon relaying the messages. Messages are encoded in JSON and can be send in either persistent (guaranteed delivery) and transient (higher efficiency but values may be lost) delivery mode.
Synopsis
<Plugin "amqp">
# Send values to an AMQP broker
<Publish "some_name">
Host "localhost"
Port "5672"
VHost "/"
User "guest"
Password "guest"
Exchange "amq.fanout"
# RoutingKey "collectd"
# Persistent false
# StoreRates false
</Publish>
# Receive values from an AMQP broker (work in progress)
<Subscribe "some_name">
Host "localhost"
Port "5672"
VHost "/"
User "guest"
Password "guest"
Exchange "amq.fanout"
# ExchangeType "fanout"
# Queue "queue_name"
# RoutingKey "collectd"
# Persistent false
# StoreRates false
</Subscribe>
</Plugin>
Dependencies
See also
- The RabbitMQ homepage
- The sp/amqp branch in octo's repository on Github.
- The amqp branch in Sebastien's repository on Github.
