|
a/mail/app/handlers/react.py |
|
b/mail/app/handlers/react.py |
|
... |
|
... |
| 60 |
except:
|
60 |
except:
|
| 61 |
logging.debug('REACT: invalid mount point (' + appmount + ')')
|
61 |
logging.debug('REACT: invalid mount point (' + appmount + ')')
|
| 62 |
else:
|
62 |
else:
|
| 63 |
logging.debug('REACT: valid mount point (' + appmount + ') with plugin_name:' + plugin_name)
|
63 |
logging.debug('REACT: valid mount point (' + appmount + ') with plugin_name:' + plugin_name)
|
| 64 |
routing_key = plugin_name + '.' + apploc
|
64 |
routing_key = plugin_name + '.' + apploc
|
|
|
65 |
mailto = message.__getitem__('To')
|
|
|
66 |
mailfrom = message.__getitem__('From')
|
|
|
67 |
mailsubj = message.__getitem__('Subject')
|
|
|
68 |
mailbody = message.body()
|
|
|
69 |
logging.debug('REACT: *** TO *** = ' + mailto)
|
|
|
70 |
logging.debug('REACT: *** FROM *** = ' + mailfrom)
|
|
|
71 |
logging.debug('REACT: *** SUBJECT *** = ' + mailsubj)
|
|
|
72 |
logging.debug('REACT: *** CONTENT *** = ' + message.body())
|
| 65 |
try:
|
73 |
try:
|
| 66 |
pylons.g.publish('audit', routing_key,
|
74 |
pylons.g.publish('audit', routing_key,
|
|
|
75 |
dict(to=mailto,fro=mailfrom,subject=mailsubj,body=mailbody),
|
| 67 |
dict(content=str(message)),
|
76 |
# dict(content=str(message)),
|
| 68 |
serializer='yaml')
|
77 |
serializer='yaml')
|
| 69 |
except:
|
78 |
except:
|
| 70 |
logging.debug('REACT: unable to queue message in carrot')
|
79 |
logging.debug('REACT: unable to queue message in carrot')
|
| 71 |
else:
|
80 |
else:
|
| 72 |
logging.debug('REACT: successfully queued message in carrot with key:' + routing_key)
|
81 |
logging.debug('REACT: successfully queued message in carrot with key:' + routing_key)
|