From e8f27025ba7869057d86fe37a5264e1c742969f5 Mon Sep 17 00:00:00 2001 From: Evan Prodromou Date: Thu, 2 Jul 2009 12:43:09 -0400 Subject: [PATCH] more logging in stompqueuemanager --- lib/stompqueuemanager.php | 11 ++++++++++- 1 file changed, 10 insertions(+), 1 deletion(-) diff --git a/lib/stompqueuemanager.php b/lib/stompqueuemanager.php index badcd4abb0..08a5790d41 100644 --- a/lib/stompqueuemanager.php +++ b/lib/stompqueuemanager.php @@ -49,10 +49,14 @@ class StompQueueManager function _connect() { + $this->_log(LOG_DEBUG, "Connecting to $this->server..."); if (empty($this->con)) { + $this->_log(LOG_INFO, "Connecting to '$this->server' as '$this->username'..."); $this->con = new Stomp($this->server); - if (!$this->con->connect($this->username, $this->password)) { + if ($this->con->connect($this->username, $this->password)) { + $this->_log(LOG_INFO, "Connected."); + } else { $this->_log(LOG_ERR, 'Failed to connect to queue server'); throw new ServerException('Failed to connect to queue server'); } @@ -160,4 +164,9 @@ class StompQueueManager $k = $this->_frameKey($notice, $queue); unset($this->_frames[$k]); } + + function _log($level, $msg) + { + common_log($level, 'StompQueueManager: '.$msg); + } } -- 2.39.5