Class: Celluloid::ZMQ::Socket::Sub

Inherits:
Celluloid::ZMQ::Socket show all
Includes:
Readable
Defined in:
lib/celluloid/zmq/socket/types.rb

Overview

SubSockets are the counterpart of PubSockets (PUB/SUB)

Instance Attribute Summary

Attributes inherited from Celluloid::ZMQ::Socket

#linger

Instance Method Summary collapse

Methods included from Readable

#bind, #connect, #read, #read_multipart

Methods inherited from Celluloid::ZMQ::Socket

#bind, #close, #connect, #get, #identity, #identity=, #set

Constructor Details

#initialize ⇒ Sub

Returns a new instance of Sub.



86
87
88
 
# File 'lib/celluloid/zmq/socket/types.rb', line 86

def initialize
  super :sub
end

Instance Method Details

#subscribe(topic) ⇒ Object 



90
91
92
93
94
 
# File 'lib/celluloid/zmq/socket/types.rb', line 90

def subscribe(topic)
  unless result_ok? @socket.setsockopt(::ZMQ::SUBSCRIBE, topic)
    fail IOError, "couldn't set subscribe: #{::ZMQ::Util.error_string}"
  end
end

#unsubscribe(topic) ⇒ Object 



96
97
98
99
100
 
# File 'lib/celluloid/zmq/socket/types.rb', line 96

def unsubscribe(topic)
  unless result_ok? @socket.setsockopt(::ZMQ::UNSUBSCRIBE, topic)
    fail IOError, "couldn't set unsubscribe: #{::ZMQ::Util.error_string}"
  end
end