import BaseIntervalWorker2 from './BaseIntervalWorker2'; import { ICurrency, ICurrencyWorkerOptions } from './interfaces'; // const MixedClass = BaseMQConsumer(BaseMQProducer(BaseIntervalWorker2)); export class BaseCurrencyWorker extends BaseIntervalWorker2 { protected _currency: ICurrency; public constructor(currency: ICurrency, options: ICurrencyWorkerOptions) { super(); this._currency = currency; this._options = options; } public getCurrency(): ICurrency { return this._currency; } // protected async _connect(options: Options.Connect): Promise { // await Promise.all([this.setupConsumer(options), this.setupProducer(options)]); // } }