Class: Client::Message

Inherits:
Object
  • Object
show all
Includes:
Rocketmq::C
Defined in:
lib/rocketmq-client-ruby/client/message.rb

Overview

Message module

Constant Summary

Constants included from Rocketmq::C

Rocketmq::C::ConsumeStatus, Rocketmq::C::MessageModel, Rocketmq::C::MessageProperty, Rocketmq::C::SendStatus, Rocketmq::C::Status, Rocketmq::C::TransactionStatus

Instance Method Summary collapse

Methods included from Rocketmq::C

attach_function_maybe

Constructor Details

#initialize(topic) ⇒ Message

Returns a new instance of Message.



8
9
10
 
# File 'lib/rocketmq-client-ruby/client/message.rb', line 8

def initialize(topic)
  @message = CreateMessage(topic)
end

Instance Method Details

#[](key) ⇒ Object 



36
37
38
 
# File 'lib/rocketmq-client-ruby/client/message.rb', line 36

def [](key)
  get_property(key)
end

#[]=(key, value) ⇒ Object 



40
41
42
 
# File 'lib/rocketmq-client-ruby/client/message.rb', line 40

def []=(key, value)
  set_property(key, value)
end

#get_property(key) ⇒ Object 



28
29
30
 
# File 'lib/rocketmq-client-ruby/client/message.rb', line 28

def get_property(key)
  GetMessageProperty(@message, key)
end

#raw ⇒ Object 



44
45
46
 
# File 'lib/rocketmq-client-ruby/client/message.rb', line 44

def raw
  @message
end

#set_body(body) ⇒ Object 



20
21
22
 
# File 'lib/rocketmq-client-ruby/client/message.rb', line 20

def set_body(body)
  SetMessageBody(@message, body)
end

#set_delay_time_level(delay_time_level) ⇒ Object 



32
33
34
 
# File 'lib/rocketmq-client-ruby/client/message.rb', line 32

def set_delay_time_level(delay_time_level)
  SetDelayTimeLevel(@message, delay_time_level)
end

#set_keys(keys) ⇒ Object 



12
13
14
 
# File 'lib/rocketmq-client-ruby/client/message.rb', line 12

def set_keys(keys)
  SetMessageKeys(@message, keys)
end

#set_property(key, value) ⇒ Object 



24
25
26
 
# File 'lib/rocketmq-client-ruby/client/message.rb', line 24

def set_property(key, value)
  SetMessageProperty(@message, key, value)
end

#set_tags(tags) ⇒ Object 



16
17
18
 
# File 'lib/rocketmq-client-ruby/client/message.rb', line 16

def set_tags(tags)
  SetMessageTags(@message, tags)
end