Class: LogStash::Outputs::Pubsub::MessageFutureCallback

Inherits:

Object

• Object
• LogStash::Outputs::Pubsub::MessageFutureCallback

Defined in:

lib/logstash/outputs/pubsub/message_future_callback.rb

Overview

Implements ApiFutureCallback<String>

Instance Method Summary

• #initialize(message_body, logger) ⇒ MessageFutureCallback constructor

  A new instance of MessageFutureCallback.

• #on_failure(throwable) ⇒ Object

  Implements public void onFailure(Throwable t).

• #on_success(message_id) ⇒ Object

  Implements public void onSuccess(String messageId).

Constructor Details

#initialize(message_body, logger) ⇒ MessageFutureCallback

Returns a new instance of MessageFutureCallback.

# File 'lib/logstash/outputs/pubsub/message_future_callback.rb', line 6

def initialize(message_body, logger)
  @message_body = message_body
  @logger = logger
end

Instance Method Details

#on_failure(throwable) ⇒ Object

Implements public void onFailure(Throwable t)

# File 'lib/logstash/outputs/pubsub/message_future_callback.rb', line 17

def on_failure(throwable)
  @logger.error("Failed to send message.", message: @message_body, error: throwable.getMessage)
end

#on_success(message_id) ⇒ Object

Implements public void onSuccess(String messageId)

# File 'lib/logstash/outputs/pubsub/message_future_callback.rb', line 12

def on_success(message_id)
  @logger.debug("Published #{@message_body} with id: #{message_id}")
end