SimpleBusPublisher::publish() - Code Metrics - damax-solutions/enqueue-simple-bus-queue-interop - Measure and Improve Code Quality continuously with Scrutinizer

SimpleBusPublisher::publish() A
last analyzed 2019-02-16 20:45 UTC

↳ Parent: SimpleBusPublisher

Complexity

Conditions	1
Paths	1

Size

Total Lines	7
Code Lines	3

Duplication

Lines	0
Ratio	0 %

Importance

Changes

Metric	Value
eloc	3
dl	0
loc	7
rs	10
c	0
b	0
f	0
cc	1
nc	1
nop	1

<?php

declare(strict_types=1);

namespace Enqueue\SimpleBus;

use Interop\Queue\Context;
use SimpleBus\Asynchronous\Publisher\Publisher;
use SimpleBus\Asynchronous\Routing\RoutingKeyResolver;
use SimpleBus\Serialization\Envelope\Serializer\MessageInEnvelopeSerializer;

final class SimpleBusPublisher implements Publisher
{
    private $serializer;
    private $queueResolver;
    private $context;

    public function __construct(MessageInEnvelopeSerializer $serializer, RoutingKeyResolver $queueResolver, Context $context)
    {
        $this->serializer = $serializer;
        $this->queueResolver = $queueResolver;
        $this->context = $context;
    }

    public function publish($message): void
    {
        $queue = $this->context->createQueue($this->queueResolver->resolveRoutingKeyFor($message));

        $message = $this->context->createMessage($this->serializer->wrapAndSerialize($message));

        $this->context->createProducer()->send($queue, $message);
    }
}


1			<?php
2
3			declare(strict_types=1);
4
5			namespace Enqueue\SimpleBus;
6
7			use Interop\Queue\Context;
8			use SimpleBus\Asynchronous\Publisher\Publisher;
9			use SimpleBus\Asynchronous\Routing\RoutingKeyResolver;
10			use SimpleBus\Serialization\Envelope\Serializer\MessageInEnvelopeSerializer;
11
12			final class SimpleBusPublisher implements Publisher
13			{
14			private $serializer;
15			private $queueResolver;
16			private $context;
17
18			public function __construct(MessageInEnvelopeSerializer $serializer, RoutingKeyResolver $queueResolver, Context $context)
19			{
20			$this->serializer = $serializer;
21			$this->queueResolver = $queueResolver;
22			$this->context = $context;
23			}
24
25			public function publish($message): void
26			{
27			$queue = $this->context->createQueue($this->queueResolver->resolveRoutingKeyFor($message));
28
29			$message = $this->context->createMessage($this->serializer->wrapAndSerialize($message));
30
31			$this->context->createProducer()->send($queue, $message);
32			}
33			}
34

damax-solutions / enqueue-simple-bus-queue-interop

SimpleBusPublisher::publish() A last analyzed 2019-02-16 20:45 UTC

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like

SimpleBusPublisher::publish() A
last analyzed 2019-02-16 20:45 UTC