Class: Message::PulsarMessage

Inherits:
Object
  • Object
show all
Defined in:
lib/fluent/plugin/lib/pulsar_client/PulsarClient.rb

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize ⇒ PulsarMessage

Returns a new instance of PulsarMessage.



27
28
29
30
31
32
 
# File 'lib/fluent/plugin/lib/pulsar_client/PulsarClient.rb', line 27

def initialize()
  @client_created_id = 0
  @message_ledger_id = 0
  @message_entry_id = 0
  @message = ""
end

Instance Attribute Details

#client_created_id ⇒ Object

Returns the value of attribute client_created_id.



22
23
24
 
# File 'lib/fluent/plugin/lib/pulsar_client/PulsarClient.rb', line 22

def client_created_id
  @client_created_id
end

#message ⇒ Object

Returns the value of attribute message.



25
26
27
 
# File 'lib/fluent/plugin/lib/pulsar_client/PulsarClient.rb', line 25

def message
  @message
end

#message_entry_id ⇒ Object

Returns the value of attribute message_entry_id.



24
25
26
 
# File 'lib/fluent/plugin/lib/pulsar_client/PulsarClient.rb', line 24

def message_entry_id
  @message_entry_id
end

#message_ledger_id ⇒ Object

Returns the value of attribute message_ledger_id.



23
24
25
 
# File 'lib/fluent/plugin/lib/pulsar_client/PulsarClient.rb', line 23

def message_ledger_id
  @message_ledger_id
end