Class: Gcpc::Interceptors::Publisher::PublisherNameInterceptor

Inherits:
Publisher::BaseInterceptor
  • Object
show all
Defined in:
lib/gcpc/interceptors/publisher/publisher_name_interceptor.rb

Overview

‘PublisherNameInterceptor` adds a publisher name to a message’s attributes

Instance Method Summary collapse

Constructor Details

#initialize(publisher:) ⇒ PublisherNameInterceptor

Returns a new instance of PublisherNameInterceptor.

Parameters:

  • publisher (String) 


8
9
10
 
# File 'lib/gcpc/interceptors/publisher/publisher_name_interceptor.rb', line 8

def initialize(publisher:)
  @publisher = publisher
end

Instance Method Details

#publish(data, attributes) {|data, a| ... } ⇒ Object

Parameters:

  • data (String)
  • attributes (Hash)

Yields:

  • (data, a) 


14
15
16
17
 
# File 'lib/gcpc/interceptors/publisher/publisher_name_interceptor.rb', line 14

def publish(data, attributes)
  a = attributes.merge("published_by" => @publisher)
  yield data, a
end