bugs fixed: when client send circular json data, JSON.stringify lead …

…to unack queue
johnny9144 · Dec 26, 2018 · 01b1745 · 01b1745
1 parent 7469983
commit 01b1745
Showing 1 changed file with 10 additions and 1 deletion.
diff --git a/lib/amqp.js b/lib/amqp.js
@@ -156,8 +156,17 @@ async function onRPC ( connection, qName, callback) {
       return callback(
         data,
         out => {
+          let obj;
+          try {
+            obj = JSON.stringify( out);
+          } catch( e) {
+            obj = {
+              code: 500, 
+              msg: 'error_occur_when_data_stringify'
+            };
+          }
           ch.sendToQueue( msg.properties.replyTo,
-            Buffer.from( JSON.stringify( out)),
+            Buffer.from( obj),
             { correlationId: msg.properties.correlationId });
           ch.ack( msg);
         }