@@ -27,25 +27,15 @@ class RabbitMqContainer(DockerContainer):
27
27
RABBITMQ_DEFAULT_USER = os .environ .get ("RABBITMQ_DEFAULT_USER" , "guest" )
28
28
RABBITMQ_DEFAULT_PASS = os .environ .get ("RABBITMQ_DEFAULT_PASS" , "guest" )
29
29
30
- def __init__ (
31
- self ,
32
- image : str = "rabbitmq:latest" ,
33
- port : Optional [int ] = None ,
34
- username : Optional [str ] = None ,
35
- password : Optional [str ] = None ,
36
- ** kwargs ,
37
- ) -> None :
30
+ def __init__ (self , image : str = "rabbitmq:latest" , port : Optional [int ] = None ,
31
+ username : Optional [str ] = None , password : Optional [str ] = None , ** kwargs ) -> None :
38
32
"""Initialize the RabbitMQ test container.
39
33
40
34
Args:
41
- image (str, optional):
42
- The docker image from docker hub. Defaults to "rabbitmq:latest".
43
- port (int, optional):
44
- The port to reach the AMQP API. Defaults to 5672.
45
- username (str, optional):
46
- Overwrite the default username which is "guest".
47
- password (str, optional):
48
- Overwrite the default username which is "guest".
35
+ image: Docker image from docker hub. Defaults to "rabbitmq:latest".
36
+ port: Port to reach the AMQP API. Defaults to 5672.
37
+ username: RabbitMQ username.
38
+ password: RabbitMQ password.
49
39
"""
50
40
super (RabbitMqContainer , self ).__init__ (image = image , ** kwargs )
51
41
self .RABBITMQ_NODE_PORT = port or int (self .RABBITMQ_NODE_PORT )
@@ -81,7 +71,7 @@ def get_connection_params(self) -> pika.ConnectionParameters:
81
71
credentials = credentials ,
82
72
)
83
73
84
- def start (self ):
74
+ def start (self ) -> "RabbitMqContainer" :
85
75
"""Start the test container."""
86
76
super ().start ()
87
77
self .readiness_probe ()
0 commit comments