Changeset 937 for trunk/Monitoring/Watch/watch

Timestamp:

08/23/13 10:13:15 (11 years ago)

Author:

jripsl

Message:

Create AMQP queue on supervisor side if not exists already.

File:

• trunk/Monitoring/Watch/watch (modified) (4 diffs)

trunk/Monitoring/Watch/watch

@@ -24 +24 @@
 
 # line below is to include "smon" package in the search path
-sys.path.append("/home/jripsl/snapshot/Monitoring")
+sys.path.append("/opt/supervisor/Monitoring")
 
 import smon.repo_io as repo_io
 import smon.types
 
+CSTE_BROKER_HOST='cstest-broker.ipsl.jussieu.fr' # cstest
+#CSTE_BROKER_HOST='localhost' # vesg4
 
 class Mail():
@@ -137 +139 @@
         @classmethod
         def log(cls,message):
-                with open("/home/jripsl/supervisor/log/supervisor.log", "a") as log_file:
+                with open("/opt/supervisor/log/supervisor.log", "a") as log_file:
                         log_file.write("%s %s %s %s %s\n"%(datetime.datetime.now().strftime('%Y%m%d_%H%M%S'), message.code,message.jobid,message.timestamp,message.command))
 
@@ -213 +215 @@
                 """
 
-                connection = pika.BlockingConnection(pika.ConnectionParameters( host='localhost'))
+                connection = pika.BlockingConnection(pika.ConnectionParameters(host=CSTE_BROKER_HOST))
                 self.channel = connection.channel()
 
-                #self.channel.queue_declare(queue='myqueue')
 
                 print ' [*] Waiting for messages. To exit press CTRL+C'
@@ -311 +312 @@
                         #time.sleep(0.5)
 
+                self.channel.queue_declare(queue='myqueue')
 
                 self.channel.basic_consume(callback, queue='myqueue', no_ack=True)