Nachricht
Nachricht is a message dispatcher which focuses on distributing workloads.
Features
- Directly dispatch messages
- Dispatch messages via AMQP
- auto-discovery to find and create AMQP Messages queues
- dead-lettering mechanism
Requirements
A PSR-11 compatible container (we recommend the Symfony DependencyInjection component) is required. The instances of listeners will be obtained from the container via $container->get($listenerClass).
The RabbitMQ delayed message exchange plugin may be installed before using Nachricht to make sure you can work with message delay.
Usage
Create an message class by implementing JTL\Nachricht\Contract\Message\Message.
use JTL\Nachricht\Contract\Message\Message;
class DummyMessage implements Message
{
private string $data;
public function __construct(string $data)
{
$this->data = $data;
}
public function getData(): string
{
return $this->data;
}
}
Create a listener class by implementing JTL\Nachricht\Contract\Listener\Listener
use JTL\Nachricht\Contract\Listener\Listener;
class DummyListener implements Listener
{
public function listen(DummyMessage $event): void
{
echo 'Dummy Listener called: ' . $event->getData() . "\n";
}
}
Emit the Event
$emitter = $container->get(DirectEmitter::class);
$event = new FooMessage('Test');
$emitter->emit($event);
Output
# php examples/DirectEmit/DirectEmit.php
FooListener called: Test
Emit delayed messages
A delay can be used to make a message invisible for the consumer until a defined time is reached. There are two types of delay available
On message construct: delay a message when it is getting emitted. You can specify such a delay (in seconds) when constructing a new message instance.
$event = new DelayedDummyAmqpMessage(data: 'Test', delay: 3);
$emitter->emit($event);
To specify a retry delay overwrite method getRetryDelay(): int method (default retry delay is set to 3 seconds). Such delay will be used every time a Listener facing an Error when cause jtl/nachricht to re-queue the message
You can find more examples in the example directory.
11 Oct 13, 2020
197 Dec 30, 2022
17 Oct 24, 2022
16 Jul 17, 2022
2.2k Dec 28, 2022
4 Dec 8, 2022
1 Jan 7, 2022
364 Oct 18, 2022
1 Jan 21, 2022
1.1k Jan 4, 2023
299 Nov 29, 2022
24 Aug 10, 2022
6 Jan 18, 2022
0 Dec 25, 2021
7.9k Jan 7, 2023
457 Jan 8, 2023
3 Jan 6, 2022
18 Nov 20, 2022
1 Nov 17, 2021