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

Inherits:
Object
  • Object
show all
Defined in:
lib/logstash/outputs/pubsub/message_future_callback.rb

Overview

Implements ApiFutureCallback<String>

Instance Method Summary collapse

Constructor Details

#initialize(message_body, logger) ⇒ MessageFutureCallback

Returns a new instance of MessageFutureCallback.



8
9
10
11
 
# File 'lib/logstash/outputs/pubsub/message_future_callback.rb', line 8

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)



19
20
21
 
# File 'lib/logstash/outputs/pubsub/message_future_callback.rb', line 19

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)



14
15
16
 
# File 'lib/logstash/outputs/pubsub/message_future_callback.rb', line 14

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