input {
    tcp {
        port => 5002
    }

    rabbitmq {
        user => '<username>'
        password => '<password>'
        durable => true
        host => <host>
        port => <port>
        queue => '<rabbitmq_queue>'
        metadata_enabled => true
    }
}

filter {
	ruby {
		code => "event.to_hash.each { |k, v|
			event.remove(k)}"
	}

	mutate {
        add_field => {
              "rabbitmq_headers"           => "%{[@metadata][rabbitmq_headers]}"
              "rabbitmq_properties"            => "%{[@metadata][rabbitmq_properties]}"
              "rabbitmq_payload"             => "%{[@metadata][rabbitmq_payload]}"
        }
    }
}


output {
     s3 {
            access_key_id => "<your_key_id>"
            secret_access_key => "your_access_key"
            region => "us-east-1"
            bucket => "<your_bucket>"
            size_file => 1024
            time_file => 5
            encoding => "gzip"
            canned_acl => "private"
            temporary_directory => "C:/logstash-5.2.1/bin/temp"
			validate_credentials_on_root_bucket => false
            prefix => 'billing'
			codec => 'json_lines'
    }
}