The highest tagged major version is
Documentation
¶
Index ¶
- type Listener
- func (l *Listener) Close(ctx context.Context) error
- func (l *Listener) Listen(ctx context.Context, handler message.Handler, topicName string, opts ...Option) error
- func (l *Listener) Namespace() *servicebus.Namespace
- func (l *Listener) Subscription() *servicebus.SubscriptionEntity
- func (l *Listener) Topic() *servicebus.TopicEntity
- type ManagementOption
- func WithConnectionString(connStr string) ManagementOption
- func WithFilterDescriber(filterName string, filter servicebus.FilterDescriber) ManagementOption
- func WithManagedIdentityClientID(serviceBusNamespaceName, managedIdentityClientID string) ManagementOption
- func WithManagedIdentityResourceID(serviceBusNamespaceName, managedIdentityResourceID string) ManagementOption
- func WithSubscriptionName(name string) ManagementOption
- func WithToken(serviceBusNamespaceName string, spt *adal.ServicePrincipalToken) ManagementOption
- type Option
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Listener ¶
type Listener struct {
// contains filtered or unexported fields
}
Listener is a struct to contain service bus entities relevant to subscribing to a publisher topic
func New ¶
func New(opts ...ManagementOption) (*Listener, error)
New creates a new service bus listener
func (*Listener) Listen ¶
func (l *Listener) Listen(ctx context.Context, handler message.Handler, topicName string, opts ...Option) error
Listen waits for a message from the Service Bus Topic subscription
func (*Listener) Namespace ¶
func (l *Listener) Namespace() *servicebus.Namespace
Namespace returns the servicebus.Namespace that the listener is setup with
func (*Listener) Subscription ¶
func (l *Listener) Subscription() *servicebus.SubscriptionEntity
Subscription returns the servicebus.SubscriptionEntity that the listener is setup with
func (*Listener) Topic ¶
func (l *Listener) Topic() *servicebus.TopicEntity
Topic returns servicebus.TopicEntity that the listener is setup with
type ManagementOption ¶
ManagementOption provides structure for configuring a new Listener
func WithConnectionString ¶
func WithConnectionString(connStr string) ManagementOption
WithConnectionString configures a listener with the information provided in a Service Bus connection string
func WithFilterDescriber ¶
func WithFilterDescriber(filterName string, filter servicebus.FilterDescriber) ManagementOption
WithFilterDescriber configures the filters on the subscription
func WithManagedIdentityClientID ¶
func WithManagedIdentityClientID(serviceBusNamespaceName, managedIdentityClientID string) ManagementOption
WithManagedIdentityClientID configures a listener with the attached managed identity and the Service bus resource name
func WithManagedIdentityResourceID ¶
func WithManagedIdentityResourceID(serviceBusNamespaceName, managedIdentityResourceID string) ManagementOption
WithManagedIdentityResourceID configures a listener with the attached managed identity and the Service bus resource name
func WithSubscriptionName ¶
func WithSubscriptionName(name string) ManagementOption
WithSubscriptionName configures the subscription name of the subscription to listen to
func WithToken ¶
func WithToken(serviceBusNamespaceName string, spt *adal.ServicePrincipalToken) ManagementOption
Source Files