ini ELK JMS示例

Posted 2021-05-24

activemq:
  :factory: org.apache.activemq.ActiveMQConnectionFactory
  :broker_url: tcp://esb.example.org:61616
  :require_jars:
    - /opt/jms/libs/activemq-all-5.15.3.jar

input {
        jms {
                yaml_file => "/opt/jms/jms.yml"
                yaml_section => "activemq"
                destination => "Consumer.example.VirtualTopic.example.topic"
                include_body => true
                include_header => true
                interval => 1
                use_jms_timestamp => true
        }
}
output {
	if [MESSAGE_PRODUCER] == "EXAMPLE_SERVICE" {
        	elasticsearch {
        	       hosts => "elasticsearch:9200"
                       index => "example-%{+YYYY.MM.dd}"
        	}
  }
}