Class EventBusFactory<TAdapters>

IMPORT_PATH: "@daiso-tech/core/event-bus/implementations/derivables"

Type Parameters

  • TAdapters extends string = string

Implements

Constructors

constructor

Methods

use

Constructors

constructor

  • new EventBusFactory<TAdapters>(settings): EventBusFactory<TAdapters>

  • Type Parameters

    • TAdapters extends string = string

    Parameters

    Returns EventBusFactory<TAdapters>

    Example

    import { EventBusFactory } from "@daiso-tech/core/event-bus/implementations/derivables";
    import { MemoryEventBusAdapter, RedisPubSubEventBusAdapter } from "@daiso-tech/core/event-bus/implementations/adapters";
    import { Serde } from "@daiso-tech/core/serde/implementations/derivables";
    import { SuperJsonSerdeAdapter } from "@daiso-tech/core/serde/implementations/adapters";
    import Redis from "ioredis";

    const serde = new Serde(new SuperJsonSerdeAdapter());
    const cacheFactory = new EventBusFactory({
      serde,
      adapters: {
        memory:new MemoryEventBusAdapter({
          rootGroup: "@global"
        }),
        redis: new RedisPubSubEventBusAdapter({
          dispatcherClient: new Redis("YOUR_REDIS_CONNECTION"),
          listenerClient: new Redis("YOUR_REDIS_CONNECTION")
          serde,
          rootGroup: "@global"
        }),
        defaultAdapter: "memory"
      }
    });

Methods

use

  • use<TEvents>(adapterName?): IGroupableEventBus<TEvents>

  • Type Parameters

    Parameters

    Returns IGroupableEventBus<TEvents>

    Example

    import { BaseEvent } from "@daiso-tech/core/event-bus/contracts";
    import { EventBusFactory } from "@daiso-tech/core/event-bus/implementations/derivables";
    import { MemoryEventBusAdapter, RedisPubSubEventBusAdapter } from "@daiso-tech/core/event-bus/implementations/adapters";
    import { Serde } from "@daiso-tech/core/serde/implementations/derivables";
    import { SuperJsonSerdeAdapter } from "@daiso-tech/core/serde/implementations/adapters";
    import Redis from "ioredis";

    const serde = new Serde(new SuperJsonSerdeAdapter());
    const cacheFactory = new EventBusFactory({
      serde,
      adapters: {
        memory:new MemoryEventBusAdapter({
          rootGroup: "@global"
        }),
        redis: new RedisPubSubEventBusAdapter({
          dispatcherClient: new Redis("YOUR_REDIS_CONNECTION"),
          listenerClient: new Redis("YOUR_REDIS_CONNECTION")
          serde,
          rootGroup: "@global"
        }),
        defaultAdapter: "memory"
      }
    });

    class AddEvent extends BaseEvent<{ a: number, b: number }> {}
    serde.registerEvent(AddEvent);

    // Will use the default adapter which is MemoryEventBusAdapter
    await cacheFactory.use().dispatch(new AddEvent({ a: 1, b: 2 }));

    // Will use the redis dapter which is RedisPubSubEventBusAdapter
    await cacheFactory.use("redis").dispatch(new AddEvent({ a: 1, b: 2 }));

Settings

Member Visibility

On This Page

Constructors
Methods