Heka issue1235

gistfile1.txt

[hekad]
maxprocs = 2
base_dir = "/tmp/cache"
pid_file = "/tmp/hekad.pid"
share_dir = "/usr/share/heka"

[log1]
type = "LogstreamerInput"
log_directory = "/var/log/"
file_match = 'yum\.log'
parser_type = 'token'

[log2]
type = "LogstreamerInput"
log_directory = "/var/log/"
file_match = 'messages'
parser_type = 'token'

[amqp-output1]
type = "AMQPOutput"
url = "amqp://usr:usr@localhost"
exchange = "heka-test"
exchange_type = "topic"
exchange_durability = true
exchange_auto_delete = false
routing_key = "hdp1"
persistent = false
message_matcher = 'Logger =~ /^log1/'

[amqp-output2]
type = "AMQPOutput"
url = "amqp://usr:usr@localhost"
exchange = "heka-test"
exchange_type = "topic"
exchange_durability = true
exchange_auto_delete = false
routing_key = "hdp2"
persistent = true
message_matcher = 'Logger =~ /^log2/'

Queued message samples:

Exchange 	heka-test
Routing Key 	hdp2
Redelivered 	●
Properties 	
timestamp:	1420574648
delivery_mode:	2
content_type:	application/hekad
Payload 160 bytes Encoding: base64 	
...

Exchange 	heka-test
Routing Key 	hdp1
Redelivered 	○
Properties 	
timestamp:	1420574648
delivery_mode:	1
content_type:	application/hekad
Payload 128 bytes Encoding: base64 	
...