Documentation ¶
Index ¶
- func NewBackend(cfg *AmqpConfig) (v *backend, err error)
- func NewBroker(cfg *AmqpConfig) (v *broker, err error)
- type AmqpChannel
- type AmqpConfig
- func (me *AmqpConfig) Connection() string
- func (me *AmqpConfig) GetMaxChannel() int
- func (me *AmqpConfig) Host(host string) *AmqpConfig
- func (me *AmqpConfig) MaxChannel(count int) *AmqpConfig
- func (me *AmqpConfig) Password(password string) *AmqpConfig
- func (me *AmqpConfig) Port(port int) *AmqpConfig
- func (me *AmqpConfig) User(user string) *AmqpConfig
- type AmqpConnection
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewBackend ¶
func NewBackend(cfg *AmqpConfig) (v *backend, err error)
func NewBroker ¶
func NewBroker(cfg *AmqpConfig) (v *broker, err error)
Types ¶
type AmqpChannel ¶
type AmqpChannel struct { Channel *amqp.Channel Confirm chan amqp.Confirmation Cancel chan string }
type AmqpConfig ¶
type AmqpConfig struct { Host_ string `json:"Host"` Port_ int `json:"Port"` User_ string `json:"User"` Password_ string `json:"Password"` MaxChannel_ int `json:"MaxChannel"` }
func DefaultAmqpConfig ¶
func DefaultAmqpConfig() *AmqpConfig
func (*AmqpConfig) Connection ¶
func (me *AmqpConfig) Connection() string
func (*AmqpConfig) GetMaxChannel ¶
func (me *AmqpConfig) GetMaxChannel() int
func (*AmqpConfig) Host ¶
func (me *AmqpConfig) Host(host string) *AmqpConfig
func (*AmqpConfig) MaxChannel ¶
func (me *AmqpConfig) MaxChannel(count int) *AmqpConfig
func (*AmqpConfig) Password ¶
func (me *AmqpConfig) Password(password string) *AmqpConfig
func (*AmqpConfig) Port ¶
func (me *AmqpConfig) Port(port int) *AmqpConfig
func (*AmqpConfig) User ¶
func (me *AmqpConfig) User(user string) *AmqpConfig
type AmqpConnection ¶
type AmqpConnection struct {
// contains filtered or unexported fields
}
func (*AmqpConnection) Channel ¶
func (me *AmqpConnection) Channel() (ch *AmqpChannel, err error)
func (*AmqpConnection) Close ¶
func (me *AmqpConnection) Close() error
func (*AmqpConnection) ReleaseChannel ¶
func (me *AmqpConnection) ReleaseChannel(ci *AmqpChannel)
Click to show internal directories.
Click to hide internal directories.