From 043311e654999c6eeff6ad3dbdc074acbfd4c50a Mon Sep 17 00:00:00 2001
From: Cloud Wu <cloudwu@gmail.com>
Date: Tue, 1 Apr 2014 20:58:49 +0800
Subject: [PATCH] bugfix: fork a new thread when message dispatch error

---
 lualib/mqueue.lua | 1 +
 1 file changed, 1 insertion(+)

diff --git a/lualib/mqueue.lua b/lualib/mqueue.lua
index da7712af..11931200 100644
--- a/lualib/mqueue.lua
+++ b/lualib/mqueue.lua
@@ -41,6 +41,7 @@ local function message_dispatch(f)
 						error(string.format("[:%x] send a message to [:%x] return something", msg.addr, skynet.self()))
 					end
 				else
+					skynet.fork(message_dispatch,f)
 					error(string.format("[:%x] send a message to [:%x] throw an error : %s", msg.addr, skynet.self(),msg))
 				end
 			else