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