diff --git a/src/FuseSource/Stomp/Stomp.php b/src/FuseSource/Stomp/Stomp.php index 29491e7..99c12bc 100755 --- a/src/FuseSource/Stomp/Stomp.php +++ b/src/FuseSource/Stomp/Stomp.php @@ -542,6 +542,17 @@ public function setReadTimeout($seconds, $milliseconds = 0) $this->_read_timeout_seconds = $seconds; $this->_read_timeout_milliseconds = $milliseconds; } + + /** + * Set timeout to wait for connection to MQ + * + * @param int $seconds Seconds to attempt for a connection + * + */ + public function setConnectTimeout($seconds) + { + $this->_connect_timeout_seconds = $seconds; + } /** * Read response frame from server