Options
All
  • Public
  • Public/Protected
  • All
Menu

Event bus implementation that does pub/sub over a Redis connection.

Hierarchy

  • RedisBus

Implements

Index

Constructors

constructor

Properties

awareOfContainerLifecycle

awareOfContainerLifecycle: true = true

Protected Readonly injector

injector: Container

Protected internalSubscriptions

internalSubscriptions: string[] = []

List of events for which we have created Redis channel subscriptions.

Protected Readonly logging

logging: Logging

Protected Optional publisherConnection

publisherConnection: Redis

Protected Readonly redis

redis: Redis

Protected Readonly serial

Protected Optional subscriberConnection

subscriberConnection: Redis

Protected subscriptions

subscriptions: Collection<BusSubscriber<Event>> = ...

List of local subscriptions on this bus.

Readonly uuid

uuid: string = ...

Methods

down

Protected handleEvent

  • handleEvent(name: string, payload: string): Promise<void>

isConnected

  • isConnected(): boolean

onContainerRelease

pipe

push

  • push(event: Event): Promise<void>

subscribe

up

  • up(): Promise<void>
Extollo Logo

extollo (v. latin) - to lift up, to elevate

Extollo is a free & libre application framework in TypeScript.