11import rhea from 'rhea' ;
22import { Connection , Sender , Receiver , EventContext } from 'rhea' ;
3- import { LoggerService } from 'podverse-helpers/dist/lib/backend/logger' ;
3+ import { ILoggerLike } from 'podverse-helpers/dist/lib/backend/logger' ;
44import crypto from 'crypto' ;
55import { getContainerIpPart } from 'podverse-helpers/dist/lib/backend/os' ;
66import { ParseRSSFeedAndSaveToDatabaseOptions } from 'podverse-parser/dist/lib/rss/parser' ;
@@ -39,7 +39,7 @@ export class ActiveMQArtemisService { // Name preserved
3939 private senders : Map < MQQueueName , Sender > = new Map ( ) ;
4040 private receivers : Map < MQQueueName , Receiver > = new Map ( ) ;
4141 private params : ActiveMQArtemisServiceParams ;
42- private logger : LoggerService ;
42+ private logger : ILoggerLike ;
4343 private connecting = false ;
4444 private isShuttingDown = false ;
4545 private readonly tcpKeepAliveMs : number = 30000 ;
@@ -49,7 +49,7 @@ export class ActiveMQArtemisService { // Name preserved
4949 private heartbeatSender : Sender | null = null ;
5050 private heartbeatInterval : ReturnType < typeof setInterval > | null = null ;
5151
52- constructor ( params : ActiveMQArtemisServiceParams , logger : LoggerService ) {
52+ constructor ( params : ActiveMQArtemisServiceParams , logger : ILoggerLike ) {
5353 this . params = params ;
5454 this . logger = logger ;
5555 }
0 commit comments