@@ -79,9 +79,7 @@ describe('RabbitMqGateway', () => {
7979 } ;
8080 const tracerFactory = ( ) => tracer as any ;
8181
82- const channel = createMockChannel ( ) ;
83- const connection = createMockConnection ( channel ) ;
84- const gateway = new RabbitMqGateway ( {
82+ gateway = new RabbitMqGateway ( {
8583 rabbitMqConnectionFactory : async ( ) => connection as any ,
8684 tracerFactory
8785 } ) ;
@@ -116,12 +114,10 @@ describe('RabbitMqGateway', () => {
116114 } ;
117115 const tracerFactory = ( ) => tracer as any ;
118116
119- const channel = createMockChannel ( ) ;
120117 channel . publish . mockImplementation ( ( ) => {
121118 throw new Error ( 'channel buffer full' ) ;
122119 } ) ;
123- const connection = createMockConnection ( channel ) ;
124- const gateway = new RabbitMqGateway ( {
120+ gateway = new RabbitMqGateway ( {
125121 rabbitMqConnectionFactory : async ( ) => connection as any ,
126122 tracerFactory
127123 } ) ;
@@ -136,9 +132,7 @@ describe('RabbitMqGateway', () => {
136132 } ) ;
137133
138134 it ( 'works without tracerFactory and sets no trace headers' , async ( ) => {
139- const channel = createMockChannel ( ) ;
140- const connection = createMockConnection ( channel ) ;
141- const gateway = new RabbitMqGateway ( {
135+ gateway = new RabbitMqGateway ( {
142136 rabbitMqConnectionFactory : async ( ) => connection as any
143137 } ) ;
144138
@@ -153,9 +147,7 @@ describe('RabbitMqGateway', () => {
153147 describe ( 'consume (via subscribe)' , ( ) => {
154148
155149 it ( 'passes no span in meta when tracerFactory is not provided' , async ( ) => {
156- const channel = createMockChannel ( ) ;
157- const connection = createMockConnection ( channel ) ;
158- const gateway = new RabbitMqGateway ( {
150+ gateway = new RabbitMqGateway ( {
159151 rabbitMqConnectionFactory : async ( ) => connection as any
160152 } ) ;
161153
@@ -192,9 +184,7 @@ describe('RabbitMqGateway', () => {
192184 } ;
193185 const tracerFactory = ( ) => tracer as any ;
194186
195- const channel = createMockChannel ( ) ;
196- const connection = createMockConnection ( channel ) ;
197- const gateway = new RabbitMqGateway ( {
187+ gateway = new RabbitMqGateway ( {
198188 rabbitMqConnectionFactory : async ( ) => connection as any ,
199189 tracerFactory
200190 } ) ;
@@ -248,9 +238,7 @@ describe('RabbitMqGateway', () => {
248238 } ;
249239 const tracerFactory = ( ) => tracer as any ;
250240
251- const channel = createMockChannel ( ) ;
252- const connection = createMockConnection ( channel ) ;
253- const gateway = new RabbitMqGateway ( {
241+ gateway = new RabbitMqGateway ( {
254242 rabbitMqConnectionFactory : async ( ) => connection as any ,
255243 tracerFactory
256244 } ) ;
0 commit comments