From 2f32ab8e00414c45c666cd6dcdf939bfa1323173 Mon Sep 17 00:00:00 2001
From: stephen powis <spowis@salesforce.com>
Date: Thu, 3 Sep 2015 11:07:50 -0400
Subject: [PATCH] use new exception for connection errors

---
 src/Kafka/Exception/SocketConnect.php | 33 +++++++++++++++++++++++++++
 src/Kafka/Socket.php                  |  2 +-
 2 files changed, 34 insertions(+), 1 deletion(-)
 create mode 100644 src/Kafka/Exception/SocketConnect.php

diff --git a/src/Kafka/Exception/SocketConnect.php b/src/Kafka/Exception/SocketConnect.php
new file mode 100644
index 00000000..476b2a48
--- /dev/null
+++ b/src/Kafka/Exception/SocketConnect.php
@@ -0,0 +1,33 @@
+<?php
+/* vim: set expandtab tabstop=4 shiftwidth=4 softtabstop=4 foldmethod=marker: */
+// +---------------------------------------------------------------------------
+// | SWAN [ $_SWANBR_SLOGAN_$ ]
+// +---------------------------------------------------------------------------
+// | Copyright $_SWANBR_COPYRIGHT_$
+// +---------------------------------------------------------------------------
+// | Version  $_SWANBR_VERSION_$
+// +---------------------------------------------------------------------------
+// | Licensed ( $_SWANBR_LICENSED_URL_$ )
+// +---------------------------------------------------------------------------
+// | $_SWANBR_WEB_DOMAIN_$
+// +---------------------------------------------------------------------------
+
+namespace Kafka\Exception;
+
+use \Kafka\Exception;
+
+/**
++------------------------------------------------------------------------------
+ * Kafka php client exception
++------------------------------------------------------------------------------
+ *
+ * @package
+ * @version $_SWANBR_VERSION_$
+ * @copyright Copyleft
+ * @author $_SWANBR_AUTHOR_$
++------------------------------------------------------------------------------
+ */
+
+class SocketConnect extends Socket
+{
+}
diff --git a/src/Kafka/Socket.php b/src/Kafka/Socket.php
index 69c19289..be7321f3 100644
--- a/src/Kafka/Socket.php
+++ b/src/Kafka/Socket.php
@@ -211,7 +211,7 @@ public function connect()
             $error = 'Could not connect to '
                     . $this->host . ':' . $this->port
                     . ' ('.$errstr.' ['.$errno.'])';
-            throw new \Kafka\Exception($error);
+            throw new \Kafka\Exception\SocketConnect($error);
         }
 
         stream_set_blocking($this->stream, 0);