Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AMQPParcel ¶
func (AMQPParcel) ID ¶
func (p AMQPParcel) ID() string
func (AMQPParcel) Method ¶
func (p AMQPParcel) Method() string
func (AMQPParcel) Payload ¶
func (p AMQPParcel) Payload() []byte
func (AMQPParcel) Source ¶
func (p AMQPParcel) Source() string
type AMQPTransport ¶
type AMQPTransport struct {
// contains filtered or unexported fields
}
func New ¶
func New(name, id, url string, options ...OptionsFunc) *AMQPTransport
func (*AMQPTransport) Initialize ¶
func (t *AMQPTransport) Initialize() error
func (*AMQPTransport) Shutdown ¶
func (t *AMQPTransport) Shutdown()
func (*AMQPTransport) Subscribe ¶
func (t *AMQPTransport) Subscribe(method string, subscription transport.SubscribeFunc, throughput uint) error
type OptionsFunc ¶
type OptionsFunc func(transport *AMQPTransport)
func SetConnection ¶
func SetConnection(conn *amqp.Connection) OptionsFunc
Source Files
Click to show internal directories.
Click to hide internal directories.