userver: testsuite.databases.rabbitmq.classes.Channel Class Reference
Loading...
Searching...
No Matches
testsuite.databases.rabbitmq.classes.Channel Class Reference

Detailed Description

Definition at line 23 of file classes.py.

Public Member Functions

 __init__ (self, aio_pika.Channel channel)
'Channel' __aenter__ (self)
None __aexit__ (self, exc_type, exc_val, exc_tb)
None declare_exchange (self, str exchange, aio_pika.ExchangeType exchange_type, float timeout=1.0)
None declare_queue (self, str queue, float timeout=1.0)
 bind_queue (self, str exchange, str queue, str routing_key, float timeout=1.0)
 publish (self, str exchange, str routing_key, bytes body, float timeout=1.0)
 consume (self, str queue, int count, float timeout=2.0)

Protected Attributes

 _channel = channel

Constructor & Destructor Documentation

◆ __init__()

testsuite.databases.rabbitmq.classes.Channel.__init__ ( self,
aio_pika.Channel channel )

Definition at line 24 of file classes.py.

Member Function Documentation

◆ __aenter__()

'Channel' testsuite.databases.rabbitmq.classes.Channel.__aenter__ ( self)

Definition at line 27 of file classes.py.

◆ __aexit__()

None testsuite.databases.rabbitmq.classes.Channel.__aexit__ ( self,
exc_type,
exc_val,
exc_tb )

Definition at line 32 of file classes.py.

◆ bind_queue()

testsuite.databases.rabbitmq.classes.Channel.bind_queue ( self,
str exchange,
str queue,
str routing_key,
float timeout = 1.0 )

Definition at line 54 of file classes.py.

◆ consume()

testsuite.databases.rabbitmq.classes.Channel.consume ( self,
str queue,
int count,
float timeout = 2.0 )

Definition at line 83 of file classes.py.

◆ declare_exchange()

None testsuite.databases.rabbitmq.classes.Channel.declare_exchange ( self,
str exchange,
aio_pika.ExchangeType exchange_type,
float timeout = 1.0 )

Definition at line 35 of file classes.py.

◆ declare_queue()

None testsuite.databases.rabbitmq.classes.Channel.declare_queue ( self,
str queue,
float timeout = 1.0 )

Definition at line 47 of file classes.py.

◆ publish()

testsuite.databases.rabbitmq.classes.Channel.publish ( self,
str exchange,
str routing_key,
bytes body,
float timeout = 1.0 )

Definition at line 67 of file classes.py.

Member Data Documentation

◆ _channel

testsuite.databases.rabbitmq.classes.Channel._channel = channel
protected

Definition at line 25 of file classes.py.

The documentation for this class was generated from the following file: