Skip to content

Commit d50f1c7

Browse files
committed
Remove admin operations
1 parent 37e9881 commit d50f1c7

File tree

1 file changed

+0
-10
lines changed

1 file changed

+0
-10
lines changed

src/PubSubQueue.php

Lines changed: 0 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -160,9 +160,6 @@ public function pop($subscriber = null)
160160
$this->subscriber = $subscriber;
161161
$topic = $this->getTopic($this->getQueue($subscriber));
162162

163-
if (!$topic->exists()) {
164-
return;
165-
}
166163
$subscription = $topic->subscription($subscriber);
167164
$messages = $subscription->pull([
168165
'returnImmediately' => true,
@@ -288,10 +285,6 @@ public function getTopic($queue, $create = false)
288285
$queue = $this->getQueue($queue);
289286
$topic = $this->pubsub->topic($queue);
290287

291-
if (!$topic->exists() && $create) {
292-
$topic->create();
293-
}
294-
295288
return $topic;
296289
}
297290

@@ -305,9 +298,6 @@ public function getTopic($queue, $create = false)
305298
public function subscribeToTopic(Topic $topic, $subscriber = null)
306299
{
307300
$subscription = $topic->subscription($subscriber);
308-
if (!$subscription->exists()) {
309-
$subscription = $topic->subscribe($subscriber);
310-
}
311301

312302
return $subscription;
313303
}

0 commit comments

Comments
 (0)