/[openfoncier]/trunk/services/outgoing/messageenqueuer.php
ViewVC logotype

Diff of /trunk/services/outgoing/messageenqueuer.php

Parent Directory Parent Directory | Revision Log Revision Log | View Patch Patch

revision 830 by mlimic, Mon Nov 26 13:31:16 2012 UTC revision 834 by mlimic, Mon Nov 26 16:45:11 2012 UTC
# Line 1  Line 1 
1  <?php  <?php
2    
3    
4  require_once('../php/php-amqplib/vendor/autoload.php');  require_once('vendor/autoload.php');
5  use PhpAmqpLib\Connection\AMQPConnection;  use PhpAmqpLib\Connection\AMQPConnection;
6  use PhpAmqpLib\Message\AMQPMessage;  use PhpAmqpLib\Message\AMQPMessage;
7    
 include_once('../../core/om_debug.inc.php');  
8  (defined("DEBUG") ? "" : define("DEBUG", EXTRA_VERBOSE_MODE));  (defined("DEBUG") ? "" : define("DEBUG", EXTRA_VERBOSE_MODE));
9    
 include_once('../../core/om_logger.class.php');  
   
10  // pour des besoins de logging il faut setter $_SERVER["REQUEST_URI"]  // pour des besoins de logging il faut setter $_SERVER["REQUEST_URI"]
11  if (!isset($_SERVER["REQUEST_URI"])) {  if (!isset($_SERVER["REQUEST_URI"])) {
12      $_SERVER["REQUEST_URI"] = __FILE__;      $_SERVER["REQUEST_URI"] = __FILE__;
13  }  }
14    
15  // Si le AMQP_DEBUG est defini a true, les messages DEBUG sont envoyes aux  // Si le AMQP_DEBUG est defini a true, les messages DEBUG sont envoyes aux
16  // stdout  // stdout ce qui peut etre bien pour deboguer
17  if (DEBUG > PRODUCTION_MODE) {  if (DEBUG > PRODUCTION_MODE) {
18      define('AMQP_DEBUG', true);      define('AMQP_DEBUG', true);
19  }  }
# Line 42  class MessageEnqueuer { Line 39  class MessageEnqueuer {
39            
40    
41      public function __construct() {      public function __construct() {
42          include_once('../../dyn/services.inc.php');          include_once('../dyn/services.inc.php');
         session_start();  
43          $this->ret_array = array();          $this->ret_array = array();
44          $this->ret_array['date'] = date('d/m/Y H:i');          $this->ret_array['date'] = date('d/m/Y H:i');
45          $this->ret_array['emetteur'] = $_SESSION['login'];          $this->ret_array['emetteur'] = $_SESSION['login'];
# Line 107  class MessageEnqueuer { Line 103  class MessageEnqueuer {
103          // log le message qui etait mis sur la pile dans RabbitMQ          // log le message qui etait mis sur la pile dans RabbitMQ
104          logger::instance()->log("Ajout du message sur pile: ".          logger::instance()->log("Ajout du message sur pile: ".
105                              json_encode($this->ret_array), EXTRA_VERBOSE_MODE);                              json_encode($this->ret_array), EXTRA_VERBOSE_MODE);
         logger::instance()->writeLogToFile();  
106                    
107          return 0;          return 0;
108      }      }
Legend:
Removed from v.830  
changed lines
  Added in v.834
[email protected]
 ViewVC Help
Powered by ViewVC 1.1.26