mrabbit

README

mrabbit

mrabbit is package to interact with rabbit mq

Documentation

Index

• Constants
• type IRabbit
  • func CreateRealRabbitInstance() IRabbit
• type NotifyListener
  • func (listener *NotifyListener) GetNotifyCloseChannel() chan *amqp.Error
• type RealRabbit
  • func (q *RealRabbit) ChannelQos(prefetchCount, prefetchSize int, global bool) error
  • func (q *RealRabbit) CloseChannel() error
  • func (q *RealRabbit) CloseConnection() error
  • func (q *RealRabbit) ConsumeQueueMsq(queue, consumer string, autoAck, exclusive, noLocal, noWait bool, ...) (<-chan amqp.Delivery, error)
  • func (q *RealRabbit) CreateChannel() error
  • func (q *RealRabbit) DeclareQueue(queue string, durable, autodelete, exclusive, nowait bool, args amqp.Table) (amqp.Queue, error)
  • func (q *RealRabbit) DialRabbit(uri string, commandNo int) error
  • func (q *RealRabbit) GetWaitingTimeToConnect(trial int) time.Duration
  • func (q *RealRabbit) NotifyClose(ch chan *amqp.Error) chan *amqp.Error
  • func (q *RealRabbit) SetHeartBeat(duration time.Duration)

Constants

const (
	MaxTrial1 = 3
	MaxTrial2 = 7
)

Types

type IRabbit

type IRabbit interface {
	DialRabbit(string, int) error
	CreateChannel() error
	CloseChannel() error
	CloseConnection() error
	SetHeartBeat(time.Duration)
	DeclareQueue(string, bool, bool, bool, bool, amqp.Table) (amqp.Queue, error)
	NotifyClose(chan *amqp.Error) chan *amqp.Error
	ChannelQos(prefetchCount, prefetchSize int, global bool) error
	ConsumeQueueMsq(queue, consumer string, autoAck, exclusive, noLocal,
		noWait bool, args amqp.Table) (<-chan amqp.Delivery, error)
	GetNotifyCloseChannel() chan *amqp.Error
	GetWaitingTimeToConnect(int) time.Duration
}

func CreateRealRabbitInstance

func CreateRealRabbitInstance() IRabbit

type NotifyListener

type NotifyListener struct {
	NotifyCloseCh chan *amqp.Error
}

func (*NotifyListener) GetNotifyCloseChannel

func (listener *NotifyListener) GetNotifyCloseChannel() chan *amqp.Error

type RealRabbit

type RealRabbit struct {
	NotifyListener
	// contains filtered or unexported fields
}

func (*RealRabbit) ChannelQos

func (q *RealRabbit) ChannelQos(prefetchCount, prefetchSize int, global bool) error

func (*RealRabbit) CloseChannel

func (q *RealRabbit) CloseChannel() error

func (*RealRabbit) CloseConnection

func (q *RealRabbit) CloseConnection() error

func (*RealRabbit) ConsumeQueueMsq

func (q *RealRabbit) ConsumeQueueMsq(queue, consumer string, autoAck, exclusive,
	noLocal, noWait bool, args amqp.Table) (<-chan amqp.Delivery, error)

func (*RealRabbit) CreateChannel

func (q *RealRabbit) CreateChannel() error

func (*RealRabbit) DeclareQueue

func (q *RealRabbit) DeclareQueue(queue string, durable, autodelete, exclusive, nowait bool, args amqp.Table) (amqp.Queue, error)

func (*RealRabbit) DialRabbit

func (q *RealRabbit) DialRabbit(uri string, commandNo int) error

func (*RealRabbit) GetWaitingTimeToConnect

func (q *RealRabbit) GetWaitingTimeToConnect(trial int) time.Duration

func (*RealRabbit) NotifyClose

func (q *RealRabbit) NotifyClose(ch chan *amqp.Error) chan *amqp.Error

func (*RealRabbit) SetHeartBeat

func (q *RealRabbit) SetHeartBeat(duration time.Duration)