Alex McLain amclain

amclain / zmq-rep-router.rb

Last active August 29, 2015 13:56

	# require 'ffi-rzmq'
	require 'zeromqrb'

	# socket_path = 'tcp://127.0.0.1:5050'
	socket_path = 'ipc://zmq_hello_world.ipc'

	# ctx = ZMQ::Context.create
	ctx = ZeroMQ::Context.new

	# Server

amclain / zmq-multicast.rb

Created February 20, 2014 19:06

	require 'ffi-rzmq'
	require 'timeout'

	# socket_path = 'tcp://127.0.0.1:5050'
	# socket_path = 'ipc://zmq_pub_sub.ipc'
	socket_path = 'epgm://eth0;239.0.0.1:5050'

	ctx = ZMQ::Context.create

	# Subscriber

amclain / mqtt_reconstruct_object.rb

Created February 17, 2014 04:05

	# Convert an object to JSON, push it over MQTT,
	# and reconstruct the object.

	require 'mqtt'
	require 'json'

	# ip = '192.168.0.61'
	ip = '10.0.1.27'

	send = OpenStruct.new val_1:123, val_2:456

amclain / zmq_pub_sub_no_topic_hello_world.rb

Created February 17, 2014 04:02

	require 'ffi-rzmq'
	require 'timeout'

	socket_path = 'tcp://127.0.0.1:5050'
	# socket_path = 'ipc://zmq_pub_sub.ipc'

	ctx = ZMQ::Context.create

	# Subscriber
	sub_thread = Thread.new do

amclain / zmq_pub_sub_hello_world.rb

Created February 17, 2014 03:42

	require 'ffi-rzmq'
	require 'timeout'

	socket_path = 'tcp://127.0.0.1:5050'
	# socket_path = 'ipc://zmq_pub_sub.ipc'

	ctx = ZMQ::Context.create

	# Subscriber
	sub_thread = Thread.new do

amclain / zmq_req_rep_hello_world.rb

Last active August 29, 2015 13:56

	require 'ffi-rzmq'

	# socket_path = 'tcp://127.0.0.1:5050'
	socket_path = 'ipc://zmq_hello_world.ipc'

	ctx = ZMQ::Context.create

	# Server
	thread = Thread.new do
	rep_sock = ctx.socket ZMQ::REP