amqp-pipeline.conf

input {
	tcp {
		host => "127.0.0.1"
		port => 5045
		codec => json
		mode => "server"
	}
}

filter {

}

output {
	rabbitmq {
        durable => true
        exchange => ""
        exchange_type => "direct"
        heartbeat => 60
        host => "127.0.0.1"
        key => "canids"
        persistent => false
        port => 5672
        user => "canids"
        password => "management"
        vhost => "/"
    }
}