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 ¶
View Source
const ( // DefaultExchange name DefaultExchange = "celery" // DefaultTaskResultExchange name DefaultTaskResultExchange = "celeryresults" // DefaultTaskEventExchange name DefaultTaskEventExchange = "celeryev" )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type RabbitMqBroker ¶
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
Source Files
Click to show internal directories.
Click to hide internal directories.