rabbitmqv2

Documentation

Index

• func NewEventHandlerResolve(rbt *rmqc.RabbitMQ) ddd.IEventDispatcher
• func NewRabbitMQEventDispatcher(rbt *rmqc.RabbitMQ) ddd.IEventDispatcher
• func NewRabbitMQResolve(config Config) *rmqc.RabbitMQ
• type Config
• type RabbitMQEventDispatcher
  • func (dispatcher RabbitMQEventDispatcher) Dispatch(ctx context.Context, event ddd.IBaseEvent) error

Functions

func NewEventHandlerResolve

func NewEventHandlerResolve(rbt *rmqc.RabbitMQ) ddd.IEventDispatcher

func NewRabbitMQEventDispatcher

func NewRabbitMQEventDispatcher(rbt *rmqc.RabbitMQ) ddd.IEventDispatcher

func NewRabbitMQResolve

func NewRabbitMQResolve(config Config) *rmqc.RabbitMQ

Types

type Config

type Config struct {
	Host           string
	Port           string
	VHost          string
	Username       string
	Password       string
	ConnectionName string
	Reconnect      struct {
		MaxAttempt int
		Interval   time.Duration
	}
}

type RabbitMQEventDispatcher

type RabbitMQEventDispatcher struct {
	// contains filtered or unexported fields
}

func (RabbitMQEventDispatcher) Dispatch

func (dispatcher RabbitMQEventDispatcher) Dispatch(ctx context.Context, event ddd.IBaseEvent) error