Skip to content

FakeAioPikaFastProducer

faststream.rabbit.publisher.producer.FakeAioPikaFastProducer #

Bases: AioPikaFastProducer

codec instance-attribute #

codec: CodecProto

connect #

connect(
    serializer: Optional[SerializerProto] = None,
    codec: Optional[CodecProto] = None,
) -> None
Source code in faststream/rabbit/publisher/producer.py 
 97
 98
 99
100
101
102
def connect(
    self,
    serializer: Optional["SerializerProto"] = None,
    codec: Optional["CodecProto"] = None,
) -> None:
    raise NotImplementedError

disconnect #

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

publish async #

publish(
    cmd: RabbitPublishCommand,
) -> Optional[ConfirmationFrameType]
Source code in faststream/rabbit/publisher/producer.py 
107
108
109
110
111
112
@override
async def publish(
    self,
    cmd: "RabbitPublishCommand",
) -> Optional["aiormq.abc.ConfirmationFrameType"]:
    raise NotImplementedError

request async #

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

publish_batch async #

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