misc smaller changes and change example config to include time based SQL condition to prevent loss of in-flight data.
This commit is contained in:
@@ -5,7 +5,7 @@
|
|||||||
"serverURI": "http://localhost:2222",
|
"serverURI": "http://localhost:2222",
|
||||||
"maxResultsPerMessage":100,
|
"maxResultsPerMessage":100,
|
||||||
"statements":{
|
"statements":{
|
||||||
"poller":"'select top ' + config.maxResultsPerMessage + ' * from rpslog where pkey > \\'' + maxPKey + '\\' order by pkey'"
|
"poller":"'select top ' + config.maxResultsPerMessage + ' * from rpslog with (nolock) where pkey > \\'' + maxPKey + '\\' and businessModified < dateAdd(mi,-30, getdate()) order by pkey'"
|
||||||
},
|
},
|
||||||
"pollIntervalIdle": 10000,
|
"pollIntervalIdle": 10000,
|
||||||
"UP_sqlConfig": {
|
"UP_sqlConfig": {
|
||||||
|
|||||||
@@ -15,8 +15,8 @@ const logger = winston.createLogger({
|
|||||||
),
|
),
|
||||||
transports: [
|
transports: [
|
||||||
new winston.transports.Console(),
|
new winston.transports.Console(),
|
||||||
new winston.transports.File({ filename: './log/DBExtractorError.log', level: 'error' }),
|
new winston.transports.File({ filename: '../log/DBExtractorError.log', level: 'error' }),
|
||||||
new winston.transports.File({ filename: './log/Combined.log' })
|
new winston.transports.File({ filename: '../log/Combined.log' })
|
||||||
]
|
]
|
||||||
});
|
});
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user