New will create a new Relay that can be used to create new publishers or consumers. The caller should no longer modify the configuration once New is i

Max returns the highest priority number.

NewPriorityQueue returns a new priority queue from which a consumer or producer at a given priority can be easily retrieved.

Min returns the lowest priority number. This is always 0.

Publish will publish a message at a given priority. The publisher is automatically closed afterward.

RetryBroker returns a new retrying broker with the given settings.

Close will call a shutdown on all publishers we have used. By default, all publishers are kept open so that multiple calls to establish the sessions a

Consume is the public method for consuming data out of a priority queue. It will block until data is received, and returns the priority level of the c

consumer is used to connect the consumer to the relay queue.

consumer returns a new consumer with the indicated priority.

publisher returns a new publisher from the priority indicated by pri.

Converts the user input name into the actual name

discard is used to remove a broken consumer.

randomStagger returns a randomized duration +/- 25% of the input.

ConsumerWithRoutingKey will return a new handle that can be used to consume messages from a given queue and routing key.

IsDecodeFailure is a helper to determine if the error returned is a deserialization error.

PublisherWithRoutingKey will return a new handle that can be used to publish messages to the given queue and routing key.

Generates a channel name in the form of <host>.<rand> The random value is a hex encoding of 4 random bytes.

consume consumes a message from the priority queue. This is a blocking call which will watch every queue at every priority until a message is received

Ensures the given queue exists and is bound to the exchange

Used to get a new channel, possibly on a cached connection

publisher is used to connect the publisher to the relay queue.

queueName formats the name of a priority queue by appending its priority to the user-provided queue prefix.

Ack will send an acknowledgement to the server that the last message returned by Consume was processed. If EnableMultiAck is true, then all messages u

Ack marks message(s) as delivered.

ConfigFromURI attempts to parse the given AMQP URI according to the spec and return a relay config based on it. See http://www.rabbitmq.com/uri-spec.h

Consume will consume the next available message. The message must be acknowledged with Ack() or Nack() before the next call to Consume unless EnableMu

Consume consumes a single message from the queue.

ConsumeCancel allows passing in a channel to signal that we should stop trying to consume a message. Internally this channel will be checked on a shor

Consume will consume the next available message or times out waiting. The message must be acknowledged with Ack() or Nack() before the next call to Co

ConsumeTimeout consumes a single message from the queue with an upper bound on the time spent waiting.

Nack will send a negative acknowledgement to the server that the last message returned by Consume was not processed and should be redelivered. If Enab

discard is used to remove a broken publisher.

Used to get a new server connection

Watches for connection errors and closes the connection

Broker is used to wrap a Relay connection in one that is Broker compatible.

Close will shutdown the Consumer. Any messages that are still in flight will be Nack'ed.

Close will shutdown the publisher

Close will shutdown the relay. It is best to first Close all the Consumer and Publishers, as this will close the underlying connections.

Close closes the broker.

Close closes the consumer.

Close closes the publisher.

ConsumeAck will consume the next message and acknowledge that the message has been received. This prevents the message from being redelivered, and no

ConsumeAck is used to consume with automatic ack. The consume operation is able to be retried, but if a message is consumed and the acknowledgement fa

Consumer will return a new handle that can be used to consume messages from a given queue.

Consumer returns a new retrying broker.Consumer.

Nack sends message(s) back to the queue.

Publish will send the message to the server to be consumed

Publish publishes a single message to the queue. If an error is encountered, the broker automatically tries to replace the underlying channel and subm

Publisher will return a new handle that can be used to publish messages to the given queue.

Publisher returns a new retrying broker.Publisher.