Documentation
¶
Overview ¶
Package amqpredialer provides a redialer for github.com/streadway/amqp.Conn.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AMQPRedialer ¶
type AMQPRedialer struct {
// contains filtered or unexported fields
}
func New ¶
func New(uri string) (*AMQPRedialer, error)
func (*AMQPRedialer) Close ¶
func (r *AMQPRedialer) Close() error
func (*AMQPRedialer) Conn ¶
func (r *AMQPRedialer) Conn() <-chan *amqp.Connection
func (*AMQPRedialer) Run ¶
func (r *AMQPRedialer) Run()
Source Files
Click to show internal directories.
Click to hide internal directories.