Completed
Push — master ( 6d1120...3e38c4 )
by Michal
10s
created

RabbitMQMessageForm::__construct()   A

Complexity

Conditions 1
Paths 1

Size

Total Lines 5
Code Lines 3

Duplication

Lines 0
Ratio 0 %

Code Coverage

Tests 0
CRAP Score 2

Importance

Changes 0
Metric Value
dl 0
loc 5
ccs 0
cts 4
cp 0
rs 9.4285
c 0
b 0
f 0
cc 1
eloc 3
nc 1
nop 2
crap 2
1
<?php
2
3
namespace UniMan\Drivers\RabbitMQ\Forms;
4
5
use UniMan\Core\Forms\ItemForm\ItemFormInterface;
6
use Nette\Application\UI\Form;
7
use Nette\Utils\ArrayHash;
8
use PhpAmqpLib\Connection\AMQPStreamConnection;
9
use PhpAmqpLib\Message\AMQPMessage;
10
11
class RabbitMQMessageForm implements ItemFormInterface
12
{
13
    private $connection;
14
15
    private $queue;
16
17
    public function __construct(AMQPStreamConnection $connection, $queue)
18
    {
19
        $this->connection = $connection;
20
        $this->queue = $queue;
21
    }
22
23
    public function addFieldsToForm(Form $form)
24
    {
25
        $form->addText('message', 'rabbitmq.message_form.message.label')
26
            ->setRequired('rabbitmq.message_form.message.required');
0 ignored issues
show
Documentation introduced by
'rabbitmq.message_form.message.required' is of type string, but the function expects a boolean.

It seems like the type of the argument is not accepted by the function/method which you are calling.

In some cases, in particular if PHP’s automatic type-juggling kicks in this might be fine. In other cases, however this might be a bug.

We suggest to add an explicit type cast like in the following example:

function acceptsInteger($int) { }

$x = '123'; // string "123"

// Instead of
acceptsInteger($x);

// we recommend to use
acceptsInteger((integer) $x);
Loading history...
27
    }
28
29
    public function submit(Form $form, ArrayHash $values)
30
    {
31
        $channel = $this->connection->channel();
32
        $channel->queue_declare($this->queue, false, false, false, false);
33
        $messsage = new AMQPMessage($values['message']);
34
        $channel->basic_publish($messsage, '', $this->queue);
35
        $channel->close();
36
        $this->connection->close();
37
    }
38
}
39