Logstash-input-jms [CLIENT_ACKNOWLEDGE]

Elastic Stack Logstash
1

Hello,

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

Ali

2

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