Documentation ¶
Index ¶
- func NewBroker(options ...Option) mq.IBroker
- type Broker
- type Channel
- type Delivery
- type Option
- func MustWithCodec(c codec.ICodec) Option
- func MustWithLogger(logger ilog.ILogger) Option
- func WithConsumerName(name string) Option
- func WithDeclareQueues(queues ...string) Option
- func WithDefaultExchange(exchange string) Option
- func WithHeartbeatInterval(duration time.Duration) Option
- func WithMaxTryReconnectTimes(times uint32) Option
- func WithPanicHandler(f func(mq.IMessage, error)) Option
- func WithReconnectInterval(duration time.Duration) Option
- func WithVhost(vhost string) Option
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type Broker ¶
type Option ¶
type Option func(o *Broker)
func MustWithCodec ¶
func MustWithLogger ¶
func WithConsumerName ¶
func WithDeclareQueues ¶
func WithDefaultExchange ¶
func WithHeartbeatInterval ¶
less than 1s uses the server's interval
func WithMaxTryReconnectTimes ¶
default 10,0 means no limit,The maximum number of reconnections allowed after disconnection
func WithReconnectInterval ¶
default 10s,reconnection interval
Click to show internal directories.
Click to hide internal directories.