rmq

Documentation

Index

• func New(serverURI string, jobQueue string, resultQueue string, updateQueue string) (instance.Rmq, error)
• type RmqInstance
  • func (r *RmqInstance) Publish(queue string, contentType string, deliveryMode uint8, msg []byte) error
  • func (r *RmqInstance) Shutdown()
  • func (r *RmqInstance) Subscribe(queue string) (<-chan amqp.Delivery, error)

Functions

func New

func New(serverURI string, jobQueue string, resultQueue string, updateQueue string) (instance.Rmq, error)

Types

type RmqInstance

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

func (*RmqInstance) Publish

func (r *RmqInstance) Publish(queue string, contentType string, deliveryMode uint8, msg []byte) error

func (*RmqInstance) Shutdown

func (r *RmqInstance) Shutdown()

func (*RmqInstance) Subscribe

func (r *RmqInstance) Subscribe(queue string) (<-chan amqp.Delivery, error)