Difference between revisions of "Plugin:AMQP"

From collectd Wiki
Jump to: navigation, search
(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
  Port "5672"
+
  <Publish "some_name">
  VHost "/"
+
    Host "localhost"
  User "collectd"
+
    Port "5672"
   Password "aiwaeZ0y"
+
    VHost "/"
  Exchange "amq.direct"
+
    User "guest"
  # RoutingKey "routing_key"
+
    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