/[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

trunk/services/messagesender.php revision 811 by mlimic, Fri Nov 23 10:05:24 2012 UTC trunk/services/outgoing/messageenqueuer.php revision 829 by mlimic, Mon Nov 26 10:30:31 2012 UTC
# Line 1  Line 1 
1  <?php  <?php
2    
 /*  
 define('HOST', 'localhost');  
 define('PORT', 5672);  
 define('USER', 'guest');  
 define('PASS', 'guest');  
 define('VHOST', '/');  
 */  
3    
4    require_once('../php/php-amqplib/vendor/autoload.php');
 require_once('./php/php-amqplib/vendor/autoload.php');  
5  use PhpAmqpLib\Connection\AMQPConnection;  use PhpAmqpLib\Connection\AMQPConnection;
6  use PhpAmqpLib\Message\AMQPMessage;  use PhpAmqpLib\Message\AMQPMessage;
7  //Si le AMQP_DEBUG est defini, on peut utiliser sortie du AMQP sur CLI // ???  
8  define('AMQP_DEBUG', true);  include_once('../../core/om_debug.inc.php');
9    (defined("DEBUG") ? "" : define("DEBUG", EXTRA_VERBOSE_MODE));
10    
11    include_once('../../core/om_logger.class.php');
12    
13    // pour des besoins de logging il faut setter $_SERVER["REQUEST_URI"]
14    if (!isset($_SERVER["REQUEST_URI"])) {
15        $_SERVER["REQUEST_URI"] = __FILE__;
16    }
17    
18    // Si le AMQP_DEBUG est defini a true, les messages DEBUG sont envoyes aux
19    // stdout
20    if (DEBUG > PRODUCTION_MODE) {
21        define('AMQP_DEBUG', true);
22    }
23    
24    
25  class MessageSender {  class MessageEnqueuer {
       
26            
27      public static $ERP_DEMANDE_COMPLETUDE_PC = 'erpDemandeCompletudePc';      public static $ERP_DEMANDE_COMPLETUDE_PC = 'erpDemandeCompletudePc';
28      public static $ERP_QUALIFIE = 'erpQualifie';      public static $ERP_QUALIFIE = 'erpQualifie';
# Line 59  class MessageSender { Line 64  class MessageSender {
64      /**      /**
65       * Precondition: $msg_type est egal a valeur d'une des $ERP_*       * Precondition: $msg_type est egal a valeur d'une des $ERP_*
66       */       */
67      public function sendMessage($method) {      public function enqueueMessage($method) {
68          if (method_exists($this, $method)) {          if (method_exists($this, $method)) {
69              return $this->$method();              return $this->$method();
70          }          }
# Line 69  class MessageSender { Line 74  class MessageSender {
74            
75      private function enqueueRequest() {      private function enqueueRequest() {
76          $msg_str = json_encode($this->ret_array);          $msg_str = json_encode($this->ret_array);
         print '$msg_str:'.$msg_str;  
77                    
78          if ($msg_str === false) {          if ($msg_str === false) {
79              return $this->KO;              return $this->KO;
# Line 98  class MessageSender { Line 102  class MessageSender {
102          $ch->close();          $ch->close();
103          $conn->close();          $conn->close();
104                    
105            // log le message qui etait mis sur la pile dans RabbitMQ
106            logger::instance()->log("Ajout du message sur pile: ".
107                                json_encode($this->ret_array), EXTRA_VERBOSE_MODE);
108            logger::instance()->writeLogToFile();
109            
110          return 0;          return 0;
111      }      }
112    
Legend:
Removed from v.811  
changed lines
  Added in v.829
[email protected]
 ViewVC Help
Powered by ViewVC 1.1.26