@@ -27,7 +27,6 @@ var excon1: amqp_exchange_consumer = new amqp_exchange_consumer(logger, Config.a
2727var excon2 : amqp_exchange_consumer = new amqp_exchange_consumer ( logger , Config . amqp_url , "hello2" ) ;
2828var expub : amqp_exchange_publisher = new amqp_exchange_publisher ( logger , Config . amqp_url , "hello2" ) ;
2929var rpccon : amqp_rpc_consumer = new amqp_rpc_consumer ( logger , Config . amqp_url , "rpchello" , ( msg : string ) : string => {
30- console . log ( "SUCCESS!!!!!! " + msg ) ;
3130 return "server response! " + msg ;
3231} ) ;
3332var rpcpub : amqp_rpc_publisher = new amqp_rpc_publisher ( logger , Config . amqp_url ) ;
@@ -128,40 +127,6 @@ process.on('unhandledRejection', up => {
128127 if ( ! await initDatabase ( ) ) {
129128 process . exit ( 404 ) ;
130129 }
131-
132- // console.log("************************");
133- // var e:Base = new Base();
134- // e.name = "find me";
135- // item = await db.create(e, "users", userjwt);
136- // console.log(item);
137- // console.log(res);
138- // var arr:any[] = await db.query({}, null, 500, 0, null, "users", userjwt);
139- // console.log(arr);
140- // console.log("************************");
141- // arr = await db.query({}, null, 500, 0, null, "users", jwt);
142- // console.log(arr);
143- // var item:Base = await db.getbyid(arr[0]._id, "users", jwt);
144- // console.log(item);
145- // item.name = "TEST: " + new Date().toISOString();
146- // item = await db.update(item, "users", userjwt);
147- // console.log(item);
148-
149- // console.log("************************");
150- // await con.connect();
151- // await pub.connect();
152- // pub.SendMessage("pub/sub hi mom");
153- // console.log("************************");
154- // await excon1.connect();
155- // await excon2.connect();
156- // await expub.connect();
157- // expub.SendMessage("exchange/hi mom");
158- // console.log("************************");
159- // await rpccon.connect();
160- // await rpcpub.connect();
161- // console.log("************************");
162- // var rpcresult:string = await rpcpub.SendMessage("Client says hi!", "rpchello");
163- // console.log("rpcresult: " + rpcresult);
164- // console.log("************************");
165130 } catch ( error ) {
166131 logger . error ( error . message ) ;
167132 }
0 commit comments