Parallelize RPC server message processing

2015-10-01 17:35:10 -07:00 · 2015-10-01 17:35:10 -07:00 · c22a21febb
parent 60997377e6
commit c22a21febb
1 changed files with 1 additions and 1 deletions
--- a/rpc/amqp-rpc.go
+++ b/rpc/amqp-rpc.go
@ -407,7 +407,7 @@ func (rpc *AmqpRPCServer) Start(c cmd.Config) error {
 			select {
 			case msg, ok := <-msgs:
 				if ok {
-					rpc.processMessage(msg)
+					go rpc.processMessage(msg)
 				} else {
 					// chan has been closed by rpc.channel.Cancel
 					rpc.log.Info(" [!] Finished processing messages")