I'm using the plugin logstash input jms.
I modified the jruby-jms-1.2.0-java library ( I modified acknowledgment mode )
JMS::Session::AUTO_ACKNOWLEDGE TO JMS::Session::CLIENT_ACKNOWLEDGE
options: any of the JMS::Session constants:
# Note: :options are ignored if transacted: true # JMS::Session::AUTO_ACKNOWLEDGE # With this acknowledgment mode, the session automatically acknowledges # a client's receipt of a message either when the session has successfully # returned from a call to receive or when the message listener the session has # called to process the message successfully returns. # JMS::Session::CLIENT_ACKNOWLEDGE # With this acknowledgment mode, the client acknowledges a consumed # message by calling the message's acknowledge method. # JMS::Session::DUPS_OK_ACKNOWLEDGE # This acknowledgment mode instructs the session to lazily acknowledge # the delivery of messages. # JMS::Session::SESSION_TRANSACTED # This value is returned from the method getAcknowledgeMode if the # session is transacted. # Default: JMS::Session::AUTO_ACKNOWLEDGE
I use an output elasticsearch.
I want to retrieve the response of the output elasticsearch in my code input jms to call message's acknowledge method.
Is there a global variable that allows me to do that?
Or a way to communicate input and output?
Thank you in advance