var amqp = require('amqp-connection-manager');
var connection = amqp.connect(['amqp://test:testuser@localhost:5672','amqp://test:testuser@localhost:5674','amqp://test:testuser@localhost:5675','amqp://test:testuser@localhost:5672'], {json: true});
connection.on('connect', function() {
console.log('Connected!');
});
connection.on('disconnect', function(params) {
console.log('Disconnected.', params.err.stack);
});
// Create a channel wrapper
var channelWrapper = connection.createChannel({
json: true,
setup: function(channel) {
// `channel` here is a regular amqplib `ConfirmChannel`.
return channel.assertQueue("nameof queue", {durable: true,maxPriority: 10});
}
});
// Send messages until someone hits CTRL-C or something goes wrong...
var sendMessage = function() {
channelWrapper.publish("exchangename", "keyname","messagewehavetosend",{priority:0})
.catch(function(err) {
console.log("Message was rejected:", err.stack);
channelWrapper.close();
connection.close();
});
};
console.log("Sending messages...");
exports.sendMessage = sendMessage;
Wednesday, November 22, 2017
Monday, August 21, 2017
Node JS REST API read form-data
const express = require('express')
const app = express()
app.get('/', function (req, res) {
res.send('Hello World!')
})
app.listen(3000, function () {
console.log('Example app listening on port 3000!')
})
var multer = require('multer');
var upload = multer();
app.post('/send', upload.fields([]), (req, res) => {
var formData = req.body;
console.log('form data', formData.test);
res.sendStatus(200);
});
const app = express()
app.get('/', function (req, res) {
res.send('Hello World!')
})
app.listen(3000, function () {
console.log('Example app listening on port 3000!')
})
var multer = require('multer');
var upload = multer();
app.post('/send', upload.fields([]), (req, res) => {
var formData = req.body;
console.log('form data', formData.test);
res.sendStatus(200);
});
Tuesday, February 14, 2017
CurrentTimeStamp print in node js or JavaScript
this code is working on both JavaScript and NodeJS.
we did not add any dependency in case node js.
var d = new Date();
console.log(d);
console.log(d.toLocaleString());
console.log(d.toLocaleDateString());
console.log(d.toLocaleTimeString());
Subscribe to:
Comments (Atom)