BusConfiguration

Search…
BusConfiguration
Creates a configuration in order to initialize a new BusInstance.
Methods
withHandler(classHandler)
Registers a class handler that receives a message and performs a unit of work. When Bus is initialized it will configure the transport to subscribe to the type of message handled by the handler and upon receipt will forward the message through to the handle() function.
Arguments
Argument
Description
Default
classHandler
A class responsible for handling messages that implements Handler
None
Example
1
import { Bus } from '@node-ts/bus-core'
2
import { TestHandler } from './test-handler'
3
​
4
Bus.configure().withHandler(TestHandler)
Copied!
See also events, commands.
withHandler(functionHandler)
Registers a function handler that receives a message and performs a unit of work. When Bus is initialized it will configure the transport to subscribe to the type of message handled by the function handler and upon receipt will forward the message to the function.
Arguments
Argument
Description
Default
functionHandler
A functional handler mapping initialized using handlerFor
None
Example
1
import { Bus, handlerFor } from '@node-ts/bus-core'
2
import { TestEvent } from './test-event'
3
​
4
Bus.configure().withHandler(handlerFor(TestEvent, event => {}))
Copied!
See also events, commands.
withCustomHandler(messageHandler,  customResolver)
Registers a custom handler that receives messages from external systems, or messages that don't implement the Message interface from @node-ts/bus-messages.
Arguments
Argument
Description
Default
messageHandler
A handler that receives the custom message
None
customResolver
A discriminator that determines if an incoming message should be mapped to this handler
None
Example
1
import { Bus } from '@node-ts/bus-core'
2
import { S3Event } from 'aws-sdk'
3
​
4
Bus.configure()
5
  .withCustomHandler(
6
    async (event: S3Event) => console.log('Received S3 event', { event }),
7
    {
8
      resolveWith: event => event.Records
9
        && event.Records.length
10
    }
11
  )   
Copied!
See also System messages.
withWorkflow(workflow)
Registers a workflow definition so that all of the messages it depends on will be subscribed to and forwarded to the handlers inside the workflow.
Arguments
Argument
Description
Default
workflow
Workflow definition to register
None
Example
1
import { Bus } from '@node-ts/bus-core'
2
import { TestWorkflow } from './test-workflow'
3
​
4
Bus.configure().withWorkflow(TestWorkflow) 
Copied!
See also Workflows.
withTransport(transport)
Configures Bus to use a different transport than the default MemoryQueue.
Arguments
Argument
Description
Default
transport
A configured transport to use
None
Example
1
import { Bus } from '@node-ts/bus-core'
2
import { SqsTransport, SqsTransportConfiguration } from '@node-ts/bus-sqs'
3
​
4
const sqsConfiguration: SqsTransportConfiguration = {
5
  // ...
6
}
7
const sqsTransport = new SqsTransport(sqsConfiguration)
8
Bus.configure().withTransport(sqsTransport) 
Copied!
See also Transports.
withLogger(loggerFactory)
Configures Bus to use a different logging provider than the default consoler logger.
Arguments
Argument
Description
Default
loggerFactory
A factory that creates a new logger
None
Example
1
import { Bus } from '@node-ts/bus-core'
2
import { CustomLogger } from './custom-logger'
3
​
4
Bus.configure().withLogger((target: string) => new CustomLogger(target))
Copied!
See also Loggers.
withSerializer(serializer)
Configures Bus to use a different serialization provider. The provider is responsible for transforming messages to/from a serialized representation, as well as ensuring all object properties are a strong type.
Arguments
Argument
Description
Default
serializer
Serializer to use
None
Example
1
import { Bus } from '@node-ts/bus-core'
2
import { ClassSerializer } from '@node-ts/bus-class-serializer'
3
​
4
Bus.configure().withSerializer(new ClassSerializer())
Copied!
See also Serializer.
withPersistence(persistence)
Configures Bus to use a different persistence provider than the default InMemoryPersistence provider. This is used to persist workflow data and is unused if not using workflows.
Arguments
Argument
Description
Default
persistence
Persistence provider to use
None
Example
1
import { Bus } from '@node-ts/bus-core'
2
import { PostgresPersistence, PostgresConfiguration } from '@node-ts/bus-postgres'
3
​
4
const postgresConfiguration: PostgresConfiguration = {
5
  connection: {
6
    connectionString: 'postgres://postgres:[email protected]:5432/postgres'
7
  },
8
  schemaName: 'workflows'
9
}
10
const postgresPersistence = new PostgresPersistence(postgresConfiguration)
11
Bus.configure().withPersistence(postgresPersistence)
Copied!
See also Persistence.
withConcurrency(concurrency)
Sets the message handling concurrency beyond the default value of 1, which will increase the number of messages handled in parallel.concurrency
Arguments
Argument
Description
Default
concurrency
The number of messages that can be handled in parallel
None
Example
1
import { Bus } from '@node-ts/bus-core'
2
​
3
Bus.configure().withConcurrency(5)
Copied!
withContainer(containerAdapter)
1
withContainer({
2
      get <T>(type: ClassConstructor<T>) {
3
        return container.get<T>(type)
4
      }
5
    })
Copied!
Use a local dependency injection/IoC container to resolve handlers and workflows.
Configures Bus to use a different persistence provider than the default InMemoryPersistence provider. This is used to persist workflow data and is unused if not using workflows.
Arguments
Argument
Description
Default
containerAdapter
An adapter that allows Bus to resolve class instances from the underlying IoC container
None
Example
1
import { Bus } from '@node-ts/bus-core'
2
import { Container } from 'inversify'
3
​
4
const container = new Container()
5
Bus.configure().withContainer({
6
      get <T>(type: ClassConstructor<T>) {
7
        return container.get<T>(type)
8
      }
9
})   
Copied!
See also Dependency injection.​
withMessageReadMiddleware(middleware)
1
  withMessageReadMiddleware<TransportMessageType = unknown> (
2
    messageReadMiddleware: Middleware<TransportMessage<TransportMessageType>>
3
  )
Copied!
Run custom middleware before/after the point a message is read from the transport and then dispatched to handlers and workflow handlers.
Arguments
Argument
Description
Default
middleware
A middleware function that will be executed after a message is read from the transport and before it is dispatched to handlers.
None
Example
1
import { Bus, Middleware, Next, TransportMessage } from '@node-ts/bus-core'
2
​
3
const messageTimingMiddleware = async (
4
  context: TransportMessage<unknown>,
5
  next: Next
6
) => {
7
  const start = Date.now()
8
  await next()
9
  const end = Date.now()
10
  const durationMs = end - start
11
  console.log(
12
    'Message handled',
13
    { messageName: context.domainMessage.$name, durationMs }
14
  )
15
}
16
const bus = await Bus.configure()
17
  .withMessageReadMiddleware(messageTimingMiddleware)
Copied!
See also Middleware.
withRetryStrategy(retryStrategy)
1
  withRetryStrategy({
2
    calculateRetryDelay (currentAttempt: number): number
3
  })
Copied!
Configure the bus to use a different retry strategy instead of the default.
Arguments
Argument
Description
Default
retryStrategy
An implementation of RetryStrategy that calculates the delay between retrying failed messages.
DefaultRetryStrategy
Example
1
const bus = await Bus.configure()
2
  .withRetryStrategy({
3
    calculateRetryDelay (currentAttempt: number) { return Math.pow(2, currentAttempt) }
4
  }) 
5
  .initialize()
Copied!
See also Retry Strategies.
initialize([options])
Initialize a configured BusInstance. This should be called after all options have been provided for the configuration.
Bus
BusInstance
Last modified 6mo ago
Copy link
Contents
Methods
withHandler(classHandler)
withHandler(functionHandler)
withCustomHandler(messageHandler, customResolver)
withWorkflow(workflow)
withTransport(transport)
withLogger(loggerFactory)
withSerializer(serializer)
withPersistence(persistence)
withConcurrency(concurrency)
withContainer(containerAdapter)
withMessageReadMiddleware(middleware)
withRetryStrategy(retryStrategy)
initialize([options])