AngularJS service wrapper for the Vert.x Event Bus


Added by: Sam Deering





Stars: 77

Watchers: 77

Forks: 23


Jan Philipp
Jan Philipp

Module Description


Bower version npm version Build Status Built with Grunt

Client side library using VertX Event Bus as an Angular Service module


| Branch | Stability | Status | | --- | --- | --- | | Canary | unstable | Build Status | | Master | stable | Build Status |

How to get

Either download it manually or install it automatically with Bower: bower install angular-vertxbus --save

Then only import dist/angular-vertxbus.js or dist/angular-vertxbus.min.js. The file itself comes with a CJS header.

Alternatively you can use the cdnjs:

How to use


An Api Documentation is available.

Quick start

You have to define the module dependency, this module is named knalli.angular-vertxbus.

angular.module('app', ['knalli.angular-vertxbus'])
  .controller('MyCtrl', function(vertxEventBus, vertxEventBusService) {

    // using the EventBus directly
    vertxEventBus.send('my.address', {data: 123});

    // using the service
    vertxEventBusService.send('my.address', {data: 123})


Consume messages

vertxEventBusService.on('myaddress', function(message) {
  console.log('Received a message: ', message);

Publish a message

vertxEventBusService.publish('myaddress', {data: 123});

Send a message

vertxEventBusService.send('myaddress', {data: 123})
  .then(function(reply) {
    console.log('A reply received: ', reply);
  .catch(function() {
    console.warn('No message');

// The "No reply message found" is controlled via a timeout (default 10000ms)
vertxEventBusService.send('myaddress', {data: 123}, {timeout: 3000})
  .then(function(reply) {
    console.log('A reply received: ', reply);
  .catch(function() {
    console.warn('No message within 3 seconds');

Advanced configuration

The module has some advanced configuration options. Perhaps you do not have to change them, but at least you should know them!

Each module configuration option must be defined in the run phase, i.e.:

angular.module('app', ['knalli.angular-vertxbus'])
  .config(function(vertxEventBusProvider) {

Please have a look at the API documentation for vertxEventBusProvider and vertxEventBusServiceProvider for further options.

Architecture details

The module contains two items: the stub holder vertxEventBus for the Vert.X EventBus and a more comfortbale high level service vertxEventBusService.

The stub is required because the Vert.X Event Bus cannot handle a reconnect. The reason is the underlaying SockJS which cannot handle a reconnect, too. A reconnect means to create a new instance of SockJS, therefore a new instanve of vertx.EventBus. The stub ensures only one single instance exists. Otherwise a global module was not possible.

More or less the stub supports the same API calls like the original vertx.EventBus.

Based on the stub, the high level service vertxEventBusService detects disconnects, handles reconnects and ensures re-registrations of subscriptions. Furthermore, the service provides some neat aliases for the usage of handlers.

// Same as vertx.EventBus.registerHandler()
service.registerHandler('myaddress', callback);
service.on('myaddress', callback);
service.addListener('myaddress', callback);

// Same as vertx.EventBus.unregisterHandler()
service.unregisterHandler('myaddress', callback);
service.un('myaddress', callback);
service.removeListener('myaddress', callback);

// Same as vertx.EventBus.send()
service.send('myaddress', data)

// Same as vertx.EventBus.publish
service.publish('myaddress', data)
service.emit('myaddress', data)

// Same as vertx.readyState()

In addition to this, when sending a message with an expected reply:

// Same as vertx.EventBus.send() but with a promise
service.send('myaddress', data)
  .then(function(replyMessage) {})

For each connect or disconnect, a global broadcast will be emitted (on $rootScope with 'vertx-eventbus.system.connected', 'vertx-eventbus.system.disconnected')

Setup for using same callback with different addresses

In some scenarios you will want to use a single callback definition to many different addresses. To do this you will have to follow this pattern.

Create a javascript object that defines your callback. Do not attempt to use .prototype as the methods defined as such will always point to the same memory allocation - so will always be found identical when adding to the internal array.

function FunctionHolder(){
  "use strict";
  return {
      handler: function (message) {
          // do stuff here

Then when adding the listeners, you will create a new instance of your object and use your defined function.

var funcHolder = new FunctionHolder();
vertxEventBusService.addListener('address', funcHolder.handler);

NOTE: this functionality is only available after version 0.8.0.


Unit tests

Note: Check that dependencies are be installed (npm install).

The unit tests are available with npm test which is actually a shortcut for grunt test. It performs tests under the current primary target version of AngularJS. Use npm run test-scopes for testing other scoped versions as well.

E2E tests (manually)

Note: Check that dependencies are be installed (npm install).

The end-to-end tests start and utilize a full Vert.X node and a NodeJS based web server.

  1. npm run install-it-vertx-server downloads and installs a Vert.X locally.
  2. npm run start-it-vertx-server starts Vert.X on port 8080.
  3. npm run start-it-web-server starts a web server on port 3000.
  4. Open http://localhost:3000/ in your browser.


Copyright 2015 by Jan Philipp. Licensed under MIT.

Module stats last updated: 2018-01-11 15:00:05

Disclaimer: Some data on this page may have been gathered from the authors GitHub respository. If you see any mistakes or outdated information please let us know. Thanks!