Completed
Pull Request — master (#27)
by Frederic
06:01
created
src/Daemon/QueueHandlingDaemon.php 2 patches
Unused Use Statements   +3 added lines, -3 removed lines patch added patch discarded remove patch
@@ -4,18 +4,18 @@
 block discarded – undo
4 4
 
5 5
 use Burrow\Clock;
6 6
 use Burrow\ConsumeOptions;
7
+use Burrow\Driver;
7 8
 use Burrow\Event\DaemonStarted;
8 9
 use Burrow\Event\DaemonStopped;
9 10
 use Burrow\Event\MessageConsumed;
10 11
 use Burrow\Event\MessageReceived;
11 12
 use Burrow\Event\NullEmitter;
13
+use Burrow\Message;
14
+use Burrow\QueueHandler;
12 15
 use Burrow\RealClock;
13 16
 use Evaneos\Daemon\Daemon;
14 17
 use Evaneos\Daemon\DaemonMonitor;
15
-use Burrow\Driver;
16
-use Burrow\Message;
17 18
 use Evaneos\Daemon\Monitor\NullMonitor;
18
-use Burrow\QueueHandler;
19 19
 use League\Event\Emitter;
20 20
 use League\Event\EmitterInterface;
21 21
 use Psr\Log\LoggerAwareInterface;
Please login to merge, or discard this patch.
Spacing   +1 added lines, -1 removed lines patch added patch discarded remove patch
@@ -85,7 +85,7 @@
 block discarded – undo
85 85
 
86 86
         $this->driver->consume(
87 87
             $this->queueName,
88
-            function (Message $message) use ($startTime) {
88
+            function(Message $message) use ($startTime) {
89 89
                 $this->eventEmitter->emit(new MessageReceived());
90 90
                 $this->monitor->monitor($this, $message);
91 91
 
Please login to merge, or discard this patch.