We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 7bdf66e commit ec71188Copy full SHA for ec71188
1 file changed
apps/integrated-tests/src/setup/rabbitmq/spy-consumer.ts
@@ -31,17 +31,8 @@ export class RabbitMQSpyConsumerManager implements SpyConsumerManager {
31
32
// Create connection if not exists
33
if (!this.connection) {
34
- console.log('[SpyConsumer] Creating rabbitmq-client connection to:', url.replace(/\/\/[^:]+:[^@]+@/, '//***:***@'));
35
this.connection = new Connection(url);
36
-
37
- // Wait for connection to be ready
38
- try {
39
- await this.connection.onConnect(5000);
40
- console.log('[SpyConsumer] Connected successfully');
41
- } catch (error) {
42
- console.error('[SpyConsumer] Failed to connect:', error);
43
- throw error;
44
- }
+ await this.connection.onConnect(5000);
45
}
46
47
// Create a spy consumer that intercepts and requeues messages
0 commit comments