Logstash x ActiveMQ


Im trying to figure out how to set up logstash as an input for ActiveMQ. The documentation about it is not clear at all. Do I need to configure the MQ on logstash conf files(conf.d on Debian) only? Is there any other file that should be modified?

Here is my jms.conf:

input {
jms {
broker_url = "tcp://"
destination = "QUEUE"
username = "admin"
password = "admin"
output {
elasticsearch {
hosts = ["localhost:9200"]
index = "mensagens"
stdout {
codec => rubydebug
file {
path = "/var/log/logstash/jms.log"
codec = line { format => " %{@timestamp} FILA WHATSAPP ActiveMQ: %{message}"}

Do I need to change this file also?

HornetQ Broker


Connect to a local HornetQ Broker using JNDI

:jndi_name: /ConnectionFactory
java.naming.factory.initial: org.jnp.interfaces.NamingContextFactory
java.naming.provider.url: jnp://localhost:1099
java.naming.factory.url.pkgs: org.jboss.naming:org.jnp.interfaces
java.naming.security.principal: guest
java.naming.security.credentials: guest
- /Applications/hornetq-2.4.0.Final/lib/hornetq-commons.jar
- /Applications/hornetq-2.4.0.Final/lib/hornetq-core-client.jar
- /Applications/hornetq-2.4.0.Final/lib/hornetq-jms-client.jar
- /Applications/hornetq-2.4.0.Final/lib/jboss-jms-api.jar
- /Applications/hornetq-2.4.0.Final/lib/jnp-client.jar
- /Applications/hornetq-2.4.0.Final/lib/netty.jar

This topic was automatically closed 28 days after the last reply. New replies are no longer allowed.