Contents

# encoding: utf-8

# Durable publisher to be used in conjunction with durable_sub.rb
# Justin Case <[e-mail]>

require File.join(File.dirname(__FILE__), '..', 'lib', 'ffi-rxs')

context = XS::Context.create()

# Subscriber tells us when it's ready here
sync = context.socket(XS::PULL)
sync.bind("tcp://127.0.0.1:5564")

# We send updates via this socket
publisher = context.socket(XS::PUB)
publisher.bind("tcp://127.0.0.1:5565")

# Wait for synchronization request
sync.recv_string(sync_request = '')

# Now broadcast exactly 10 updates with pause
10.times do |update_number|
  message = sprintf("Update %d", update_number)
  puts "Sending: " + message
  publisher.send_string(message)
  sleep(1)
end
  
publisher.send_string("END")

sync.close
publisher.close
context.terminate

Version data entries

4 entries across 4 versions & 1 rubygems

Version	Path
ffi-rxs-1.2.1	examples/durable_pub.rb
ffi-rxs-1.2.0	examples/durable_pub.rb
ffi-rxs-1.1.0	examples/durable_pub.rb
ffi-rxs-1.0.1	examples/durable_pub.rb