rabbitmq

package module

v0.0.0-...-f45e54c Latest Latest Go to latest Published: Nov 1, 2023 License: Apache-2.0 Imports: 10 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/flylib/mq

Links

Open Source Insights

Documentation ¶

Index ¶

func NewBroker(options ...Option) mq.IBroker
type Broker
type Channel
type Delivery
type Option

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func NewBroker ¶

func NewBroker(options ...Option) mq.IBroker

Types ¶

type Broker ¶

type Broker struct {
	amqp.Config

	ilog.ILogger //default logger
	codec.ICodec //default codec
	sync.Mutex
	// contains filtered or unexported fields
}

func (*Broker) Close ¶

func (b *Broker) Close() error

func (*Broker) Connect ¶

func (b *Broker) Connect(url string) (err error)

func (*Broker) OpenChannel ¶

func (b *Broker) OpenChannel(name string) (mq.IChannel, error)

func (*Broker) Publish ¶

func (b *Broker) Publish(topic string, v any) error

func (b *Broker) Subscribe(topic string, handler mq.MessageHandler) error

type Channel ¶

type Channel struct {
	sync.Map
	sync.Mutex
	// contains filtered or unexported fields
}

channel represents a task

func (*Channel) Close ¶

func (c *Channel) Close() error

func (*Channel) DeclareQueue ¶

func (c *Channel) DeclareQueue(queue string) error

func (*Channel) Delivering ¶

func (c *Channel) Delivering(delivery Delivery)

continuous delivery

func (*Channel) Publish ¶

func (c *Channel) Publish(topic string, v any) error

func (c *Channel) Subscribe(topic string, handler mq.MessageHandler) error

type Delivery ¶

type Delivery struct {
	// contains filtered or unexported fields
}

type Option ¶

type Option func(o *Broker)

func MustWithCodec ¶

func MustWithCodec(c codec.ICodec) Option

func MustWithLogger ¶

func MustWithLogger(logger ilog.ILogger) Option

func WithConsumerName ¶

func WithConsumerName(name string) Option

func WithDeclareQueues ¶

func WithDeclareQueues(queues ...string) Option

func WithDefaultExchange ¶

func WithDefaultExchange(exchange string) Option

func WithHeartbeatInterval ¶

func WithHeartbeatInterval(duration time.Duration) Option

less than 1s uses the server's interval

func WithMaxTryReconnectTimes ¶

func WithMaxTryReconnectTimes(times uint32) Option

default 10,0 means no limit,The maximum number of reconnections allowed after disconnection

func WithPanicHandler ¶

func WithPanicHandler(f func(mq.IMessage, error)) Option

func WithReconnectInterval ¶

func WithReconnectInterval(duration time.Duration) Option

default 10s,reconnection interval

func WithVhost ¶

func WithVhost(vhost string) Option

Source Files ¶

View all Source files

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