import { AsyncBlockingQueue } from '../../lib/Queues' ; import { Message , MessageListener } from '../../lib/message' ; export class MockMessageListener implements MessageListener { messageQueue = new AsyncBlockingQueue < Message > ( ) ; newMessage ( msg ) { this . messageQueue . enqueue ( msg ) ; } }