Skip to content

Commit 16a3b8d

Browse files
committed
updates PHP files to use videlalvaro/php-amqplib
1 parent c75e098 commit 16a3b8d

File tree

8 files changed

+21
-9
lines changed

8 files changed

+21
-9
lines changed

php/emit_log.php

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,8 @@
11
<?php
22

3-
require_once(__DIR__ . '/lib/php-amqplib/amqp.inc');
3+
require_once __DIR__ . '/vendor/autoload.php';
4+
use PhpAmqpLib\Connection\AMQPConnection;
5+
use PhpAmqpLib\Message\AMQPMessage;
46

57
$connection = new AMQPConnection('localhost', 5672, 'guest', 'guest');
68
$channel = $connection->channel();

php/new_task.php

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,8 @@
11
<?php
22

3-
require_once(__DIR__ . '/lib/php-amqplib/amqp.inc');
3+
require_once __DIR__ . '/vendor/autoload.php';
4+
use PhpAmqpLib\Connection\AMQPConnection;
5+
use PhpAmqpLib\Message\AMQPMessage;
46

57
$connection = new AMQPConnection('localhost', 5672, 'guest', 'guest');
68
$channel = $connection->channel();

php/receive.php

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,7 @@
11
<?php
22

3-
require_once(__DIR__ . '/lib/php-amqplib/amqp.inc');
3+
require_once __DIR__ . '/vendor/autoload.php';
4+
use PhpAmqpLib\Connection\AMQPConnection;
45

56
$connection = new AMQPConnection('localhost', 5672, 'guest', 'guest');
67
$channel = $connection->channel();

php/receive_logs.php

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,7 @@
11
<?php
22

3-
require_once(__DIR__ . '/lib/php-amqplib/amqp.inc');
3+
require_once __DIR__ . '/vendor/autoload.php';
4+
use PhpAmqpLib\Connection\AMQPConnection;
45

56
$connection = new AMQPConnection('localhost', 5672, 'guest', 'guest');
67
$channel = $connection->channel();

php/rpc_client.php

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,8 @@
11
<?php
22

3-
require_once(__DIR__ . '/lib/php-amqplib/amqp.inc');
3+
require_once __DIR__ . '/vendor/autoload.php';
4+
use PhpAmqpLib\Connection\AMQPConnection;
5+
use PhpAmqpLib\Message\AMQPMessage;
46

57
class FibonacciRpcClient {
68
private $connection;

php/rpc_server.php

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,8 @@
11
<?php
22

3-
require_once(__DIR__ . '/lib/php-amqplib/amqp.inc');
3+
require_once __DIR__ . '/vendor/autoload.php';
4+
use PhpAmqpLib\Connection\AMQPConnection;
5+
use PhpAmqpLib\Message\AMQPMessage;
46

57
$connection = new AMQPConnection('localhost', 5672, 'guest', 'guest');
68
$channel = $connection->channel();

php/send.php

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,8 @@
11
<?php
22

3-
require_once(__DIR__ . '/lib/php-amqplib/amqp.inc');
3+
require_once __DIR__ . '/vendor/autoload.php';
4+
use PhpAmqpLib\Connection\AMQPConnection;
5+
use PhpAmqpLib\Message\AMQPMessage;
46

57
$connection = new AMQPConnection('localhost', 5672, 'guest', 'guest');
68
$channel = $connection->channel();

php/worker.php

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,11 +1,11 @@
11
<?php
22

3-
require_once(__DIR__ . '/lib/php-amqplib/amqp.inc');
3+
require_once __DIR__ . '/vendor/autoload.php';
4+
use PhpAmqpLib\Connection\AMQPConnection;
45

56
$connection = new AMQPConnection('localhost', 5672, 'guest', 'guest');
67
$channel = $connection->channel();
78

8-
99
$channel->queue_declare('task_queue', false, true, false, false);
1010

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

0 commit comments

Comments
 (0)