import { messagingClient } from '@marblejs/messaging';
messagingClient :: MessagingClientConfig
-> Reader<Context, Promise<MessagingClient>>
import { bindEagerlyTo, createContextToken } from '@marblejs/core';
import { messagingClient, Transport } from '@marblejs/messaging';
const AmqpClientToken = createContextToken<MessagingClient>('AmqpClient');
const AmqpClient = messagingClient({
transport: Transport.AMQP,
options: {
host: 'amqp://localhost:5672',
queue: 'some_queue_name',
queueOptions: { durable: false },
timeout: 360 * 1000,
},
});
...
const dependencies = [
bindEagerlyTo(AmqpClientToken)(AmqpClient),
];
import { bindEagerlyTo, createContextToken } from '@marblejs/core';
import { messagingClient, Transport } from '@marblejs/messaging';
const RedisClientToken = createContextToken<MessagingClient>('RedisClient');
const RedisClient = messagingClient({
transport: Transport.REDIS,
options: {
host: 'redis://127.0.0.1:6379',
channel: 'some_channel_name',
timeout: 360 * 1000,
},
});
...
const dependencies = [
bindEagerlyTo(RedisClientToken)(RedisClient),
];