File tree Expand file tree Collapse file tree 2 files changed +2
-6
lines changed Expand file tree Collapse file tree 2 files changed +2
-6
lines changed Original file line number Diff line number Diff line change @@ -90,8 +90,6 @@ protected function maybeStopConsumer()
90
90
91
91
if ($ this ->forceStop || ($ this ->consumed == $ this ->target && $ this ->target > 0 )) {
92
92
$ this ->stopConsuming ();
93
- } else {
94
- return ;
95
93
}
96
94
}
97
95
Original file line number Diff line number Diff line change @@ -121,13 +121,13 @@ public function consume()
121
121
$ this ->batchConsume ();
122
122
}
123
123
124
- $ timeoutWanted = ( $ isConsuming) ? $ this ->getTimeoutWait () : $ this ->getIdleTimeout ();
124
+ $ timeoutWanted = $ isConsuming ? $ this ->getTimeoutWait () : $ this ->getIdleTimeout ();
125
125
}
126
126
}
127
127
128
128
public function batchConsume ()
129
129
{
130
- if ($ this ->batchCounter == 0 ) {
130
+ if ($ this ->batchCounter === 0 ) {
131
131
return ;
132
132
}
133
133
@@ -387,8 +387,6 @@ protected function maybeStopConsumer()
387
387
388
388
if ($ this ->forceStop ) {
389
389
$ this ->stopConsuming ();
390
- } else {
391
- return ;
392
390
}
393
391
}
394
392
You can’t perform that action at this time.
0 commit comments