rabbitmq

Documentation

Index

• Constants
• type RabbitMqBroker
  • func (b *RabbitMqBroker) Close() error
  • func (b *RabbitMqBroker) Connect(uri string) error
  • func (b *RabbitMqBroker) GetTaskResult(taskID string) <-chan *broker.Message
  • func (b *RabbitMqBroker) GetTasks(queueName string) <-chan *broker.Message
  • func (b *RabbitMqBroker) PublishTask(queueName string, taskID string, message *broker.Message, ignoreResults bool) error
  • func (b *RabbitMqBroker) PublishTaskEvent(key string, message *broker.Message) error
  • func (b *RabbitMqBroker) PublishTaskResult(key string, message *broker.Message) error
  • func (b *RabbitMqBroker) String() string

Constants

const (
	// DefaultExchange name
	DefaultExchange = "celery"
	// DefaultTaskResultExchange name
	DefaultTaskResultExchange = "celeryresults"
	// DefaultTaskEventExchange name
	DefaultTaskEventExchange = "celeryev"
)

Types

type RabbitMqBroker

type RabbitMqBroker struct {
	sync.Mutex
	// contains filtered or unexported fields
}

RabbitMqBroker implements RabbitMq broker

func (*RabbitMqBroker) Close

func (b *RabbitMqBroker) Close() error

Close the broker and cleans up resources

func (*RabbitMqBroker) Connect

func (b *RabbitMqBroker) Connect(uri string) error

Connect to rabbitmq

func (*RabbitMqBroker) GetTaskResult

func (b *RabbitMqBroker) GetTaskResult(taskID string) <-chan *broker.Message

GetTaskResult fetchs task result for the specified taskID

func (*RabbitMqBroker) GetTasks

func (b *RabbitMqBroker) GetTasks(queueName string) <-chan *broker.Message

GetTasks waits and fetches the tasks from queue

func (*RabbitMqBroker) PublishTask

func (b *RabbitMqBroker) PublishTask(queueName string, taskID string, message *broker.Message, ignoreResults bool) error

PublishTask sends a task to queue

func (*RabbitMqBroker) PublishTaskEvent

func (b *RabbitMqBroker) PublishTaskEvent(key string, message *broker.Message) error

PublishTaskEvent sends task events back to event queue

func (*RabbitMqBroker) PublishTaskResult

func (b *RabbitMqBroker) PublishTaskResult(key string, message *broker.Message) error

PublishTaskResult sends task result back to task queue

func (*RabbitMqBroker) String

func (b *RabbitMqBroker) String() string