add worker

Author: oylenshpeegul

new_task.pl

@@ -4,6 +4,8 @@
 use warnings;
 use Net::AMQP::RabbitMQ;
 
+my $message = shift // 'Hello, World!';
+
 my $mq = Net::AMQP::RabbitMQ->new;
 
 $mq->connect('localhost', { user => 'guest', password => 'guest' });
@@ -12,8 +14,8 @@
 
 $mq->queue_declare(1, 'hello');
 
-$mq->publish(1, 'hello', 'Hello, World!');
+$mq->publish(1, 'hello', $message);
 
-say " [x] Sent 'Hello World!' ";
+say " [x] Sent '$message' ";
 
 $mq->disconnect;

worker.pl

@@ -0,0 +1,21 @@
+#!/usr/bin/env perl
+
+use v5.24;
+use warnings;
+use Net::AMQP::RabbitMQ;
+
+my $mq = Net::AMQP::RabbitMQ->new();
+
+$mq->connect('localhost', { user => 'guest', password => 'guest' });
+
+$mq->channel_open(1);
+
+$mq->queue_declare(1, 'hello');
+
+$mq->consume(1, 'hello');
+
+say ' [*] Waiting for messages. To exit press CTRL-C';
+while (1) {
+my $received = $mq->recv(0);
+say " [x] Received '$received->{body}'";
+}