richzw

var peopleSchema = new mongoose.Schema({
	name: {
		type: String,
		required: true,
		minlength: 3,
		maxlength: 25
	},
	age: Number
});

richzw

var mongoose = require('mongoose');
var c = mongoose.connect('mongodb://localhost/test');
var db = mongoose.connection;
//console.log(c.connection === mongoose.connection);

//var con = mongoose.createConnection('mongodb://localhost/test');
//console.log(con.connection === mongoose.connection);


db.on('error', console.error.bind(console, 'connection error:'));

richzw

var mongoose = require('mongoose');
var isSeenConnected = false;
var connect = function() {
    var opt = { server: { auto_reconnect: true } };
    mongoose.connect('mongodb://localhost/' + 'test', opt);
};

connect();

mongoose.connection.on('error', function() {

richzw

		while ( gets( line, line_len, BODY_LEN/*sizeof(line)*/ ) != NULL )
		{

			if ( strncmp( line, "Host:", 5 ) == 0 )
			{
				strncpy_s(m_strHost, 100, line + 5, sizeof(m_strHost)-1);
			}
			else if ( strncmp( line, "Connection:", 11 ) == 0 )
			{
				if(strstr(line, "Keep-Alive")) 

richzw

void ConsumerThread::Run()
{
    enum
    {
        Term_Evt = 0,
        MQTimer_Evt,
        RpTimer_Evt,
        Queue_Evt,

        Evt_cnt,

richzw

'use strict';

/**
 * dependencies
 */
var amqp = require('amqplib'),
	when = require('when');

/**
 * Receiver Class, initialized with amqp address

richzw

'use strict';

/**
 * dependencies
 */
var amqp = require('amqplib'),
	when = require('when');


/**

richzw

'use strict';

/**
 * dependencies
 */
var amqp = require('amqplib'),
	when = require('when');


/**

richzw

'use strict';

/**
 * dependencies
 */
var amqp = require('amqplib'),
	when = require('when');


/**

richzw

'use strict';

/**
 * dependencies
 */
var amqp = require('amqplib'),
	when = require('when');


/**