module Aggro::ZeroMQTransport
Public: Transport layer over nanomsg sockets.
Attributes
linger[W]
Public Instance Methods
client(endpoint)
click to toggle source
# File lib/aggro/zeromq_transport.rb, line 15 def client(endpoint) Client.new endpoint end
context()
click to toggle source
# File lib/aggro/zeromq_transport.rb, line 19 def context @context ||= ZeroMQ::Context.new end
linger()
click to toggle source
# File lib/aggro/zeromq_transport.rb, line 23 def linger @linger ||= 1_000 end
publisher(endpoint)
click to toggle source
# File lib/aggro/zeromq_transport.rb, line 27 def publisher(endpoint) Publisher.new endpoint end
server(endpoint, callable = nil, &block)
click to toggle source
# File lib/aggro/zeromq_transport.rb, line 31 def server(endpoint, callable = nil, &block) Server.new endpoint, callable, &block end
subscriber(endpoint, callable = nil, &block)
click to toggle source
# File lib/aggro/zeromq_transport.rb, line 35 def subscriber(endpoint, callable = nil, &block) Subscriber.new endpoint, callable, &block end
teardown()
click to toggle source
# File lib/aggro/zeromq_transport.rb, line 39 def teardown @context.terminate if @context @context = nil end