# SPDX-FileCopyrightText: 2019-2024 Helmholtz Centre Potsdam GFZ German Research Centre for Geosciences
# SPDX-FileCopyrightText: 2020-2021 Helmholtz-Zentrum Geesthacht GmbH
# SPDX-FileCopyrightText: 2021-2024 Helmholtz-Zentrum hereon GmbH
#
# SPDX-License-Identifier: Apache-2.0
from warnings import warn
from demessaging.messaging.consumer import MessageConsumer # noqa: F403, F401
warn(
"The demessaging.PulsarMessageConsumer module has been renamed to "
"demessaging.messaging.consumer and will be removed soon!",
DeprecationWarning,
)
[docs]
class PulsarMessageConsumer(MessageConsumer):
# deprecated
def __init__(self, *args, **kwargs):
warn(
"The `demessaging.PulsarMessageConsumer.PulsarMessageConsumer` "
"class has been replaced by the "
"`demessaging.messaging.consumer.MessageConsumer` class "
"and will be removed soon!",
DeprecationWarning,
)
super().__init__(*args, **kwargs)