Skip to content

Commit 90e519a

Browse files
ivantseppjosephlewis42
authored andcommitted
Add interface to MessageFutureCallback for performance (#18)
Remove callback for performance
1 parent d4e5160 commit 90e519a

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

lib/logstash/outputs/pubsub/message_future_callback.rb

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -3,6 +3,8 @@ module Outputs
33
module Pubsub
44
# Implements ApiFutureCallback<String>
55
class MessageFutureCallback
6+
include com.google.api.core.ApiFutureCallback
7+
68
def initialize(message_body, logger)
79
@message_body = message_body
810
@logger = logger

0 commit comments

Comments
 (0)