Skip to content

Commit 0ea9f5f

Browse files
repeats name variable initialisation if failed. issue 64
resolve apel#64
1 parent 919a0f2 commit 0ea9f5f

File tree

1 file changed

+6
-4
lines changed

1 file changed

+6
-4
lines changed

ssm/ssm2.py

+6-4
Original file line numberDiff line numberDiff line change
@@ -352,15 +352,17 @@ def _save_msg_to_queue(self, body, empaid):
352352
log.error('Failed to read or write file: %s', error)
353353
for i in range(3):
354354
try:
355-
name = self._rejectq.add({'body': body,
355+
if extracted_msg is None or err_msg is not None:
356+
name = self._rejectq.add({'body': body,
356357
'signer': signer,
357358
'empaid': empaid,
358359
'error': err_msg})
359-
log.info("Message saved to reject queue as %s", name)
360-
name = self._inq.add({'body': extracted_msg,
360+
log.info("Message saved to reject queue as %s", name)
361+
else: # message verified ok
362+
name = self._inq.add({'body': extracted_msg,
361363
'signer': signer,
362364
'empaid': empaid})
363-
log.info("Message saved to incoming queue as %s", name)
365+
log.info("Message saved to incoming queue as %s", name)
364366
except:
365367
continue
366368
break

0 commit comments

Comments
 (0)