servicebus

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

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

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

type ReceiverInterface interface {
	ReceiveMessage(ctx context.Context, maxMessages int, options *azservicebus.ReceiveMessagesOptions) ([]*azservicebus.ReceivedMessage, error)
	GetAzureReceiver() (*azservicebus.Receiver, error)
}

type SenderInterface interface {
	SendMessage(ctx context.Context, message *azservicebus.Message) error
	GetAzureSender() (*azservicebus.Sender, error)
}

type ServiceBus struct {
	Client *azservicebus.Client
}

type ServiceBusClientInterface interface {
	NewServiceBusReceiver(ctx context.Context, topicOrQueue string, options *azservicebus.ReceiverOptions) (ReceiverInterface, error)
	NewServiceBusSender(ctx context.Context, queue string, options *azservicebus.NewSenderOptions) (SenderInterface, error)
}

type ServiceBusReceiver struct {
	Receiver *azservicebus.Receiver
}

type ServiceBusSender struct {
	Sender *azservicebus.Sender
}