Skip to content

Commit

Permalink
add extra example to AMQPInput docs
Browse files Browse the repository at this point in the history
  • Loading branch information
ioc32 committed Sep 1, 2015
1 parent 0cba97c commit 9fc0096
Showing 1 changed file with 42 additions and 0 deletions.
42 changes: 42 additions & 0 deletions docs/source/config/inputs/amqp.rst
Original file line number Diff line number Diff line change
Expand Up @@ -107,3 +107,45 @@ following:
[leftovers.MessageFields]
Type = "drop"
Payload = ""
If the downstream heka messages are delimited by Heka's :ref:`stream_framing`,
you will need to specify "HekaFramingSplitter" as the AMQPInput splitter. An example
would look like:

.. code-block:: ini
[rsyslog-mq-input]
type = "AMQPInput"
url = "amqp://guest:guest@rabbitmq/"
exchange = "system-logs"
exchange_type = "topic"
exchange_durability = true
exchange_auto_delete = false
routing_key = "system.rsyslog"
queue = "rsyslog-logs"
queue_durability = true
queue_auto_delete = false
prefetch_count = 20
decoder = "rsyslog-multidecoder"
splitter = "HekaFramingSplitter"
[rsyslog-mq-input.retries]
max_delay = "180s"
delay = "30s"
max_retries = -1
[rsyslog-multidecoder]
type = "MultiDecoder"
subs = ["ProtobufDecoder", "rsyslog-decoder"]
cascade_strategy = "all"
log_sub_errors = true
[ProtobufDecoder]
[rsyslog-decoder]
type = "SandboxDecoder"
filename = "/usr/share/heka/lua_decoders/rsyslog.lua"
[rsyslog-decoder.config]
hostname_keep = true
template = '%TIMESTAMP% %HOSTNAME% %syslogtag%%msg:::sp-if-no-1st-sp%%msg:::drop-last-lf%\n'

0 comments on commit 9fc0096

Please sign in to comment.