DefaultDeliverer is a deliverer that publishes the specified Publishing and returns the first Delivery object with the matching correlationId.

DefaultErrorEncoder simply ignores the message.

DefaultResponsePublisher extracts the reply exchange and reply key from the request, and sends the response object to that destination.

EncodeJSONResponse marshals the response as JSON as part of the payload of the AMQP Publishing object.

EncodeNopResponse is a response function that does nothing.

NewPublisher constructs a usable Publisher for a single remote method.

NewSubscriber constructs a new subscriber, which provides a handler for AMQP Delivery messages.

NopResponsePublisher does not deliver a response to the original sender.

PublisherAfter sets the ClientResponseFuncs applied to the incoming AMQP request prior to it being decoded.

PublisherBefore sets the RequestFuncs that are applied to the outgoing AMQP request before it's invoked.

PublisherDeliverer sets the deliverer function that the Publisher invokes.

PublisherTimeout sets the available timeout for an AMQP request.

ReplyAndAckErrorEncoder serializes the error message as a DefaultErrorResponse JSON and sends the message to the ReplyTo address then Acks the original message.

ReplyErrorEncoder serializes the error message as a DefaultErrorResponse JSON and sends the message to the ReplyTo address.

SendAndForgetDeliverer delivers the supplied publishing and returns a nil response.

SetAckAfterEndpoint returns a SubscriberResponseFunc that prompts the service to Ack the Delivery object after successfully evaluating the endpoint, and before it encodes the response.

SetConsumeArgs returns a RequestFunc that set the arguments for amqp Consume function.

SetConsumeAutoAck returns a RequestFunc that sets whether or not to autoAck messages when consuming.

SetContentEncoding returns a RequestFunc that sets the ContentEncoding field of an AMQP Publishing.

SetContentType returns a RequestFunc that sets the ContentType field of an AMQP Publishing.

SetCorrelationID returns a RequestFunc that sets the CorrelationId field of an AMQP Publishing.

SetNackSleepDuration returns a RequestFunc that sets the amount of time to sleep in the event of a Nack.

SetPublishDeliveryMode sets the delivery mode of a Publishing.

SetPublishExchange returns a RequestFunc that sets the Exchange field of an AMQP Publish call.

SetPublishKey returns a RequestFunc that sets the Key field of an AMQP Publish call.

SingleNackRequeueErrorEncoder issues a Nack to the delivery with multiple flag set as false and requeue flag set as true.

SubscriberAfter functions are executed on the subscriber reply after the endpoint is invoked, but before anything is published to the reply.

SubscriberBefore functions are executed on the publisher delivery object before the request is decoded.

SubscriberErrorEncoder is used to encode errors to the subscriber reply whenever they're encountered in the processing of a request.

SubscriberErrorHandler is used to handle non-terminal errors.

SubscriberErrorLogger is used to log non-terminal errors.

SubscriberResponsePublisher is used by the subscriber to deliver response objects to the original sender.

ContextKeyAutoAck is the value of autoAck field when calling amqp.Channel.Consume.

ContextKeyConsumeArgs is the value of consumeArgs field when calling amqp.Channel.Consume.

ContextKeyExchange is the value of the reply Exchange in amqp.Publish.

ContextKeyNackSleepDuration is the duration to sleep for if the service Nack and requeues a message.

ContextKeyPublishKey is the value of the ReplyTo field in amqp.Publish.

DefaultErrorResponse is the default structure of responses in the event of an error.

Publisher wraps an AMQP channel and queue, and provides a method that implements endpoint.Endpoint.

Subscriber wraps an endpoint and provides a handler for AMQP Delivery messages.

Channel is a channel interface to make testing possible.

DecodeRequestFunc extracts a user-domain request object from an AMQP Delivery object.

DecodeResponseFunc extracts a user-domain response object from an AMQP Delivery object.

Deliverer is invoked by the Publisher to publish the specified Publishing, and to retrieve the appropriate response Delivery object.

EncodeRequestFunc encodes the passed request object into an AMQP Publishing object.

EncodeResponseFunc encodes the passed response object to an AMQP Publishing object.

ErrorEncoder is responsible for encoding an error to the subscriber reply.

PublisherOption sets an optional parameter for clients.

PublisherResponseFunc may take information from an AMQP request and make the response available for consumption.

RequestFunc may take information from a publisher request and put it into a request context.

ResponsePublisher functions are executed by the subscriber to publish response object to the original sender.

SubscriberOption sets an optional parameter for subscribers.

SubscriberResponseFunc may take information from a request context and use it to manipulate a Publisher.