Revision 9c766317 snf-cyclades-app/synnefo/logic/callbacks.py
| b/snf-cyclades-app/synnefo/logic/callbacks.py | ||
|---|---|---|
| 61 | 61 |
""" |
| 62 | 62 |
@wraps(func) |
| 63 | 63 |
def wrapper(client, message, *args, **kwargs): |
| 64 |
log.debug("Checking if action is required for msg %s", message)
|
|
| 65 |
|
|
| 66 | 64 |
try: |
| 67 | 65 |
msg = json.loads(message['body']) |
| 68 | 66 |
|
| ... | ... | |
| 74 | 72 |
db_time = vm.backendtime |
| 75 | 73 |
if event_time <= db_time: |
| 76 | 74 |
format_ = "%d/%m/%y %H:%M:%S:%f" |
| 77 |
log.debug("Ignoring message. event_timestamp: %s db_timestamp: %s",
|
|
| 75 |
log.debug("Ignoring message %s.\nevent_timestamp: %s db_timestamp: %s",
|
|
| 76 |
message, |
|
| 78 | 77 |
event_time.strftime(format_), |
| 79 | 78 |
db_time.strftime(format_)) |
| 80 | 79 |
client.basic_ack(message) |
| ... | ... | |
| 174 | 173 |
def dummy_proc(client, message): |
| 175 | 174 |
try: |
| 176 | 175 |
log.debug("Msg: %s", message['body'])
|
| 177 |
pass |
|
| 178 | 176 |
except Exception as e: |
| 179 | 177 |
log.exception("Could not receive message")
|
Also available in: Unified diff