amqpv1

Documentation

Index

• type AMQPBrokerV1
  • func (a *AMQPBrokerV1) Connect() error
  • func (a *AMQPBrokerV1) Disconnect() error
  • func (a *AMQPBrokerV1) Marshal() string
  • func (a *AMQPBrokerV1) Publish(topic string, msg *broker.Message, opt ...broker.PublishOption) (err error)
  • func (a *AMQPBrokerV1) String() string
  • func (a *AMQPBrokerV1) Subscribe(topics []string, callBack broker.CallBack, opt ...broker.SubscribeOption) (broker.Subscriber, error)

Types

type AMQPBrokerV1

type AMQPBrokerV1 struct {
	sync.Once
	URI        string // amqp[s]://[username][:password]@host.domain[:port][vhost]
	CID        string // client id
	CACertFile string
	CertFile   string
	KeyFile    string
	Insecure   bool
	Logger     log.Logger
	// contains filtered or unexported fields
}

func (*AMQPBrokerV1) Connect

func (a *AMQPBrokerV1) Connect() error

func (*AMQPBrokerV1) Disconnect

func (a *AMQPBrokerV1) Disconnect() error

func (*AMQPBrokerV1) Marshal

func (a *AMQPBrokerV1) Marshal() string

func (*AMQPBrokerV1) Publish

func (a *AMQPBrokerV1) Publish(topic string, msg *broker.Message, opt ...broker.PublishOption) (err error)

Publish

func (*AMQPBrokerV1) String

func (a *AMQPBrokerV1) String() string

func (*AMQPBrokerV1) Subscribe

func (a *AMQPBrokerV1) Subscribe(topics []string, callBack broker.CallBack, opt ...broker.SubscribeOption) (broker.Subscriber, error)

Subscribe