servicebus

func CreateQueue ¶

func CreateQueue(name string) error

CreateQueue creates a service bus queue.

func DeleteQueue ¶

func DeleteQueue(name string) error

DeleteQueue deletes a service bus queue.

func ListQueues ¶

func ListQueues() error

ListQueues lists service bus queues in the account and marshals them to JSON which provides full details.

func Receive ¶

func Receive(queue string) (string, error)

Receive receives a single message from the service bus queue using the ReceiveOne method, with the help of a channel.

func Send ¶

func Send(queue, message string) error

Send sends a message to the named service bus queue.

func ServiceBusFromEnv ¶

func ServiceBusFromEnv() (*servicebus.Namespace, error)

ServiceBusFromEnv creates a new *servicebus.Namespace authenticated via the AZGO_SERVICEBUS_CONNECTION_STRING environment variable

func Test ¶

func Test() error