common

Jun 16, 2022

Changes in this version

type Publisher

+ Marshaller func() marshal.Marshaller

+ SetMarshaller func(marshal.Marshaller)

type PublisherSettings

+ func (p *PublisherSettings) Marshaller() marshal.Marshaller

+ func (p *PublisherSettings) SetMarshaller(marshaller marshal.Marshaller)

Aug 13, 2021

Changes in this version

+ type Listener interface

+ LockDuration func() time.Duration

+ LockRenewalInterval func() *time.Duration

+ MaxConcurrency func() *int

+ MaxDeliveryCount func() int32

+ Namespace func() *servicebus.Namespace

+ PrefetchCount func() *uint32

+ SetLockDuration func(lockDuration time.Duration)

+ SetLockRenewalInterval func(lockRenewalInterval *time.Duration)

+ SetMaxConcurrency func(maxConcurrency *int)

+ SetMaxDeliveryCount func(maxDeliveryCount int32)

+ SetNamespace func(namespace *servicebus.Namespace)

+ SetPrefetchCount func(prefectCount *uint32)

+ type ListenerSettings struct

+ func (l *ListenerSettings) LockDuration() time.Duration

+ func (l *ListenerSettings) LockRenewalInterval() *time.Duration

+ func (l *ListenerSettings) MaxConcurrency() *int

+ func (l *ListenerSettings) MaxDeliveryCount() int32

+ func (l *ListenerSettings) Namespace() *servicebus.Namespace

+ func (l *ListenerSettings) PrefetchCount() *uint32

+ func (l *ListenerSettings) SetLockDuration(lockDuration time.Duration)

+ func (l *ListenerSettings) SetLockRenewalInterval(lockRenewalInterval *time.Duration)

+ func (l *ListenerSettings) SetMaxConcurrency(maxConcurrency *int)

+ func (l *ListenerSettings) SetMaxDeliveryCount(maxDeliveryCount int32)

+ func (l *ListenerSettings) SetNamespace(namespace *servicebus.Namespace)

+ func (l *ListenerSettings) SetPrefetchCount(prefectCount *uint32)

+ type Publisher interface

+ AppendHeader func(k, v string)

+ Headers func() map[string]string

+ Namespace func() *servicebus.Namespace

+ SetNamespace func(namespace *servicebus.Namespace)

+ type PublisherSettings struct

+ func (p *PublisherSettings) AppendHeader(key, value string)

+ func (p *PublisherSettings) Headers() map[string]string

+ func (p *PublisherSettings) Namespace() *servicebus.Namespace

+ func (p *PublisherSettings) SetNamespace(namespace *servicebus.Namespace)