bugfix/DEV-4588 - Veel NATS messages worden niet opgepakt zoals bij de GFP te zien

src/Publisher/JetStreamPublisher.php

@@ -34,6 +34,11 @@ public function __construct(
     }
 
     public function publish(string $subject, string $payload): void
+    {
+        $this->stream->publish($subject, $payload);
+    }
+
+    public function publishFireAndForget(string $subject, string $payload): void
     {
         $this->stream->put($subject, $payload);
     }

tests/Publisher/JetStreamPublisherTest.php

@@ -64,7 +64,7 @@
     new JetStreamPublisher($connection, $streamName);
 })->throws(RuntimeException::class, 'JetStream stream "MISSING_STREAM" does not exist');
 
-it('publishes using stream->put()', function () {
+it('publishes using stream->publish() for JetStream ack', function () {
     // Arrange
     $streamName = 'FLOW';
     $subject = 'flow.order.created';
@@ -91,7 +91,7 @@
 
     $stream->shouldReceive('exists')->once()->andReturn(true);
 
-    $stream->shouldReceive('put')
+    $stream->shouldReceive('publish')
         ->with($subject, $payload)
         ->once();
 
@@ -102,3 +102,42 @@
     // Assert
     expect(true)->toBeTrue();
 });
+
+it('publishes fire-and-forget using stream->put()', function () {
+    // Arrange
+    $streamName = 'FLOW';
+    $subject = 'flow.telemetry.heartbeat';
+    $payload = 'fire-and-forget-payload';
+
+    $connection = Mockery::mock(NatsConnection::class);
+    $client = Mockery::mock(Client::class);
+    $api = Mockery::mock(Api::class);
+    $stream = Mockery::mock(Stream::class);
+
+    $connection->shouldReceive('getClient')
+        ->once()
+        ->andReturn($client);
+
+    $client
+        ->shouldReceive('getApi')
+        ->once()
+        ->andReturn($api);
+
+    $api->shouldReceive('getStream')
+        ->with($streamName)
+        ->once()
+        ->andReturn($stream);
+
+    $stream->shouldReceive('exists')->once()->andReturn(true);
+
+    $stream->shouldReceive('put')
+        ->with($subject, $payload)
+        ->once();
+
+    // Act
+    $publisher = new JetStreamPublisher($connection, $streamName);
+    $publisher->publishFireAndForget($subject, $payload);
+
+    // Assert
+    expect(true)->toBeTrue();
+});