diff --git a/include/tcpdefines.h b/include/tcpdefines.h
new file mode 100644
index 0000000..e30f561
--- /dev/null
+++ b/include/tcpdefines.h
@@ -0,0 +1,27 @@
+#pragma once
+
+/**
+ * No MSG_NOSIGNAL on OS X.
+ * Avoid SIGPIPE by using sockopt call.
+ */
+#ifdef MSG_NOSIGNAL
+# define AMQP_CPP_MSG_NOSIGNAL MSG_NOSIGNAL
+#else
+# define AMQP_CPP_MSG_NOSIGNAL 0
+# ifdef SO_NOSIGPIPE
+#  define AMQP_CPP_USE_SO_NOSIGPIPE
+# else
+#  error "Cannot block SIGPIPE!"
+# endif
+#endif
+
+#ifdef AMQP_CPP_USE_SO_NOSIGPIPE
+/**
+ * Ignore SIGPIPE when there is no MSG_NOSIGNAL.
+ */
+inline void set_sockopt_nosigpipe(int socket)
+{
+    int optval = 1;
+    setsockopt(socket, SOL_SOCKET, SO_NOSIGPIPE, &optval, sizeof(optval));
+}
+#endif
diff --git a/src/includes.h b/src/includes.h
index ecabe00..147c86b 100644
--- a/src/includes.h
+++ b/src/includes.h
@@ -40,6 +40,7 @@
 #include "../include/outbuffer.h"
 #include "../include/watchable.h"
 #include "../include/monitor.h"
+#include "../include/tcpdefines.h"
 
 // amqp types
 #include "../include/field.h"
diff --git a/src/tcpconnected.h b/src/tcpconnected.h
index 7b77aae..ded777a 100644
--- a/src/tcpconnected.h
+++ b/src/tcpconnected.h
@@ -189,7 +189,7 @@ public:
         if (_out) return _out.add(buffer, size);
 
         // there is no buffer, send the data right away
-        auto result = ::send(_socket, buffer, size, MSG_NOSIGNAL);
+        auto result = ::send(_socket, buffer, size, AMQP_CPP_MSG_NOSIGNAL);
 
         // number of bytes sent
         size_t bytes = result < 0 ? 0 : result;
diff --git a/src/tcpoutbuffer.h b/src/tcpoutbuffer.h
index 0e10f63..186a9b4 100644
--- a/src/tcpoutbuffer.h
+++ b/src/tcpoutbuffer.h
@@ -236,7 +236,7 @@ public:
             header.msg_iovlen = index;
 
             // send the data
-            auto result = sendmsg(socket, &header, MSG_NOSIGNAL);
+            auto result = sendmsg(socket, &header, AMQP_CPP_MSG_NOSIGNAL);
 
             // skip on error, or when nothing was written
             if (result <= 0) return total > 0 ? total : result;
diff --git a/src/tcpresolver.h b/src/tcpresolver.h
index c8721e5..fb15781 100644
--- a/src/tcpresolver.h
+++ b/src/tcpresolver.h
@@ -120,6 +120,10 @@ private:
                 
                 // set the option
                 setsockopt(_socket, IPPROTO_TCP, TCP_NODELAY, &optval, sizeof(int));
+
+#ifdef AMQP_CPP_USE_SO_NOSIGPIPE
+                set_sockopt_nosigpipe(_socket);
+#endif
             }
         }
         catch (const std::runtime_error &error)