--- mqtt/src/mqttd.c	2011/12/14 15:09:31	1.1.1.1.2.13
+++ mqtt/src/mqttd.c	2011/12/29 14:13:13	1.1.1.1.2.14
@@ -51,6 +51,8 @@ sigHand(int sig)
 		case SIGCHLD:
 			while (waitpid(-1, &stat, WNOHANG) > 0);
 			break;
+		case SIGPIPE:
+			break;
 	}
 }
 
@@ -157,6 +159,7 @@ main(int argc, char **argv)
 	sigaction(SIGHUP, &sa, NULL);
 	sigaction(SIGTERM, &sa, NULL);
 	sigaction(SIGCHLD, &sa, NULL);
+	sigaction(SIGPIPE, &sa, NULL);
 	ioDEBUG(2, "Service is ready for start engine ...");
 
 	if ((sock = srv_Socket(&cfg)) == -1) {