This package is not ready for prime time, hence the <1.0.0 version number. Stay tuned!

Bus-Boy

A collection of scripts used to interact with Azure Service Bus

Usage

These scripts are meant to be extended for use as a CLI, in a GUI, or any other tool to provide users with access to Azure Service Bus topics and subscription data.

Add as an npm module to your project

npm -i bus-boy --save

*assumes you have node and npm installed

Available scripts

createMessage - Creates a message on the specified topic.
createSubscription - Creates the specified subscription.
createTopic - Creates the specified topic.
deleteSubscription - Deletes the specified subscription.
deleteTopic - Deletes the specified topic.
listRules - Returns all rules for a subscription.
listSubscriptions - Returns all subscriptions for the specified topic.
listTopics - Returns all topics for the current Service Bus connection. Also returns a count of topics.
peekDeadLetter - Peeklocks and returns the first retrieved message in the specified subscription's dead letter queue.
peekSubscription - Peeklocks and returns the first retrieved message in the specified subscription.
subscriptionDetails - Returns the details of the specified subscription.
subscriptionMsgCount - Returns the current count of messages in the specified subscription.
queueMsgCount - Returns the current count of messages in the specified queue.
watchTopic - Creates a temporary subscription on the configured topic and returns incoming messages.

Documentation for the Azure SDK for Node can be found here:

http://azure.github.io/azure-sdk-for-node/

Basic Usage

const busBoy = require('bus-boy');
const azureSb = require('azure-sb');

const connectionString = 'my-service-bus-connection-string';
const azureServiceBus = azureSb.createServiceBusService(connectionString);

busBoy
  .subscriptionDetails(azureServiceBus, 'my-topic-name', 'my-subscription')
  .then(results => {
    console.log(results);
  })
  .catch(error => {
    console.log(error);
  });

Basic Watch Topic Usage

const busBoy = require('bus-boy');
const azureSb = require('azure-sb');

const connectionString = 'my-connection-string';
const azureServiceBus = azureSb.createServiceBusService(connectionString);

const { watchTopic } = busBoy;

// callback to handle messages
function onMessage(message) {
  console.log('%O', message);
}

// stop watching topic after 5 seconds
setTimeout(() => { watchTopic.onSIGINT(); }, 5000);

// start watching topic
watchTopic.run(azureServiceBus, topic, onMessage);