configurations

Documentation

Index

• type RabbitMQProducerConfiguration
  • func NewDefaultRabbitMQProducerConfiguration(messageType types2.IMessage) *RabbitMQProducerConfiguration
• type RabbitMQProducerConfigurationBuilder
  • func NewRabbitMQProducerConfigurationBuilder(messageType types2.IMessage) RabbitMQProducerConfigurationBuilder
• type RabbitMQProducerConfigurationBuilderFuc

Types

type RabbitMQProducerConfiguration

type RabbitMQProducerConfiguration struct {
	ProducerMessageType reflect.Type
	ExchangeOptions     *options.RabbitMQExchangeOptions
	RoutingKey          string
	DeliveryMode        uint8
	Priority            uint8
	AppId               string
	Expiration          string
	ReplyTo             string
	ContentEncoding     string
}

func NewDefaultRabbitMQProducerConfiguration

func NewDefaultRabbitMQProducerConfiguration(
	messageType types2.IMessage,
) *RabbitMQProducerConfiguration

type RabbitMQProducerConfigurationBuilder

type RabbitMQProducerConfigurationBuilder interface {
	WithDurable(durable bool) RabbitMQProducerConfigurationBuilder
	WithAutoDeleteExchange(autoDelete bool) RabbitMQProducerConfigurationBuilder
	WithExchangeType(exchangeType types.ExchangeType) RabbitMQProducerConfigurationBuilder
	WithExchangeName(exchangeName string) RabbitMQProducerConfigurationBuilder
	WithRoutingKey(routingKey string) RabbitMQProducerConfigurationBuilder
	WithExchangeArgs(args map[string]any) RabbitMQProducerConfigurationBuilder
	WithDeliveryMode(deliveryMode uint8) RabbitMQProducerConfigurationBuilder
	WithPriority(priority uint8) RabbitMQProducerConfigurationBuilder
	WithAppId(appId string) RabbitMQProducerConfigurationBuilder
	WithExpiration(expiration string) RabbitMQProducerConfigurationBuilder
	WithReplyTo(replyTo string) RabbitMQProducerConfigurationBuilder
	WithContentEncoding(contentEncoding string) RabbitMQProducerConfigurationBuilder
	Build() *RabbitMQProducerConfiguration
}

func NewRabbitMQProducerConfigurationBuilder

func NewRabbitMQProducerConfigurationBuilder(
	messageType types2.IMessage,
) RabbitMQProducerConfigurationBuilder

type RabbitMQProducerConfigurationBuilderFuc

type RabbitMQProducerConfigurationBuilderFuc func(builder RabbitMQProducerConfigurationBuilder)