Class: Messaging::Messages::Message

Inherits:
Object
  • Object
show all
Defined in:
lib/messaging/messages/message.rb

Direct Known Subclasses

Events::MessagePoisoned

Class Method Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(options = {}) ⇒ Message

Returns a new instance of Message.



15
16
17
 
# File 'lib/messaging/messages/message.rb', line 15

def initialize(options = {})
  ;
end

Class Method Details

.async_publish(options = {}) ⇒ Object 



10
11
12
13
 
# File 'lib/messaging/messages/message.rb', line 10

def self.async_publish(options = {})
  message = self.new(options)
  Messaging::Kafka::MessageSender.async_publish(message)
end

.publish(options = {}) ⇒ Object 



5
6
7
8
 
# File 'lib/messaging/messages/message.rb', line 5

def self.publish(options = {})
  message = self.new(options)
  Messaging::Kafka::MessageSender.publish(message)
end

Instance Method Details

#body ⇒ Object

Raises:

  • (NotImplementedError) 


39
40
41
 
# File 'lib/messaging/messages/message.rb', line 39

def body
  raise NotImplementedError
end

#body_json ⇒ Object 



23
24
25
 
# File 'lib/messaging/messages/message.rb', line 23

def body_json
  body.merge({ message_id: message_identifier }).to_json
end

#message_identifier ⇒ Object 



31
32
33
 
# File 'lib/messaging/messages/message.rb', line 31

def message_identifier
  SecureRandom.uuid
end

#partition_key ⇒ Object 



27
28
29
 
# File 'lib/messaging/messages/message.rb', line 27

def partition_key
  nil
end

#topic ⇒ Object 



19
20
21
 
# File 'lib/messaging/messages/message.rb', line 19

def topic
  ENV.fetch('KAFKA_PREFIX', '') + topic_name
end

#topic_name ⇒ Object

Raises:

  • (NotImplementedError) 


35
36
37
 
# File 'lib/messaging/messages/message.rb', line 35

def topic_name
  raise NotImplementedError
end