keabusclient

Kea bus client package

features

• sucribe
• listen
• push
• pull
• healthcheck
• clear

Installation

Install KeabusclientComponent using npm;

$ [npm install | yarn add] keabusclient

Basic Use

Configure and load KeabusclientComponent in the application constructor as shown below.

import {KeabusclientComponent, KeabusclientComponentOptions, DEFAULT_KEABUSCLIENT_OPTIONS} from 'keabusclient';
// ...
export class MyApplication extends BootMixin(ServiceMixin(RepositoryMixin(RestApplication))) {
  constructor(options: ApplicationConfig = {}) {
    const opts: KeabusclientComponentOptions = DEFAULT_KEABUSCLIENT_OPTIONS;
    this.configure(KeabusclientComponentBindings.COMPONENT).to(opts);
      // Put the configuration options here
    });
    this.component(KeabusclientComponent);
    // ...
  }
  // ...
}