34 lines
1.4 KiB
Go
34 lines
1.4 KiB
Go
|
// Package constants define constant variable
|
||
|
|
package constants
|
||
|
|
|
||
|
|
const (
|
||
|
|
// MessageExchangeName define exchange name for message
|
||
|
|
MessageExchangeName = "message-exchange"
|
||
|
|
// MessageDeadExchangeName define dead letter exchange name for message
|
||
|
|
MessageDeadExchangeName = "message-dead-letter-exchange"
|
||
|
|
)
|
||
|
|
|
||
|
|
const (
|
||
|
|
// MessageRoutingKey define binding routing key pattern for the message queue (matches all message.* categories)
|
||
|
|
MessageRoutingKey = "message.#"
|
||
|
|
// MessageDeadRoutingKey define binding routing key for the message dead letter queue
|
||
|
|
MessageDeadRoutingKey = "#"
|
||
|
|
// MessageQueueName define queue name for message
|
||
|
|
MessageQueueName = "message-queue"
|
||
|
|
// MessageDeadQueueName define dead letter queue name for message
|
||
|
|
MessageDeadQueueName = "message-dead-letter-queue"
|
||
|
|
)
|
||
|
|
|
||
|
|
const (
|
||
|
|
// MessageTaskSubmittedCategory define category for task submitted message
|
||
|
|
MessageTaskSubmittedCategory = "message.task.submitted"
|
||
|
|
// MessageTaskRunningCategory define category for task running message
|
||
|
|
MessageTaskRunningCategory = "message.task.running"
|
||
|
|
// MessageTaskCompletedCategory define category for task completed message
|
||
|
|
MessageTaskCompletedCategory = "message.task.completed"
|
||
|
|
// MessageTaskFailedCategory define category for task failed message
|
||
|
|
MessageTaskFailedCategory = "message.task.failed"
|
||
|
|
// MessageTaskCancelledCategory define category for task cancelled message
|
||
|
|
MessageTaskCancelledCategory = "message.task.cancelled"
|
||
|
|
)
|