Merge pull request #98 from aaqaishtyaq/queue-quorum

add quorum queue option for the consumer

Author: wagslane

consumer_options.go

@@ -282,3 +282,14 @@ func WithConsumerOptionsQOSPrefetch(prefetchCount int) func(*ConsumerOptions) {
 func WithConsumerOptionsQOSGlobal(options *ConsumerOptions) {
 	options.QOSGlobal = true
 }
+
+// WithConsumerOptionsQueueQuorum sets the queue a quorum type, which means
+// multiple nodes in the cluster will have the messages distributed amongst them
+// for higher reliability
+func WithConsumerOptionsQueueQuorum(options *ConsumerOptions) {
+	if options.QueueOptions.Args == nil {
+		options.QueueOptions.Args = Table{}
+	}
+
+	options.QueueOptions.Args["x-queue-type"] = "quorum"
+}