better debug logging in stomp queue manager
This commit is contained in:
parent
49eaa04b50
commit
66a4a60e0b
|
@ -75,12 +75,12 @@ class StompQueueManager
|
||||||
array ('created' => $notice->created));
|
array ('created' => $notice->created));
|
||||||
|
|
||||||
if (!$result) {
|
if (!$result) {
|
||||||
common_log(LOG_ERR, 'Error sending to '.$transport.' queue');
|
common_log(LOG_ERR, 'Error sending to '.$queue.' queue');
|
||||||
return false;
|
return false;
|
||||||
}
|
}
|
||||||
|
|
||||||
common_log(LOG_DEBUG, 'complete remote queueing notice ID = '
|
common_log(LOG_DEBUG, 'complete remote queueing notice ID = '
|
||||||
. $notice->id . ' for ' . $transport);
|
. $notice->id . ' for ' . $queue);
|
||||||
}
|
}
|
||||||
|
|
||||||
function service($queue, $handler)
|
function service($queue, $handler)
|
||||||
|
@ -101,7 +101,7 @@ class StompQueueManager
|
||||||
$notice = Notice::staticGet($frame->body);
|
$notice = Notice::staticGet($frame->body);
|
||||||
|
|
||||||
if ($handler->handle_notice($notice)) {
|
if ($handler->handle_notice($notice)) {
|
||||||
$this->_log(LOG_INFO, 'Successfully handled notice '. $notice->id);
|
$this->_log(LOG_INFO, 'Successfully handled notice '. $notice->id .' posted at ' . $frame->headers['created']);
|
||||||
$this->con->ack($frame);
|
$this->con->ack($frame);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue
Block a user