Skip to content

AioPikaFastProducer

faststream.rabbit.publisher.producer.AioPikaFastProducer #

Bases: ProducerProto[RabbitPublishCommand]

connect #

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

disconnect #

disconnect() -> None
Source code in faststream/rabbit/publisher/producer.py 
62
def disconnect(self) -> None: ...

publish abstractmethod async #

publish(
    cmd: RabbitPublishCommand,
) -> Optional[ConfirmationFrameType]
Source code in faststream/rabbit/publisher/producer.py 
64
65
66
67
68
@abstractmethod
async def publish(
    self,
    cmd: "RabbitPublishCommand",
) -> Optional["aiormq.abc.ConfirmationFrameType"]: ...

request abstractmethod async #

request(cmd: RabbitPublishCommand) -> IncomingMessage
Source code in faststream/rabbit/publisher/producer.py 
70
71
@abstractmethod
async def request(self, cmd: "RabbitPublishCommand") -> "IncomingMessage": ...

publish_batch async #

publish_batch(cmd: RabbitPublishCommand) -> None
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)