Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AuthCommandHandler ¶
type AuthCommandHandler struct {
// contains filtered or unexported fields
}
AuthCommandHandlers handles rabbitmq messages
func NewAuthCommandHandler ¶
func NewAuthCommandHandler(logger *zap.SugaredLogger, bus ycq.EventBus, dispatcher ycq.Dispatcher) *AuthCommandHandler
func (*AuthCommandHandler) Handle ¶
func (h *AuthCommandHandler) Handle(d *amqp.Delivery)
Handle handles the rabbitmq message
type BankCommandHandler ¶
type BankCommandHandler struct {
// contains filtered or unexported fields
}
func NewBankCommandHandler ¶
func NewBankCommandHandler(logger *zap.SugaredLogger, bus ycq.EventBus, dispatcher ycq.Dispatcher) *BankCommandHandler
func (*BankCommandHandler) Handle ¶
func (h *BankCommandHandler) Handle(d *amqp.Delivery)
type CommandHandler ¶
type Connections ¶
type Connections struct {
// contains filtered or unexported fields
}
func RegisterRabbitMqConsumers ¶
func RegisterRabbitMqConsumers(logger *zap.SugaredLogger, bus ycq.EventBus, dispatcher ycq.Dispatcher, url string) (*Connections, error)
func (*Connections) Close ¶
func (c *Connections) Close()
type EventConsumer ¶
type EventConsumer struct {
// contains filtered or unexported fields
}
func NewEventConsumer ¶
func NewEventConsumer(logger *zap.SugaredLogger, bus ycq.EventBus, dispatcher ycq.Dispatcher, conn *amqp.Connection, ch *amqp.Channel, queue string, handler CommandHandler) (*EventConsumer, error)
Source Files
Click to show internal directories.
Click to hide internal directories.