Octobus is a javascript library that helps you keep your code modular and extensible by creating services that respond to messages.
npm install octobus.js
- functions with named arguments are preferred to functions with positional arguments
- promises are better than callbacks (they help you get rid of callback hell)
- async / await calls are better than promises alone and will make you code more readable and manageable
- service functions (handlers) as first class citizens
- inheritance is great when used with good care; composition is even better.
- promotes high decoupling between the sender and the receiver of the message
- logging and introspection of the messages
- microservices friendly
- dependency injection of other services
- ability to extend existing services
- service calls interception
- extensions (octobus-crud, hapi-octobus etc.)
- everything is asynchronous (promises, async / await)
Requirements:
- octobus.js requires node >= 6 because of its Proxy use.
- First we need to create a MessageBus instance. We use it to send message to services.
import { MessageBus } from 'octobus.js';
const messageBus = new MessageBus();- We create a ServiceBus and connect it to our MessageBus instance. This service bus will proxy the message sending to the message bus and its main use is to group together handlers of a specific area of the business logic.
import { ServiceBus } from 'octobus.js';
const serviceBus = new ServiceBus();
serviceBus.connect(messageBus);- We create services, which are functions that can listen and act on a specific topic.
serviceBus.subscribe('hello', ({ message }) => `Hello, ${message.data}!`);- Now we are able to send message to be handled by the services we previously defined.
serviceBus.send('hello', 'world').then((result) => {
console.log(result); // will output "Hello, world!"
});