Difference between revisions of "Plugin:AMQP"

From collectd Wiki
Jump to: navigation, search
(Synopsis: Remove "Persistent" from <Subscribe />)
(Update to the current state.)
Line 9: Line 9:
 
   | Manpage={{Manpage|collectd.conf|5|plugin_amqp}}
 
   | Manpage={{Manpage|collectd.conf|5|plugin_amqp}}
 
}}
 
}}
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.
+
The '''AMQP plugin''' transmits or receives values collected by ''collectd'' via the ''Advanced Message Queuing Protocol'' (AMQP). Data is sent to or received from a "message broker" – a daemon relaying messages. The values are encoded in either the [[plain text protocol]] or [[JSON]], though only the plain-text protocol can be parsed by the plugin at the moment. Messages can be sent in either ''persistent'' (guaranteed delivery) or ''transient'' (higher efficiency but values may be lost) delivery mode.
  
 
== Synopsis ==
 
== Synopsis ==
Line 24: Line 24:
 
  #  RoutingKey "collectd"
 
  #  RoutingKey "collectd"
 
  #  Persistent false
 
  #  Persistent false
 +
#  Format "command"
 
  #  StoreRates false
 
  #  StoreRates false
 
   </Publish>
 
   </Publish>
Line 38: Line 39:
 
  #  Queue "queue_name"
 
  #  Queue "queue_name"
 
  #  RoutingKey "collectd"
 
  #  RoutingKey "collectd"
 +
#  Format "command"
 
   </Subscribe>
 
   </Subscribe>
 
  </Plugin>
 
  </Plugin>

Revision as of 15:23, 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 transmits or receives values collected by collectd via the Advanced Message Queuing Protocol (AMQP). Data is sent to or received from a "message broker" – a daemon relaying messages. The values are encoded in either the plain text protocol or JSON, though only the plain-text protocol can be parsed by the plugin at the moment. Messages can be sent in either persistent (guaranteed delivery) or 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
#   Format "command"
#   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"
#   Format "command"
  </Subscribe>
</Plugin>

Dependencies

See also