Contents

# encoding: utf-8

require File.join(File.dirname(__FILE__), '..', 'helper')

class TestRouting < ZmqTestCase
  def test_flow
    ctx = ZMQ::Context.new
    router = ctx.bind(:ROUTER, "inproc://test.routing-flow")
    dealer = ctx.socket(:DEALER)
    dealer.identity = "xyz"
    dealer.connect("inproc://test.routing-flow")

    router.sendm("xyz")
    router.send("request")
    assert_equal "request", dealer.recv

    dealer.send("reply")
    assert_equal "xyz", router.recv
    assert_equal "reply", router.recv
  ensure
    ctx.destroy
  end

  def test_transfer
    ctx = ZMQ::Context.new
    router = ctx.bind(:ROUTER, "inproc://test.routing-transfer")
    dealer = ctx.socket(:DEALER)
    dealer.identity = "xyz"
    dealer.connect("inproc://test.routing-transfer")

    router.send_frame ZMQ::Frame("xyz"), ZMQ::Frame::MORE
    router.send_frame ZMQ::Frame("request")

    assert_equal ZMQ::Frame("request"), dealer.recv_frame

    req = ZMQ::Message.new
    req.push ZMQ::Frame("request")
    req.push ZMQ::Frame("xyz")
    router.send_message req

    msg = dealer.recv_message
    assert_equal ZMQ::Frame("request"), msg.pop
  ensure
    ctx.destroy
  end

  def test_distribution
    ctx = ZMQ::Context.new
    router = ctx.bind(:ROUTER, "inproc://test.routing-distribution")
    thread = Thread.new do
      dealer = ctx.socket(:DEALER)
      dealer.identity = "xyz"
      dealer.connect("inproc://test.routing-distribution")
      frame = dealer.recv_frame
      dealer.close
      frame
    end

    sleep 0.5 # "slow joiner" syndrome
    router.send_frame ZMQ::Frame("xyz"), ZMQ::Frame::MORE
    router.send_frame ZMQ::Frame("message")
    assert_equal ZMQ::Frame("message"), thread.value
  ensure
    ctx.destroy
  end
end

Version data entries

23 entries across 23 versions & 1 rubygems

Version	Path
rbczmq-0.3	test/socket/test_routing.rb
rbczmq-0.2	test/socket/test_routing.rb
rbczmq-0.1	test/socket/test_routing.rb