Documentation ¶
Overview ¶
Dozer: amqp protocol module
Index ¶
- type Context
- type DozerProtocolAmqp
- func (p *DozerProtocolAmqp) Close() error
- func (p *DozerProtocolAmqp) Dial(typ, host string, port int64) (uint64, error)
- func (p *DozerProtocolAmqp) Init(args ...string) error
- func (p *DozerProtocolAmqp) RecvFrom(id uint64, dest string, messages chan []byte, quit chan bool) error
- func (p *DozerProtocolAmqp) SendTo(id uint64, dest string, messages chan []byte, quit chan bool) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type DozerProtocolAmqp ¶
type DozerProtocolAmqp struct { sync.RWMutex Creds string // contains filtered or unexported fields }
AMQP protocol type.
func (*DozerProtocolAmqp) Close ¶
func (p *DozerProtocolAmqp) Close() error
Unsubscribe and disconnect.
func (*DozerProtocolAmqp) Dial ¶
func (p *DozerProtocolAmqp) Dial(typ, host string, port int64) (uint64, error)
Connect to a AMQP server
func (*DozerProtocolAmqp) Init ¶
func (p *DozerProtocolAmqp) Init(args ...string) error
Intialize the AMQP protocol
Click to show internal directories.
Click to hide internal directories.