bus-boy v0.0.5

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);