queue

Documentation

Index

• type Factory
• type MessageQueueConsumer

Types

type Factory

type Factory func(*config.ProviderConfig) (MessageQueueConsumer, error)

Factory is a function type that creates a new MessageQueueConsumer based on the provided configuration.

type MessageQueueConsumer

type MessageQueueConsumer interface {
	Connect() error
	Consume(queueName string, handler func(msg []byte) error) error
	Close() error
}

MessageQueueConsumer is the interface that each message queue producer should implement