rabbitmq

Documentation

Index

• type Service
  • func New(rabbitCli *rabbitmq.Rabbit) (_ Service, err error)

Types

type Service

type Service interface {
	NewCh() (*amqp.Channel, error)
	CloseCh(ch *amqp.Channel)

	GetExchangesQueue() *amqp.Queue
	GetSymbolsQueue() *amqp.Queue

	DeclareExchangesQueue() (amqp.Queue, error)
	DeclareSymbolsQueue() (amqp.Queue, error)

	Publish(exchange, queueName string, mandatory, immediate bool, body []byte) error
	RPCCall(routingKey string, reqBody []byte) ([]byte, error)
}

func New

func New(rabbitCli *rabbitmq.Rabbit) (_ Service, err error)