gistfile1.builder

require 'connamara_api'
require 'serializer/protobuf/protobuf'
require 'pub/activemq/publisher'

include Connamara

## start
config = {'connect_string'=>"tcp://localhost:61616"}
api = ConnamaraAPI.run( config, Connamara::ProtoBuf, Connamara::AMQPublisher )

## publish
api.publish( :Execution, :Quantity=>100.5, :Price=>10.4025, :UpdateTime=>Time.now )

## subscribe
api.subscribe( :Position ) { |position| puts "I got a position: " + position.inspect }

## error callback
api.error { |err| puts "received an error " + err.inspect }

## stop
api.stop
exit!