/
server-http.js
30 lines (26 loc) · 1002 Bytes
/
server-http.js
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
var sqsConnector = require('volos-sqs');
var vault = require('avault').createVault(__dirname);
var http = require('http');
var Q = require('q');
var sqs;
vault.get('aws', function(profileString) {
if (!profileString) {
console.log('Error: required vault not found.');
} else {
var profile = JSON.parse(profileString);
var svr = http.createServer(function(req, resp) {
sqs.dispatchRequest(req, resp);
});
svr.listen(9100, function() {
sqs = new sqsConnector.SqsConnector({"profile": profile, configuration: undefined, receiveMessageCallback: receiveMessageCallback});
sqs.initializePaths(sqs.configuration.restMap);
console.log(sqs.applicationName + ' server is listening');
});
}
function receiveMessageCallback(body, message) {
var dfd = Q.defer();
console.log('body: ' + body + ', message: ' + message);
dfd.resolve('');
return(dfd.promise);
}
});