Fixed a bug when used `consumer_update_listener` callback from anothe… #607

	name: CI

	on:
	push:
	branches:
	- master
	pull_request:
	types:
	- opened
	- synchronize

	jobs:
	ci:
	strategy:
	fail-fast: false
	matrix:
	python-version: [3.9]
	os: [ubuntu-22.04]
	runs-on: ${{ matrix.os }}
	services:
	rabbitmq-streaming:
	image: rabbitmq:3.13.1-management
	env:
	RABBITMQ_SERVER_ADDITIONAL_ERL_ARGS: "-rabbitmq_stream advertised_host localhost"
	ports:
	- 5552:5552
	- 15672:15672
	steps:
	- uses: actions/checkout@v2
	- uses: actions/setup-python@v2
	with:
	python-version: ${{ matrix.python-version }}
	- name: Install and configure Poetry
	uses: snok/install-poetry@v1
	with:
	version: 1.4.2
	virtualenvs-create: true
	virtualenvs-in-project: false
	- name: Enable RabbitMQ Plugins
	run: docker exec ${{ job.services.rabbitmq-streaming.id }} rabbitmq-plugins enable rabbitmq_stream rabbitmq_stream_management rabbitmq_amqp1_0
	- name: poetry install
	run: poetry install --no-root
	- name: isort check-only
	run: poetry run isort --check-only .
	- name: black check
	run: poetry run black --check .
	- name: flake8
	run: poetry run flake8 --exclude=venv,local_tests,docs/examples --max-line-length=120 --ignore=E203,W503
	- name: mypy
	run: \|
	poetry add --group dev requests
	poetry add --group dev types-requests
	poetry run mypy .
	- name: poetry run pytest
	run: poetry run pytest

Provide feedback