diff options
author | Evan Prodromou <evan@controlyourself.ca> | 2009-08-27 07:56:19 -0700 |
---|---|---|
committer | Evan Prodromou <evan@controlyourself.ca> | 2009-08-27 07:56:19 -0700 |
commit | f1fda6c0503e32edfc99b297f4bf2cb07e629d9e (patch) | |
tree | 4190903afb80c20b7e98c95e6ea8d57ced0695d9 /lib/xmppqueuehandler.php | |
parent | 209486d3be877d85b3e241797e6042283d0f66d6 (diff) | |
parent | fd53fba114283935a304ed2e05111da256ae798f (diff) |
Merge branch '0.8.x' into 0.9.x
Diffstat (limited to 'lib/xmppqueuehandler.php')
-rw-r--r-- | lib/xmppqueuehandler.php | 18 |
1 files changed, 13 insertions, 5 deletions
diff --git a/lib/xmppqueuehandler.php b/lib/xmppqueuehandler.php index 77d476c30..0ab837eb6 100644 --- a/lib/xmppqueuehandler.php +++ b/lib/xmppqueuehandler.php @@ -38,14 +38,20 @@ class XmppQueueHandler extends QueueHandler function start() { # Low priority; we don't want to receive messages + $this->log(LOG_INFO, "INITIALIZE"); $this->conn = jabber_connect($this->_id.$this->transport()); - if ($this->conn) { - $this->conn->addEventHandler('message', 'forward_message', $this); - $this->conn->addEventHandler('reconnect', 'handle_reconnect', $this); - $this->conn->setReconnectTimeout(600); - jabber_send_presence("Send me a message to post a notice", 'available', null, 'available', -1); + + if (empty($this->conn)) { + $this->log(LOG_ERR, "Couldn't connect to server."); + return false; } + + $this->conn->addEventHandler('message', 'forward_message', $this); + $this->conn->addEventHandler('reconnect', 'handle_reconnect', $this); + $this->conn->setReconnectTimeout(600); + jabber_send_presence("Send me a message to post a notice", 'available', null, 'available', -1); + return !is_null($this->conn); } @@ -56,6 +62,8 @@ class XmppQueueHandler extends QueueHandler function handle_reconnect(&$pl) { + $this->log(LOG_NOTICE, 'reconnected'); + $this->conn->processUntil('session_start'); $this->conn->presence(null, 'available', null, 'available', -1); } |