
Security News
Deno 2.2 Improves Dependency Management and Expands Node.js Compatibility
Deno 2.2 enhances Node.js compatibility, improves dependency management, adds OpenTelemetry support, and expands linting and task automation for developers.
The MB client creates an abstraction over the inter-service interaction on top of RabbitMQ. The library defines a common interface for messages and provides ways to send and subscribe to them. The client supports automatic re-connections to RabbitMQ and support for the Rabbit cluster.
The mechanism is quite simple and currently supports 2 simple operation modes (sending directly to the queue, sending to topic exchange).
When a client created, a durable topic exchange ("dispatcher" by default) is automatically created, and a service queue (with the name that was passed as serviceName during initialization).
When sending a message indicating the recipients, the message sent to their queue directly. Otherwise, the message sent via routingKey "{serviceName}.{Action}" to the dispatcher exchange.
Check FAQ if you have questions.
import { createClient } from 'mbclient';
const logger = {
info: console.log,
warn: console.log,
error: console.error,
}
const client = createClient({
serviceName: 'news',
logger,
connectOptions: {
username: 'test',
password: '123',
host: 'localhost',
amqps: true,
frameMax: 8192,
},
queueOptions: {
singleActiveConsumer: true,
}
});
See AMQPOptions interface to get all available options.
See QueueOptions interface to get all available queue options.
// listening to messages
client.consumeByAction('logAction', ({ message, ack, nack }) => {
// do something
ack();
});
client.consumeByAction('otherAction', ({ message, ack, nack }) => {
// do something
ack();
});
The handler will be called if there is no handler for specified action type.
client.consume(({ message, ack, nack }) => {
// do something
ack();
});
client.send({
action: 'comeAction',
payload: 'some payload',
requestId: 'id',
recipients: ['news', 'test'] // a message will be sent to news and test
});
client.send({
action: 'someAction', // Everyone who consumed on someAction will receive this message
payload: 'some payload',
requestId: 'id',
});
It is possible to subscribe to a change in connection status with rabbitmq
client.on('disconnected', () => {
// do something
});
client.on('connected', () => {
// do something
});
Supported Events:
connecting
- Attempt to connect to amqp
connected
- Successful connection to amqp
disconnecting
- Close the connection (usually emitted when calling close for a graceful disconnect)
disconnected
- Loss of connection with amqp due to an error or as a result of processing close ()
Create one more client instance with required exchange name in connectOptions.
client.send({
action: 'someAction',
payload: 'some payload',
routingKey: 'my.routingKey'
});
It may happen because of action names collision. For example, service A sends messages with action entityCreated
to service B directly (with specifying recipients: ['serviceB']
). Later a service C was added that sends messages
with the same action, but uses broadcast sending. In this case service B will also receive messages from service C.
Copyright 2019 Tinkoff Bank
Licensed under the Apache License, Version 2.0 (the "License");
you may not use this file except in compliance with the License.
You may obtain a copy of the License at
http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software
distributed under the License is distributed on an "AS IS" BASIS,
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
See the License for the specific language governing permissions and
limitations under the License.
FAQs
Message broker library
The npm package mbclient receives a total of 7 weekly downloads. As such, mbclient popularity was classified as not popular.
We found that mbclient demonstrated a healthy version release cadence and project activity because the last version was released less than a year ago. It has 0 open source maintainers collaborating on the project.
Did you know?
Socket for GitHub automatically highlights issues in each pull request and monitors the health of all your open source dependencies. Discover the contents of your packages and block harmful activity before you install or update your dependencies.
Security News
Deno 2.2 enhances Node.js compatibility, improves dependency management, adds OpenTelemetry support, and expands linting and task automation for developers.
Security News
React's CRA deprecation announcement sparked community criticism over framework recommendations, leading to quick updates acknowledging build tools like Vite as valid alternatives.
Security News
Ransomware payment rates hit an all-time low in 2024 as law enforcement crackdowns, stronger defenses, and shifting policies make attacks riskier and less profitable.