rabbitmq

Documentation

Index

• type TopicQueue
  • func NewTopicQueue(uri, exchange, routingKey, queueName string) (queue *TopicQueue, err error)
  • func (queue *TopicQueue) Close()
  • func (queue *TopicQueue) NewReceiver(customer string) (rece *TopicReceiver, err error)
• type TopicReceiver
  • func NewTopicReceiver(uri, exchange, routingKey, queueName, customer string) (rec *TopicReceiver, err error)
  • func (rec *TopicReceiver) Read() (bts []byte, err error)
• type TopicSender
  • func NewTopicSender(uri, exchange, routingKey string) (sender *TopicSender, err error)
  • func (sender *TopicSender) Close()
  • func (sender *TopicSender) Emit(bts []byte) (err error)

Types

type TopicQueue

type TopicQueue struct {
	E, R, Q string // exchange, routingKey, queueName
	// contains filtered or unexported fields
}

func NewTopicQueue

func NewTopicQueue(uri, exchange, routingKey, queueName string) (queue *TopicQueue, err error)

create Receiver uri: fmt.Sprintf("amqp://%s:%s@%s:%s%s", user, passwd, host, port, vhost)

func (*TopicQueue) Close

func (queue *TopicQueue) Close()

func (*TopicQueue) NewReceiver

func (queue *TopicQueue) NewReceiver(customer string) (rece *TopicReceiver, err error)

type TopicReceiver

type TopicReceiver struct {
	TopicQueue
	D <-chan amqp.Delivery
}

func NewTopicReceiver

func NewTopicReceiver(uri, exchange, routingKey, queueName, customer string) (
	rec *TopicReceiver, err error)

create Receiver

func (*TopicReceiver) Read

func (rec *TopicReceiver) Read() (bts []byte, err error)

type TopicSender

type TopicSender struct {
	E, R string
	// contains filtered or unexported fields
}

func NewTopicSender

func NewTopicSender(uri, exchange, routingKey string) (sender *TopicSender, err error)

func (*TopicSender) Close

func (sender *TopicSender) Close()

func (*TopicSender) Emit

func (sender *TopicSender) Emit(bts []byte) (err error)