Skip to content
This repository was archived by the owner on Oct 30, 2023. It is now read-only.

Commit 2937518

Browse files
chiragobchiragob
authored
Merge pull request #11 from FlowzPlatform/QA
Qa
2 parents 3ae656a + 69d9d32 commit 2937518

File tree

4 files changed

+104
-55
lines changed

4 files changed

+104
-55
lines changed

‎finish.sh‎

Lines changed: 22 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -2,49 +2,62 @@ if [ "$TRAVIS_BRANCH" = "master" ]
22
then
33
{
44
echo "call $TRAVIS_BRANCH branch"
5-
ENV_ID=`curl -u ""$RANCHER_USER":"$RANCHER_PASS"" -X GET -H 'Accept: application/json' -H 'Content-Type: application/json' "http://rancher.flowz.com:8080/v2-beta/projects?name=Production" | jq '.data[].id' | tr -d '"'`
5+
ENV_ID=`curl -u ""$RANCHER_ACCESSKEY_MASTER":"$RANCHER_SECRETKEY_MASTER"" -X GET -H 'Accept: application/json' -H 'Content-Type: application/json' "$RANCHER_URL_MASTER/v2-beta/projects?name=Production" | jq '.data[].id' | tr -d '"'`
66
echo $ENV_ID
7+
RANCHER_ACCESSKEY="$RANCHER_ACCESSKEY_MASTER";
8+
RANCHER_SECRETKEY="$RANCHER_SECRETKEY_MASTER";
9+
RANCHER_URL="$RANCHER_URL_MASTER";
710
}
811
elif [ "$TRAVIS_BRANCH" = "develop" ]
912
then
1013
{
1114
echo "call $TRAVIS_BRANCH branch"
12-
ENV_ID=`curl -u ""$RANCHER_USER":"$RANCHER_PASS"" -X GET -H 'Accept: application/json' -H 'Content-Type: application/json' "http://rancher.flowz.com:8080/v2-beta/projects?name=Develop" | jq '.data[].id' | tr -d '"'`
15+
ENV_ID=`curl -u ""$RANCHER_ACCESSKEY_DEVELOP":"$RANCHER_SECRETKEY_DEVELOP"" -X GET -H 'Accept: application/json' -H 'Content-Type: application/json' "$RANCHER_URL_DEVELOP/v2-beta/projects?name=Develop" | jq '.data[].id' | tr -d '"'`
1316
echo $ENV_ID
17+
RANCHER_ACCESSKEY="$RANCHER_ACCESSKEY_DEVELOP";
18+
RANCHER_SECRETKEY="$RANCHER_SECRETKEY_DEVELOP";
19+
RANCHER_URL="$RANCHER_URL_DEVELOP";
1420
}
1521
elif [ "$TRAVIS_BRANCH" = "staging" ]
1622
then
1723
{
1824
echo "call $TRAVIS_BRANCH branch"
19-
ENV_ID=`curl -u ""$RANCHER_USER":"$RANCHER_PASS"" -X GET -H 'Accept: application/json' -H 'Content-Type: application/json' "http://rancher.flowz.com:8080/v2-beta/projects?name=Staging" | jq '.data[].id' | tr -d '"'`
25+
ENV_ID=`curl -u ""$RANCHER_ACCESSKEY_STAGING":"$RANCHER_SECRETKEY_STAGING"" -X GET -H 'Accept: application/json' -H 'Content-Type: application/json' "$RANCHER_URL_STAGING/v2-beta/projects?name=Staging" | jq '.data[].id' | tr -d '"'`
2026
echo $ENV_ID
27+
RANCHER_ACCESSKEY="$RANCHER_ACCESSKEY_STAGING";
28+
RANCHER_SECRETKEY="$RANCHER_SECRETKEY_STAGING";
29+
RANCHER_URL="$RANCHER_URL_STAGING";
30+
2131
}
2232
else
2333
{
2434
echo "call $TRAVIS_BRANCH branch"
25-
ENV_ID=`curl -u ""$RANCHER_USER":"$RANCHER_PASS"" -X GET -H 'Accept: application/json' -H 'Content-Type: application/json' "http://rancher.flowz.com:8080/v2-beta/projects?name=QA" | jq '.data[].id' | tr -d '"'`
35+
ENV_ID=`curl -u ""$RANCHER_ACCESSKEY_QA":"$RANCHER_SECRETKEY_QA"" -X GET -H 'Accept: application/json' -H 'Content-Type: application/json' "$RANCHER_URL_QA/v2-beta/projects?name=QA" | jq '.data[].id' | tr -d '"'`
2636
echo $ENV_ID
37+
RANCHER_ACCESSKEY="$RANCHER_ACCESSKEY_QA";
38+
RANCHER_SECRETKEY="$RANCHER_SECRETKEY_QA";
39+
RANCHER_URL="$RANCHER_URL_QA";
2740
}
2841
fi
2942

30-
SERVICE_ID=`curl -u ""$RANCHER_USER":"$RANCHER_PASS"" -X GET -H 'Accept: application/json' -H 'Content-Type: application/json' "http://rancher.flowz.com:8080/v2-beta/projects/$ENV_ID/services?name=worker-uploader-progress" | jq '.data[].id' | tr -d '"'`
43+
SERVICE_ID=`curl -u ""$RANCHER_ACCESSKEY":"$RANCHER_SECRETKEY"" -X GET -H 'Accept: application/json' -H 'Content-Type: application/json' "$RANCHER_URL/v2-beta/projects/$ENV_ID/services?name=worker-uploader-progress" | jq '.data[].id' | tr -d '"'`
3144
echo $SERVICE_ID
3245

3346
echo "waiting for service to upgrade "
3447
while true; do
3548

36-
case `curl -u ""$RANCHER_USER":"$RANCHER_PASS"" \
49+
case `curl -u ""$RANCHER_ACCESSKEY":"$RANCHER_SECRETKEY"" \
3750
-X GET \
3851
-H 'Accept: application/json' \
3952
-H 'Content-Type: application/json' \
40-
"http://rancher.flowz.com:8080/v2-beta/projects/$ENV_ID/services/$SERVICE_ID/" | jq '.state'` in
53+
"$RANCHER_URL/v2-beta/projects/$ENV_ID/services/$SERVICE_ID/" | jq '.state'` in
4154
"\"upgraded\"" )
4255
echo "completing service upgrade"
43-
curl -u ""$RANCHER_USER":"$RANCHER_PASS"" \
56+
curl -u ""$RANCHER_ACCESSKEY":"$RANCHER_SECRETKEY"" \
4457
-X POST \
4558
-H 'Accept: application/json' \
4659
-H 'Content-Type: application/json' \
47-
"http://rancher.flowz.com:8080/v2-beta/projects/$ENV_ID/services/$SERVICE_ID?action=finishupgrade"
60+
"$RANCHER_URL/v2-beta/projects/$ENV_ID/services/$SERVICE_ID?action=finishupgrade"
4861
break ;;
4962
"\"upgrading\"" )
5063
echo "still upgrading"

‎upgrade.sh‎

Lines changed: 36 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -3,46 +3,74 @@ if [ "$TRAVIS_BRANCH" = "master" ]
33
then
44
{
55
echo "call $TRAVIS_BRANCH branch"
6-
ENV_ID=`curl -u ""$RANCHER_USER":"$RANCHER_PASS"" -X GET -H 'Accept: application/json' -H 'Content-Type: application/json' "http://rancher.flowz.com:8080/v2-beta/projects?name=Production" | jq '.data[].id' | tr -d '"'`
6+
ENV_ID=`curl -u ""$RANCHER_ACCESSKEY_MASTER":"$RANCHER_SECRETKEY_MASTER"" -X GET -H 'Accept: application/json' -H 'Content-Type: application/json' "$RANCHER_URL_MASTER/v2-beta/projects?name=Production" | jq '.data[].id' | tr -d '"'`
77
echo $ENV_ID
88
USERNAME="$DOCKER_USERNAME_FLOWZ";
99
TAG="latest";
10+
MONGO_URL="$MONGO_URL_MASTER";
11+
ESHOST="$ESHOST_MASTER";
12+
ESPORT="$ESPORT_MASTER";
13+
ESAUTH="$ESAUTH_MASTER";
14+
RANCHER_ACCESSKEY="$RANCHER_ACCESSKEY_MASTER";
15+
RANCHER_SECRETKEY="$RANCHER_SECRETKEY_MASTER";
16+
RANCHER_URL="$RANCHER_URL_MASTER";
1017
}
1118
elif [ "$TRAVIS_BRANCH" = "develop" ]
1219
then
1320
{
1421
echo "call $TRAVIS_BRANCH branch"
15-
ENV_ID=`curl -u ""$RANCHER_USER":"$RANCHER_PASS"" -X GET -H 'Accept: application/json' -H 'Content-Type: application/json' "http://rancher.flowz.com:8080/v2-beta/projects?name=Develop" | jq '.data[].id' | tr -d '"'`
22+
ENV_ID=`curl -u ""$RANCHER_ACCESSKEY_DEVELOP":"$RANCHER_SECRETKEY_DEVELOP"" -X GET -H 'Accept: application/json' -H 'Content-Type: application/json' "$RANCHER_URL_DEVELOP/v2-beta/projects?name=Develop" | jq '.data[].id' | tr -d '"'`
1623
echo $ENV_ID
1724
USERNAME="$DOCKER_USERNAME";
1825
TAG="dev";
26+
MONGO_URL="$MONGO_URL_DEVELOP";
27+
ESHOST="$ESHOST_DEVELOP";
28+
ESPORT="$ESPORT_DEVELOP";
29+
ESAUTH="$ESAUTH_DEVELOP";
30+
RANCHER_ACCESSKEY="$RANCHER_ACCESSKEY_DEVELOP";
31+
RANCHER_SECRETKEY="$RANCHER_SECRETKEY_DEVELOP";
32+
RANCHER_URL="$RANCHER_URL_DEVELOP";
1933
}
2034
elif [ "$TRAVIS_BRANCH" = "staging" ]
2135
then
2236
{
2337
echo "call $TRAVIS_BRANCH branch"
24-
ENV_ID=`curl -u ""$RANCHER_USER":"$RANCHER_PASS"" -X GET -H 'Accept: application/json' -H 'Content-Type: application/json' "http://rancher.flowz.com:8080/v2-beta/projects?name=Staging" | jq '.data[].id' | tr -d '"'`
38+
ENV_ID=`curl -u ""$RANCHER_ACCESSKEY_STAGING":"$RANCHER_SECRETKEY_STAGING"" -X GET -H 'Accept: application/json' -H 'Content-Type: application/json' "$RANCHER_URL_STAGING/v2-beta/projects?name=Staging" | jq '.data[].id' | tr -d '"'`
2539
echo $ENV_ID
2640
USERNAME="$DOCKER_USERNAME";
2741
TAG="staging";
42+
MONGO_URL="$MONGO_URL_STAGING";
43+
ESHOST="$ESHOST_STAGING";
44+
ESPORT="$ESPORT_STAGING";
45+
ESAUTH="$ESAUTH_STAGING";
46+
RANCHER_ACCESSKEY="$RANCHER_ACCESSKEY_STAGING";
47+
RANCHER_SECRETKEY="$RANCHER_SECRETKEY_STAGING";
48+
RANCHER_URL="$RANCHER_URL_STAGING";
2849
}
2950
else
3051
{
3152
echo "call $TRAVIS_BRANCH branch"
32-
ENV_ID=`curl -u ""$RANCHER_USER":"$RANCHER_PASS"" -X GET -H 'Accept: application/json' -H 'Content-Type: application/json' "http://rancher.flowz.com:8080/v2-beta/projects?name=QA" | jq '.data[].id' | tr -d '"'`
53+
ENV_ID=`curl -u ""$RANCHER_ACCESSKEY_QA":"$RANCHER_SECRETKEY_QA"" -X GET -H 'Accept: application/json' -H 'Content-Type: application/json' "$RANCHER_URL_QA/v2-beta/projects?name=QA" | jq '.data[].id' | tr -d '"'`
3354
echo $ENV_ID
3455
USERNAME="$DOCKER_USERNAME";
3556
TAG="qa";
57+
MONGO_URL="$MONGO_URL_QA";
58+
ESHOST="$ESHOST_QA";
59+
ESPORT="$ESPORT_QA";
60+
ESAUTH="$ESAUTH_QA";
61+
RANCHER_ACCESSKEY="$RANCHER_ACCESSKEY_QA";
62+
RANCHER_SECRETKEY="$RANCHER_SECRETKEY_QA";
63+
RANCHER_URL="$RANCHER_URL_QA";
3664
}
3765
fi
3866

39-
SERVICE_ID=`curl -u ""$RANCHER_USER":"$RANCHER_PASS"" -X GET -H 'Accept: application/json' -H 'Content-Type: application/json' "http://rancher.flowz.com:8080/v2-beta/projects/$ENV_ID/services?name=worker-uploader-progress" | jq '.data[].id' | tr -d '"'`
67+
SERVICE_ID=`curl -u ""$RANCHER_ACCESSKEY":"$RANCHER_SECRETKEY"" -X GET -H 'Accept: application/json' -H 'Content-Type: application/json' "$RANCHER_URL/v2-beta/projects/$ENV_ID/services?name=worker-uploader-progress" | jq '.data[].id' | tr -d '"'`
4068
echo $SERVICE_ID
4169

42-
curl -u ""$RANCHER_USER":"$RANCHER_PASS"" \
70+
curl -u ""$RANCHER_ACCESSKEY":"$RANCHER_SECRETKEY"" \
4371
-X POST \
4472
-H 'Accept: application/json' \
4573
-H 'Content-Type: application/json' \
4674
-d '{
47-
"inServiceStrategy":{"launchConfig": {"imageUuid":"docker:'$USERNAME'/worker_uploader_import_progress:'$TAG'","kind": "container","labels":{"io.rancher.container.pull_image": "always","io.rancher.scheduler.affinity:host_label": "machine=cluster-flowz"},"environment": {"rdbHost": "'"$rdbHost"'","rdbPort": "'"$rdbPort"'","mongoURL":"'"$mongoURL"'","esHost":"'"$esHost"'","esPort":"'"$esPort"'","esAuth":"'"$esAuth"'"}}},"toServiceStrategy":null}' \
48-
http://rancher.flowz.com:8080/v2-beta/projects/$ENV_ID/services/$SERVICE_ID?action=upgrade
75+
"inServiceStrategy":{"launchConfig": {"imageUuid":"docker:'$USERNAME'/worker_uploader_import_progress:'$TAG'","kind": "container","labels":{"io.rancher.container.pull_image": "always","io.rancher.scheduler.affinity:host_label": "machine=cluster-flowz"},"environment": {"rdbHost": "'"$rdbHost"'","rdbPort": "'"$rdbPort"'","mongoURL":"'"$MONGO_URL"'","esHost":"'"$ESHOST"'","esPort":"'"$ESPORT"'","esAuth":"'"$ESAUTH"'"}}},"toServiceStrategy":null}' \
76+
$RANCHER_URL/v2-beta/projects/$ENV_ID/services/$SERVICE_ID?action=upgrade

‎uploader.js‎

Lines changed: 39 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -2,9 +2,31 @@ let mongoose = require('mongoose')
22
const extend = require('util')._extend;
33
mongoose.set('debug', false);
44
let ObjectId = require('mongoose').Types.ObjectId
5-
65
const config = require('config')
76

7+
let mongoDBConnection = config.get('mongoDBConnection')
8+
9+
let mongoURL = mongoDBConnection.URL
10+
if (process.env.mongoURL !== undefined && process.env.mongoURL !== '') {
11+
mongoURL = process.env.mongoURL
12+
}
13+
14+
// console.log("==========", mongoURL)
15+
// `Job` here has essentially the same API as JobCollection on Meteor.
16+
// In fact, job-collection is built on top of the 'meteor-job' npm package!
17+
mongoose.Promise = global.Promise
18+
// Connect to the beerlocker MongoDB
19+
// mongoose.connect('mongodb://localhost:3001/meteor');
20+
mongoose.connect(mongoURL, {autoReconnect : true, bufferMaxEntries: 0, reconnectInterval: 1000, poolSize: 5, reconnectTries: 30, keepAlive: 800000, connectTimeoutMS: 800000}, function (err, db) {
21+
if (err) {
22+
console.log('error.........', err)
23+
}
24+
})
25+
// mongoose.connect('mongodb://obdev:123456@ds133311.mlab.com:33311/closeoutpromo');
26+
let ObjSchema = mongoose.Schema
27+
28+
29+
830
let elasticsearch = require('elasticsearch')
931
let rpRequest = require('request-promise')
1032
let http = require('http')
@@ -13,7 +35,6 @@ let https = require('https')
1335
const uuidV1 = require('uuid/v1');
1436
let ESuserData = null
1537
let Promise = require('es6-promise').Promise
16-
let ObjSchema = mongoose.Schema;
1738

1839
let rethink = require('rethinkdb')
1940
let rethinkDBConnection = extend({}, config.get('rethinkDBConnection'))
@@ -46,8 +67,9 @@ let activeSummary = []
4667
let ESClient = new elasticsearch.Client({
4768
host: esUrl,
4869
requestTimeout: 100000
49-
// ,log: 'trace'
70+
// ,log: 'trace'
5071
})
72+
let uploadedRecord = 0
5173

5274
let optionsES = {
5375
tls: 'https://',
@@ -71,6 +93,7 @@ let fileTypes =
7193

7294
let rethinkDbConnectionObj = null
7395
let doJob = async function (objWorkJob, next) {
96+
finalSKU = []
7497
rethinkDbConnectionObj = await connectRethinkDB(rethinkDBConnection)
7598
return new Promise(async (resolve, reject) => {
7699
console.log('==============In Do Job==============')
@@ -118,6 +141,10 @@ let doJob = async function (objWorkJob, next) {
118141

119142
function updateImportTrackerStatus (trackerId) {
120143
return new Promise(async (resolve, reject) => {
144+
if (uploadedRecord <=0) {
145+
reject({"message" :"data not uploaded, record count is zero"})
146+
}
147+
121148
rethinkDbConnectionObj = await connectRethinkDB(rethinkDBConnection)
122149
rethink.db(rethinkDBConnection.db).table(rethinkDBConnection.table)
123150
.filter({'id': trackerId})
@@ -196,7 +223,7 @@ async function findVirtualShopData (rconnObj, rdb, rtable, username, userObj) {
196223
return new Promise(async (resolve, reject) => {
197224
console.log('================findVal=========', username)
198225
rethink.db(rdb).table(rtable)
199-
.filter({'esUser': username})
226+
.filter({'esUser': username,'userType': 'supplier'})
200227
.run(rconnObj, function (err, cursor) {
201228
if (err) {
202229
reject(err)
@@ -332,7 +359,7 @@ async function makeNewPreviewUser (objWorkJob) {
332359

333360

334361
function getUserDataFromMongo(userid) {
335-
let ObjMain = new ObjSchema({_id: 'string'}, {strict: false, 'collection': 'users'})
362+
let ObjMain = new ObjSchema({_id: 'string'}, {strict: false,bufferCommands: false, 'collection': 'users'})
336363
let modelOBUsers
337364
let modelName = 'mdlUsers'
338365
if (mongoose.models && mongoose.models[modelName]){
@@ -343,7 +370,7 @@ function getUserDataFromMongo(userid) {
343370
let userDataa = modelOBUsers.find({'_id': userid})
344371
return userDataa
345372
}
346-
373+
let finalSKU = []
347374
async function userDataPrepared (objWorkJob) {
348375
//console.log('ESuserData', ESuserData)
349376
// user data not set throws exception user not exists
@@ -386,7 +413,7 @@ async function userDataPrepared (objWorkJob) {
386413
}
387414
})
388415
}
389-
let finalSKU = []
416+
390417
async function getUpdateRecords (objWorkJob, currentProducts, futureProducts) {
391418
let uploadType = objWorkJob.data.uploadType
392419
let jobData = objWorkJob.data
@@ -506,7 +533,7 @@ let delayPromise = (delay) => {
506533

507534
let perPageDataUpload = 100
508535
let batchPromise = []
509-
let uploadedRecord = 0
536+
510537
// to make batch for data upload
511538
async function makeBatch (objWorkJob, listObjects, currentProductsData, makeProductUpdateJsonObj) {
512539
return new Promise(async (resolve, reject) => {
@@ -1049,7 +1076,7 @@ function getUserNewVersion (ESUser) {
10491076

10501077
function makeDynamicCollectionObj (collectionName) {
10511078
collectionName = collectionName.charAt(0).toUpperCase() + collectionName.slice(1).toLowerCase()
1052-
let ObjMain = new ObjSchema({_id: 'string'}, {strict: false, 'collection': collectionPrefix + collectionName})
1079+
let ObjMain = new ObjSchema({_id: 'string'}, {strict: false, bufferCommands: false, 'collection': collectionPrefix + collectionName})
10531080
let modelName = 'mdl'+collectionName
10541081
if (mongoose.models && mongoose.models[modelName]){
10551082
return mongoose.models[modelName]
@@ -1060,7 +1087,7 @@ function makeDynamicCollectionObj (collectionName) {
10601087

10611088
function makeDynamicCollectionObjWithoutPrefix (collectionName) {
10621089
// collectionName = collectionName.charAt(0).toUpperCase() + collectionName.slice(1).toLowerCase()
1063-
let ObjMain = new ObjSchema({_id: 'string'}, {strict: false, 'collection': collectionName})
1090+
let ObjMain = new ObjSchema({_id: 'string'}, {strict: false, bufferCommands: false, 'collection': collectionName})
10641091
let modelName = 'mdl'+collectionName
10651092
if (mongoose.models && mongoose.models[modelName]){
10661093
return mongoose.models[modelName]
@@ -1082,6 +1109,7 @@ async function deleteESData (versionNo, EsUser) {
10821109
]
10831110
}
10841111
},
1112+
"_source": ["sku","vid"],
10851113
"size":10000
10861114
}
10871115
await ESClient.search({
@@ -1188,7 +1216,7 @@ function convertStringToArray (str, seprater) {
11881216

11891217
// to update user job queue process status to import_completed
11901218
function updateJobQueueStatus (objWorkJob) {
1191-
let objJobMaster = new ObjSchema({_id: String}, {strict: false, 'collection': 'uploaderJobMaster'})
1219+
let objJobMaster = new ObjSchema({_id: String}, {strict: false, bufferCommands: false, 'collection': 'uploaderJobMaster'})
11921220
let mdlobjJobMaster = null
11931221
if (mongoose.models && mongoose.models.objJobMaster) {
11941222
mdlobjJobMaster = mongoose.models.objJobMaster

‎uploaderworker.js‎

Lines changed: 7 additions & 27 deletions
Original file line numberDiff line numberDiff line change
@@ -2,8 +2,6 @@ const rfqQueue = require('rethinkdb-job-queue')
22
const extend = require('util')._extend;
33
const config = require('config')
44
let rethink = require('rethinkdb')
5-
let mongoose = require('mongoose')
6-
mongoose.set('debug', true)
75

86
let connctionOption = extend({}, config.get('rethinkDBConnection'))
97
if (process.env.rdbHost !== undefined && process.env.rdbHost !== '') {
@@ -15,41 +13,23 @@ if (process.env.rdbPort !== undefined && process.env.rdbPort !== '') {
1513

1614
let doJob = require('./uploader.js')
1715

18-
let mongoDBConnection = config.get('mongoDBConnection')
19-
20-
let mongoURL = mongoDBConnection.URL
21-
if (process.env.mongoURL !== undefined && process.env.mongoURL !== '') {
22-
mongoURL = process.env.mongoURL
23-
}
24-
25-
// console.log("==========", mongoURL)
26-
// `Job` here has essentially the same API as JobCollection on Meteor.
27-
// In fact, job-collection is built on top of the 'meteor-job' npm package!
28-
mongoose.Promise = global.Promise
29-
// Connect to the beerlocker MongoDB
30-
// mongoose.connect('mongodb://localhost:3001/meteor');
31-
mongoose.connect(mongoURL, {reconnectInterval: 5000, poolSize: 5, reconnectTries: 30, keepAlive: 800000, connectTimeoutMS: 800000}, function (err, db) {
32-
if (err) {
33-
console.log('error.........', err)
34-
}
35-
})
36-
// mongoose.connect('mongodb://obdev:123456@ds133311.mlab.com:33311/closeoutpromo');
37-
let ObjSchema = mongoose.Schema
38-
39-
module.exports = mongoose
40-
module.exports = ObjSchema
41-
4216
let queueOption = {
4317
name: 'uploaderJobQue'
4418
}
4519

4620
process.on('unhandledRejection', (reason, p) => {
47-
console.log('Unhandled Rejection reason:', reason);
21+
console.log('Unhandled Rejection reason:', reason, p);
4822
// application specific logging, throwing an error, or other logic here
4923
});
5024

5125
const objQ = new rfqQueue(connctionOption, queueOption)
5226

27+
objQ.on('error', (err) => {
28+
console.log('Queue Id: ' + err.queueId)
29+
console.error(err)
30+
})
31+
32+
5333
function getJobQueue () {
5434
objQ.process(async (job, next) => {
5535
try {

0 commit comments

Comments
 (0)