messagebus

type BusNameStamp struct {
	BusName string
}

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

type DeadLetterAttemptStamp struct {
	Count int
}

type DelayStamp struct {
	Delay time.Duration
}

type HandleOptions struct {
	RequireHandler bool
}

type HandledStamp struct {
	HandlerName string
}

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

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

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

type MessageIdStamp struct {
	MessageId string
}

type ReceivedStamp struct {
	TransportName string
}

type RedeliveryStamp struct {
	Count int
}

type RetryPolicy struct {
	MaxRetries          int
	BaseDelay           time.Duration
	FailureTransport    messagebuscontract.Transport
	MaxDelay            time.Duration
	FailureRequeueDelay time.Duration
	/* @important bound on requeues of an exhausted message after the FailureTransport rejects it; 0 keeps the default no-loss behavior (requeue until it recovers), a positive value nacks without requeue after that many failed routings so a transport-native dead-letter (AMQP DLX) can claim it instead of looping forever */
	MaxDeadLetterAttempts int
}

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

type SentStamp struct {
	TransportName string
}

type ServiceRegistrar interface {
	RegisterService(serviceName string, provider any, options ...containercontract.RegisterOption)
}

type TransportRouting struct {
	Name      string
	Transport messagebuscontract.Transport
}