mrabbit

package module

v0.0.0-...-2e54c6a Latest Latest Go to latest Published: Jul 26, 2021 License: MIT Imports: 2 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/supriadi-yusuf/mrabbit

Links

Open Source Insights

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

Constants ¶

View Source

const (
	MaxTrial1 = 3
	MaxTrial2 = 7
)

Variables ¶

This section is empty.

Functions ¶

This section is empty.

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)

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL