createMicroservice

Creates and bootstraps microservice for given transport layer

Importing

import { createMicroservice } from '@marblejs/messaging';

Type declaration

createMicroservice :: CreateMicroserviceConfig
-> Promise<ServerIO<TransportLayerConnection>>

Parameters

parameter

definition

config

CreateMicroserviceConfig

CreateMicroserviceConfig

parameter

definition

listener

MessagingListener

event$

<optional> HttpServerEffect

dependencies

<optional> Array<BoundDependency<any>>

transport

Transport

options

StrategyOptions

StrategyOptions (Transport.AMQP)

parameter

definition

host

string

queue

string

queueOptions

<optional> Options.AssertQueue (see: amqplib)

prefetchCount

<optional> number (defaults to 1)

expectAck

<optional> boolean

timeout

<optional> number in ms (defaults to 120s)

StrategyOptions (Transport.REDIS)

parameter

definition

host

string

channel

string

port

<optional> number

password

<optional> string

timeout

<optional> number in ms (defaults to 120s)

Example (AMQP):

import { IO } from 'fp-ts/lib/IO';
import { createMicroservice, messagingListener, Transport } from '@marblejs/messaging';
const amqpMicroservice = createMicroservice({
transport: Transport.AMQP,
options: {
host: 'amqp://localhost:5672',
queue: 'some_queue_name',
queueOptions: { durable: true },
timeout: 360 * 1000,
},
listener: messagingListener(...),
dependencies: [...],
});
const main: IO<void> = async () =>
(await amqpMicroservice)()
main();

Example (REDIS):

import { IO } from 'fp-ts/lib/IO';
import { createMicroservice, messagingListener, Transport } from '@marblejs/messaging';
const redisMicroservice = createMicroservice({
transport: Transport.REDIS,
options: {
host: 'redis://127.0.0.1:6379',
channel: 'some_channelname',
timeout: 360 * 1000,
},
listener: messagingListener(...),
dependencies: [...],
});
const main: IO<void> = async () =>
(await redisMicroservice)()
main();