8000 Minor tweaks to first example code, queue should be autodelete=false etc · seanhuang/rabbitmq-tutorials@0e3a569 · GitHub
[go: up one dir, main page]
Skip to content

Commit 0e3a569

Browse files
majekmajek
committed
Minor tweaks to first example code, queue should be autodelete=false etc
1 parent 93266b6 commit 0e3a569

File tree

2 files changed

+8
-9
lines changed

2 files changed

+8
-9
lines changed

‎php/receive.php

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

33
require_once(__DIR__ . '/lib/php-amqplib/amqp.inc');
4-
include_once(__DIR__ . '/config/config.php');
54

6-
$connection = new AMQPConnection(HOST, PORT, USER, PASS, VHOST);
5+
$connection = new AMQPConnection('localhost', 5672, 'guest', 'guest');
76
$channel = $connection->channel();
87

9-
$channel->queue_declare('test');
8+
9+
$channel->queue_declare('test', false, false, false, false);
1010

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

13-
$callback = function($msg){
13+
$callback = function($msg) {
1414
echo " [x] Received ", $msg->body, "\n";
1515
};
1616

17-
$channel->basic_consume('test', 'consumer_tag', false, true, false, false, $callback);
17+
$channel->basic_consume('test', '', false, true, false, false, $callback);
1818

1919
while(count($channel->callbacks)) {
2020
$channel->wait();

‎php/send.php

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

33
require_once(__DIR__ . '/lib/php-amqplib/amqp.inc');
4-
include_once(__DIR__ . '/config/config.php');
54

6-
$connection = new AMQPConnection(HOST, PORT, USER, PASS, VHOST);
5+
$connection = new AMQPConnection('localhost', 5672, 'guest', 'guest');
76
$channel = $connection->channel();
87

9-
$channel->queue_declare('test');
108

11-
$msg = new AMQPMessage('Hello World!');
9+
$channel->queue_declare('test', false, false, false, false);
1210

11+
$msg = new AMQPMessage('Hello World!');
1312
$channel->basic_publish($msg, '', 'test');
1413

1514
echo " [x] Sent 'Hello World!'\n";

0 commit comments

Comments
 (0)
0