Class: Rcom::Topic

Inherits:
Object
  • Object
show all
Defined in:
lib/rcom/topic.rb

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(params) ⇒ Topic

Returns a new instance of Topic.



5
6
7
8
 
# File 'lib/rcom/topic.rb', line 5

def initialize(params)
  @node = params[:node]
  @key = params[:channel]
end

Instance Attribute Details

#channel ⇒ Object (readonly)

Returns the value of attribute channel.



3
4
5
 
# File 'lib/rcom/topic.rb', line 3

def channel
  @channel
end

#node ⇒ Object (readonly)

Returns the value of attribute node.



3
4
5
 
# File 'lib/rcom/topic.rb', line 3

def node
  @node
end

Instance Method Details

#publish(message) ⇒ Object 



10
11
12
13
14
15
16
17
 
# File 'lib/rcom/topic.rb', line 10

def publish(message)
  begin
    node.publish(channel, message.to_msgpack)
    return true
  rescue
    return nil
  end
end

#subscribe ⇒ Object 



19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
 
# File 'lib/rcom/topic.rb', line 19

def subscribe
  begin
    node.subscribe(channel) do |on|
      on.message do |channel, message|
        message = MessagePack.unpack(
          message,
          symbolize_keys: true
        )
        yield message
      end
    end
  rescue
    sleep 1
    retry
  rescue Interrupt => _
  end
end