|
25 | 25 | # Example data objects
|
26 | 26 | CONN = Conn('localhost', '/', port=5672, username='user', password='password')
|
27 | 27 | RMQ_PARAMS = RabbitMqParams(
|
28 |
| - Exch('ims_data', 'topic'), |
29 |
| - Queue('ims_data', '', True, False, True) |
| 28 | + Exch('test_criteria_exch', 'topic'), |
| 29 | + Queue('test_criteria_queue', '', True, False, True) |
30 | 30 | )
|
31 | 31 |
|
32 | 32 |
|
@@ -106,8 +106,8 @@ def test_connection_params_works(monkeypatch: MonkeyPatch, mock_connection: Mock
|
106 | 106 | )
|
107 | 107 |
|
108 | 108 | _channel.queue_bind.assert_called_once_with(
|
109 |
| - RMQ_PARAMS.exchange.name, |
110 | 109 | RMQ_PARAMS.queue.name,
|
| 110 | + RMQ_PARAMS.exchange.name, |
111 | 111 | RMQ_PARAMS.queue.route_key
|
112 | 112 | )
|
113 | 113 |
|
@@ -178,7 +178,7 @@ def test_direct_reply_does_not_declare_queue(
|
178 | 178 | monkeypatch: MonkeyPatch, mock_connection: Mock
|
179 | 179 | ):
|
180 | 180 | params = RabbitMqParams(
|
181 |
| - Exch('ims_data', 'topic'), |
| 181 | + Exch('test_criteria_exch', 'topic'), |
182 | 182 | Queue('amq.rabbitmq.reply-to', '', True, False, True)
|
183 | 183 | )
|
184 | 184 |
|
|
0 commit comments