Module: ZMQ

Defined in:
lib/jrzmq.rb,
lib/jrzmq/components.rb,
lib/jrzmq/zmq_classes.rb,
lib/jrzmq/zmq_constants.rb

Defined Under Namespace

Classes: Context, Message, PollItem, Poller, Socket, ZMQQueue

Constant Summary collapse

SNDMORE = 
org.jeromq.ZMQ::SNDMORE
SNDTIMEO = 
ZMQ::ZMQ_SNDTIMEO
RCVTIMEO = 
ZMQ::ZMQ_RCVTIMEO
DONTWAIT = 
org.jeromq.ZMQ::DONTWAIT
NOBLOCK = 
org.jeromq.ZMQ::NOBLOCK
PAIR = 
org.jeromq.ZMQ::PAIR
PUB = 
org.jeromq.ZMQ::PUB
SUB = 
org.jeromq.ZMQ::SUB
REQ = 
org.jeromq.ZMQ::REQ
REP = 
org.jeromq.ZMQ::REP
DEALER = 
org.jeromq.ZMQ::DEALER
XREQ = 
org.jeromq.ZMQ::XREQ
ROUTER = 
org.jeromq.ZMQ::ROUTER
XREP = 
org.jeromq.ZMQ::XREP
PULL = 
org.jeromq.ZMQ::PULL
PUSH = 
org.jeromq.ZMQ::PUSH
XPUB = 
org.jeromq.ZMQ::XPUB
XSUB = 
org.jeromq.ZMQ::XSUB
STREAMER = 
org.jeromq.ZMQ::STREAMER
FORWARDER = 
org.jeromq.ZMQ::FORWARDER
QUEUE = 
org.jeromq.ZMQ::QUEUE
UPSTREAM = 
org.jeromq.ZMQ::UPSTREAM
DOWNSTREAM = 
org.jeromq.ZMQ::DOWNSTREAM
POLLIN = 
org.jeromq.ZMQ::POLLIN
POLLOUT = 
org.jeromq.ZMQ::POLLOUT
POLLERR = 
org.jeromq.ZMQ::POLLERR
SUBSCRIBE = 
ZMQ::ZMQ_SUBSCRIBE
UNSUBSCRIBE = 
ZMQ::ZMQ_UNSUBSCRIBE
IDENTITY =

EVENT_CONNECTED = org.jeromq.ZMQ::EVENT_CONNECTED

EVENT_DELAYED = org.jeromq.ZMQ::EVENT_DELAYED

EVENT_RETRIED = org.jeromq.ZMQ::EVENT_RETRIED

EVENT_CONNECT_FAILED = org.jeromq.ZMQ::EVENT_CONNECT_FAILED

EVENT_LISTENING = org.jeromq.ZMQ::EVENT_LISTENING

EVENT_BIND_FAILED = org.jeromq.ZMQ::EVENT_BIND_FAILED

EVENT_ACCEPTED = org.jeromq.ZMQ::EVENT_ACCEPTED

EVENT_ACCEPT_FAILED = org.jeromq.ZMQ::EVENT_ACCEPT_FAILED

EVENT_CLOSED = org.jeromq.ZMQ::EVENT_CLOSED

EVENT_CLOSE_FAILED = org.jeromq.ZMQ::EVENT_CLOSE_FAILED

EVENT_DISCONNECTED = org.jeromq.ZMQ::EVENT_DISCONNECTED

EVENT_ALL = org.jeromq.ZMQ::EVENT_ALL

ZMQ::ZMQ_IDENTITY
LINGER = 
ZMQ::ZMQ_LINGER

Class Method Summary collapse

Class Method Details

.initialize_logger ⇒ Object 



12
13
14
15
16
17
18
 
# File 'lib/jrzmq.rb', line 12

def initialize_logger
  require_jars(%w(logback-access logback-classic logback-core logback-site slf4j-api))
  rootLogger = Java::OrgSlf4j::LoggerFactory.getLogger(Java::ChQosLogbackClassic::Logger.java_class)
  rootLoggerLogLevel = Java::ChQosLogbackClassic::Level::DEBUG
  rootLogger.setLevel(rootLoggerLogLevel)
  rootLogger.info "Root Logger Log Level was set to: #{rootLoggerLogLevel}"
end

.poll(items, timeout) ⇒ Object 



21
22
23
 
# File 'lib/jrzmq/components.rb', line 21

def poll(items, timeout)
  org.jeromq.ZMQ.poll(items, timeout)
end

.read(data) ⇒ Object 



13
14
15
 
# File 'lib/jrzmq/components.rb', line 13

def read(data)
  EDN.read(data)
end

.require_jars(*names) ⇒ Object 



20
21
22
23
24
 
# File 'lib/jrzmq.rb', line 20

def require_jars(*names)
  names.flatten.each do |name|
    require "#{name}.jar"
  end
end

.write(data) ⇒ Object 



17
18
19
 
# File 'lib/jrzmq/components.rb', line 17

def write(data)
  data.to_edn
end