brokers

Documentation

Index

• type BrokerInterface
• type LocalBroker
  • func NewLocalBroker() LocalBroker
  • func (l *LocalBroker) Activate()
  • func (l *LocalBroker) Clone() BrokerInterface
  • func (l *LocalBroker) GetPoolSize() int
  • func (l *LocalBroker) LSend(queueName string, msg message.Message) error
  • func (l *LocalBroker) Next(queueName string) (message.Message, error)
  • func (l *LocalBroker) Send(queueName string, msg message.Message) error
  • func (l *LocalBroker) SetPoolSize(i int)

Types

type BrokerInterface

type BrokerInterface interface {
	Next(queueName string) (message.Message, error)
	Send(queueName string, msg message.Message) error
	LSend(queueName string, msg message.Message) error
	// 如果使用连接池，调用Activate后才真正建立连接
	Activate()
	SetPoolSize(int)
	GetPoolSize() int
	Clone() BrokerInterface
}

type LocalBroker

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

LocalBroker ！！！只用于本地测试！！！ !!! Only for local test !!!

func NewLocalBroker

func NewLocalBroker() LocalBroker

func (*LocalBroker) Activate

func (l *LocalBroker) Activate()

func (*LocalBroker) Clone

func (l *LocalBroker) Clone() BrokerInterface

func (*LocalBroker) GetPoolSize

func (l *LocalBroker) GetPoolSize() int

func (*LocalBroker) LSend

func (l *LocalBroker) LSend(queueName string, msg message.Message) error

func (*LocalBroker) Next

func (l *LocalBroker) Next(queueName string) (message.Message, error)

func (*LocalBroker) Send

func (l *LocalBroker) Send(queueName string, msg message.Message) error

func (*LocalBroker) SetPoolSize

func (l *LocalBroker) SetPoolSize(i int)