Skip to content

FakeAioPikaFastProducer

faststream.rabbit.publisher.producer.FakeAioPikaFastProducer #

Bases: AioPikaFastProducer

connect #

connect(serializer=None)
Source code in faststream/rabbit/publisher/producer.py 
83
84
def connect(self, serializer: Optional["SerializerProto"] = None) -> None:
    raise NotImplementedError

disconnect #

disconnect()
Source code in faststream/rabbit/publisher/producer.py 
86
87
def disconnect(self) -> None:
    raise NotImplementedError

publish async #

publish(cmd)
Source code in faststream/rabbit/publisher/producer.py 
89
90
91
92
93
94
@override
async def publish(
    self,
    cmd: "RabbitPublishCommand",
) -> Optional["aiormq.abc.ConfirmationFrameType"]:
    raise NotImplementedError

request async #

request(cmd)
Source code in faststream/rabbit/publisher/producer.py 
96
97
98
@override
async def request(self, cmd: "RabbitPublishCommand") -> "IncomingMessage":
    raise NotImplementedError

publish_batch async #

publish_batch(cmd)
Source code in faststream/rabbit/publisher/producer.py 
73
74
75
76
@override
async def publish_batch(self, cmd: "RabbitPublishCommand") -> None:
    msg = "RabbitMQ doesn't support publishing in batches."
    raise FeatureNotSupportedException(msg)