Documentation
¶
Index ¶
- func Exchange(name string) func(*AMQPTransport)
- func New(url string, options ...func(*AMQPTransport)) transport.Transport
- func NewAMQPResponseWriter(trans *AMQPTransport, delivery amqp.Delivery) transport.ResponseWriter
- func QueueName(name string) func(*AMQPTransport)
- type AMQPResponseWriter
- type AMQPTransport
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func Exchange ¶
func Exchange(name string) func(*AMQPTransport)
Exchange option to set exchange name, default "nano".
func New ¶
func New(url string, options ...func(*AMQPTransport)) transport.Transport
New returns a Transport that use AMQP to send/receive RPC messages.
func NewAMQPResponseWriter ¶
func NewAMQPResponseWriter(trans *AMQPTransport, delivery amqp.Delivery) transport.ResponseWriter
func QueueName ¶
func QueueName(name string) func(*AMQPTransport)
QueueName option to set queue name, default name of go binary.
Types ¶
type AMQPResponseWriter ¶
type AMQPResponseWriter struct {
// contains filtered or unexported fields
}
func (*AMQPResponseWriter) Write ¶
func (rw *AMQPResponseWriter) Write(data interface{}) error
type AMQPTransport ¶
type AMQPTransport struct {
// contains filtered or unexported fields
}
func (*AMQPTransport) Listen ¶
func (trans *AMQPTransport) Listen() error
func (*AMQPTransport) Receive ¶
func (trans *AMQPTransport) Receive() <-chan transport.Request
Source Files
Click to show internal directories.
Click to hide internal directories.