Commit 36d201c

committed

Ensure pass consumer tag as string to bunny amqp (fixes 8.1 compatibility)

1 parent fb1aacc commit 36d201cCopy full SHA for 36d201c

File tree

-1

lines changed

-1

lines changed

Lines changed: 1 addition & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -88,7 +88,7 @@ public function subscribe(Consumer $consumer, callable $callback): void`
`88`	`88`	`$frame = $this->context->getBunnyChannel()->consume(`
`89`	`89`	`$bunnyCallback,`
`90`	`90`	`$consumer->getQueue()->getQueueName(),`
`91`		`- $consumer->getConsumerTag(),`
	`91`	`+ $consumer->getConsumerTag() ?? '',`
`92`	`92`	`(bool) ($consumer->getFlags() & InteropAmqpConsumer::FLAG_NOLOCAL),`
`93`	`93`	`(bool) ($consumer->getFlags() & InteropAmqpConsumer::FLAG_NOACK),`
`94`	`94`	`(bool) ($consumer->getFlags() & InteropAmqpConsumer::FLAG_EXCLUSIVE),`

Comments

(0)