Queue To Elastic

let tElasticSearch = {
 URL: ELASTIC_SEARCH_URL,
 indexName: ELASTIC_INDEX_NAME,
 indexType: ELASTIC_INDEX_TYPE
}
let tRedisConfig = {
 redis: {
 port: REDIS_PORT,
 host: REDIS_HOST,
 db: REDIS_DB
 }
}
this.mQueueToElastic = new queuetoelastic("PUSH_TO_ELASTIC_SEARCH",tRedisConfig,tElasticSearch);
import queuetoelastic from 'queuetoelastic';
mSimpleQueue.pause();
mSimpleQueue.addDataTOQueue(`xyz`,{Hello: 1234});
mSimpleQueue.addDataTOQueue(`xyz2`,{Hello: 1234});
mSimpleQueue.addDataTOQueue(`xyz3`,{Hello: 1234});
mSimpleQueue.addDataTOQueue(`xyz4`,{Hello: 1234});
setTimeout(() => {
 mSimpleQueue.resume();
}, 5 * 1000);