Unable to consume a message from ActiveMQ topic

[rajeshk150 (rajesh krishna)]

Hi,

I am unable to consume a message from activemq topic. The topic with the given name will be created in activemq but when I send a message for that topic, I am unable to consume the same message in logstash. The activemq version used is 5.15.8, logstash version is 6.6.2
The configurations are as below.
Logstash config file followed by jms.yml file.

input {
                  jms {
                    include_header => true
                    include_properties => true
                    include_body => true
                    use_jms_timestamp => true
                    interval => 10
                	destination => "TOPIC1"
                	pub_sub => true
                    yaml_file => "C:/Rajesh/Elk/logstash-6.6.2/config/jms.yml"
                    yaml_section => "activemq"
                  }
                }
            activemq:
              :broker_url: tcp://localhost:61616
              :username: admin
              :password: admin
              :runner: consumer
              :factory: org.apache.activemq.ActiveMQConnectionFactory
              :require_jars:
                - C:/Rajesh/Elk/logstash-6.6.2/config/activemq-all-5.15.8.jar

[rajeshk150 (rajesh krishna)]

I am able to connect for an activemq queue and consume a message just by the config pub_sub: false attribute. But not able to consume a message from activemq topic.
Please help me with the same.
Even I am able to consume an activemq queue message with jndi configuration as below, but not able to consume a topic message.

jndi:

      :jndi_name: ConnectionFactory

      :jndi_context:
        java.naming.factory.initial: org.apache.activemq.jndi.ActiveMQInitialContextFactory
        java.naming.provider.url: tcp://localhost:61616
        java.naming.security.principal: admin
        java.naming.security.credentials: admin

      :require_jars:
        - C:/Rajesh/Elk/logstash-6.6.2/config/activemq-all-5.15.8.jar

[rajeshk150 (rajesh krishna)]

I am able to connect to the activemq topic and consume the message using the stomp plugin, but not able to do the same using the jms plugin. It would be helpful for us if we can achieve the same in jms plugin. Appreciate the suggestions and solutions for this query.

Thank You.