Breaking changes:

• Raised minimum PHP version to 8.1+ unlocking the use of fibers
• Swapped react/promise v2 with v3
• Dropped Event Loop injection and replaced it with the global loop accessor

<?php

-use Bunny\Async\Client;
+use Bunny\Client;
-use React\EventLoop\Factory;

require dirname(__DIR__, 2) . '/vendor/autoload.php';

-$loop = Factory::create();

-(new Client($loop))->connect();
+$client = new Client();

-$loop->run();

• Merged Async and Sync clients into Client utilizing fibers through react/async

Sync

receive.php:

<?php

use Bunny\Channel;
use Bunny\Client;
use Bunny\Message;

require dirname(__DIR__, 2) . '/vendor/autoload.php';

-$client = (new Client())->connect();
+$client = new Client();
$channel = $client->channel();

$channel->queueDeclare('hello', false, false, false, false);

echo ' [*] Waiting for messages. To exit press CTRL+C', "\n";

-$channel->run(
+$channel->consume(
    function (Message $message, Channel $channel) {
        echo " [x] Received ", $message->content, "\n";
    },
    'hello',
    '',
    false,
    true,
);

send.php:

<?php

use Bunny\Client;

require dirname(__DIR__, 2) . '/vendor/autoload.php';

-$client = (new Client())->connect();
+$client = new Client();
$channel = $client->channel();
$channel->queueDeclare('hello', false, false, false, false);
$channel->close();

$channel->publish('Hello World!', [], '', 'hello');
echo " [x] Sent 'Hello World!'\n";

$channel->close();
$client->disconnect();

Async

receive-async.php:

<?php

use Bunny\Channel;
-use Bunny\Async\Client;
+use Bunny\Client;
use Bunny\Message;
-use React\EventLoop\Factory;

require dirname(__DIR__, 2) . '/vendor/autoload.php';

-$loop = Factory::create();

-(new Client($loop))->connect()
+$client = new Client();
-->then(function (Client $client) {
-    return $client->channel();
-})
+$channel = $client->channel();

-->then(function (Channel $channel) {
-    return $channel->queueDeclare('hello', false, false, false, false)->then(function () use ($channel) {
-        return $channel;
-    });
-})
+$channel->queueDeclare('hello', false, false, false, false);

-->then(function (Channel $channel) {
-    echo ' [*] Waiting for messages. To exit press CTRL+C', "\n";
-    $channel->consume(
-        function (Message $message, Channel $channel, Client $client) {
-            echo " [x] Received ", $message->content, "\n";
-        },
-        'hello',
-        '',
-        false,
-        true
-    );
-});
+echo ' [*] Waiting for messages. To exit press CTRL+C', "\n";

+$channel->consume(
+    function (Message $message, Channel $channel) {
+        echo " [x] Received ", $message->content, "\n";
+    },
+    'hello',
+    '',
+    false,
+    true,
+);

-$loop->run();

send-async.php:

<?php

-use Bunny\Channel;
-use Bunny\Async\Client;
+use Bunny\Client;
-use React\EventLoop\Factory;

require dirname(__DIR__, 2) . '/vendor/autoload.php';

-$loop = Factory::create();

-(new Client($loop))->connect()
+$client = new Client();

-->then(function (Client $client) {
-    return $client->channel();
-})
+$channel = $client->channel();

-->then(function (Channel $channel) {
-    return $channel->queueDeclare('hello', false, false, false, false)->then(function () use ($channel) {
-        return $channel;
-    });
-})
+$channel->queueDeclare('hello', false, false, false, false);

-->then(function (Channel $channel) {
-    echo " [x] Sending 'Hello World!'\n";
-    return $channel->publish('Hello World!', [], '', 'hello')->then(function () use ($channel) {
-        return $channel;
-    });
-})
+$channel->publish('Hello World!', [], '', 'hello');

-->then(function (Channel $channel) {
-    echo " [x] Sent 'Hello World!'\n";
-    $client = $channel->getClient();
-    return $channel->close()->then(function () use ($client) {
-        return $client;
-    });
-})
+echo " [x] Sent 'Hello World!'\n";
+$channel->close();

-->then(function (Client $client) {
-    $client->disconnect();
-});
+$client->disconnect();

• Channel::queueBind arguments string $queue and string $exchange switched argument locations

<?php

use Bunny\Channel;
use Bunny\Client;
use Bunny\Message;

require dirname(__DIR__, 2) . '/vendor/autoload.php';


$client = new Client();
$channel = $client->channel();

$channel->exchangeDeclare('logs', 'fanout');
$queue = $channel->queueDeclare('', false, false, true, false);
-$channel->queueBind($queue->queue, 'logs');
+$channel->queueBind('logs', $queue->queue);

======

• Total issues resolved: 1
• Total pull requests resolved: 32
• Total contributors: 5

enhancement

• 190: Drop react-amqp from readme thanks to @WyriHaximus
• 189: [0.6.x] CI Optimizations thanks to @WyriHaximus
• 187: [0.6.x] Tidy up readme thanks to @WyriHaximus
• 186: [0.6.x] Update benchmark numbers thanks to @WyriHaximus
• 185: [0.6.x] Improve benchmark outputs thanks to @WyriHaximus
• 184: [0.6.x] Make Connection::onHeartbeat private thanks to @WyriHaximus
• 182: [0.6.x] Change SSL to TLS thanks to @WyriHaximus
• 181: [0.6.x] Refactor configuration internals thanks to @WyriHaximus
• 180: [0.6.x] Optional loop instance to client thanks to @tomas-novotny
• 177: [0.6.x] Update the minimum PHP version mention in the readme to 8.1 thanks to @WyriHaximus
• 176: [0.6.x] Add Configuration object thanks to @WyriHaximus
• 172: [0.6.x] One command local testing thanks to @WyriHaximus
• 167: Better typehints thanks to @tomas-novotny
• 166: Update code style thanks to @tomas-novotny
• 165: Support int64 in arguments thanks to @tomas-novotny
• 163: Missing methods to ChannelInterface thanks to @tomas-novotny
• 160: Test against RabbitMQ 4 thanks to @WyriHaximus
• 154: Replace *Enum classes with a native Enums thanks to @jeromegamez
• 152: Generate better connections thanks to @jeromegamez
• 150: Add support for setting client properties thanks to @jeromegamez
• 143: react/promise 3.0 support? thanks to @lookyman
• 153: Replace elseifs with early returns in Connection thanks to @jeromegamez
• 148: Allow CI workflow to be manually triggered thanks to @WyriHaximus

bug

• 188: [0.6.x] Run CI on pushes to 0.6.x branch thanks to @WyriHaximus
• 183: [0.6.x] Local development TLS fixes thanks to @WyriHaximus
• 173: [0.6.x] Strengthen channel consume test assertations thanks to @WyriHaximus
• 169: [0.6.x] Wait for connection to fully open while opening channel thanks to @WyriHaximus
• 164: Consume should only process one message at a time thanks to @WyriHaximus
• 162: Remove implicit nullable typehints for PHP 8.4 compatibility thanks to @janlanger

feature

• 171: [0.6.x] Concurrent consuming thanks to @WyriHaximus

bug,enhancement

• 170: [0.6.x] Await for connection in async thanks to @tomas-novotny

enhancement,feature

• 147: Rebuild into async only with sync API thanks to @WyriHaximus