input {
 	rabbitmq {
		host => "localhost"
		queue => "NewQueue"
		durable => true
		key => "key"
		exchange => "amq.fanout"
		threads => 3
		prefetch_count => 50
		port => 5672
		user => "guest"
		codec => "json"
		password => "guest"
	}
}