recv_mds

Documentation

Overview

Outputs to demonstrate different broker's algorithms for balancing messages across multiple subscriptions to the same queue. (One go routine per subscription). In this example all subscriptions share the same connection/session. The actual results can / will likely be slightly surprising. YMMV.

Prime the queue for this demonstration using publish.go.

Examples:

	# Prime a queue with messages:
	STOMP_PORT=61613 STOMP_NMSGS=10 go run publish.go
	# Review ActiveMQ balancing characteristics.  Note:
	# this will eventually block, and the program will have to be
	# forcibly stopped.
	STOMP_PORT=61613 STOMP_ACKMODE="client-individual" go run recv_mds.go

	# Prime a queue with messages again:
	STOMP_PORT=62613 STOMP_NMSGS=10 go run publish.go
	# Review Apollo balancing characteristics.  Note:
	# this will eventually block, and the program will have to be
	# forcibly stopped.
	STOMP_PORT=62613 STOMP_ACKMODE="client-individual" go run recv_mds.go