common

type Listener interface {
	MaxDeliveryCount() int32
	LockRenewalInterval() *time.Duration
	LockDuration() time.Duration
	PrefetchCount() *uint32
	MaxConcurrency() *int
	Namespace() *servicebus.Namespace
	SetMaxDeliveryCount(maxDeliveryCount int32)
	SetLockRenewalInterval(lockRenewalInterval *time.Duration)
	SetLockDuration(lockDuration time.Duration)
	SetPrefetchCount(prefectCount *uint32)
	SetMaxConcurrency(maxConcurrency *int)
	SetNamespace(namespace *servicebus.Namespace)
}

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

type Publisher interface {
	Namespace() *servicebus.Namespace
	Headers() map[string]string
	SetNamespace(namespace *servicebus.Namespace)
	AppendHeader(k, v string)
	Marshaller() marshal.Marshaller
	SetMarshaller(marshal.Marshaller)
}

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