Introducing the sps_duplex gem

The sps_duplex gem allows 2 way communication using the SimplePubSub broker.

Example

require 'simplepubsub'

SimplePubSub::Broker.start port: '55000'

The communications monitor shows what messages are being published to the messaging broker.

require 'sps-sub'

sps = SPSSub.new host: '127.0.0.1', port: '55000'

sps.subscribe(topic: '#') do |msg, topic|
  puts "%s: %s " % [topic, msg]
end

require 'sps_duplex'

chan = SPSDuplex.new host: '127.0.0.1', port: 55000

require 'sps_duplex'

chan = SPSDuplex.new host: '127.0.0.1', port: 55000, sub_topic: 'node2', pub_topic: 'node1'

chan.send 'hello'

Observed (from node 1):

node2: hello

chan.send 'hello2'

Observed (from node 2):

node1: hello2

From the communications monitor screen the following output was observed:

Connected
chan1/node2: hello 
chan1/node1: hello2

chat communication messaging sps gem sps_duplex spsduplex