Awight has uploaded a new change for review.
https://gerrit.wikimedia.org/r/308898
Change subject: Delete from pending db once the transaction is completed
......................................................................
Delete from pending db once the transaction is completed
Bug: T143945
Change-Id: I60580e79da3568812aecc919530436bcd47e0dfe
---
M sites/all/modules/queue2civicrm/fredge/PaymentsInitQueueConsumer.php
1 file changed, 5 insertions(+), 0 deletions(-)
git pull ssh://gerrit.wikimedia.org:29418/wikimedia/fundraising/crm
refs/changes/98/308898/1
diff --git
a/sites/all/modules/queue2civicrm/fredge/PaymentsInitQueueConsumer.php
b/sites/all/modules/queue2civicrm/fredge/PaymentsInitQueueConsumer.php
index 6c0a8f9..03e618a 100644
--- a/sites/all/modules/queue2civicrm/fredge/PaymentsInitQueueConsumer.php
+++ b/sites/all/modules/queue2civicrm/fredge/PaymentsInitQueueConsumer.php
@@ -24,6 +24,11 @@
$id = 0;
$inserting = true;
+ // Delete corresponding pending rows if this message is
finished.
+ if ( in_array( $message['payments_final_status'], array(
'completed', 'failed' ) ) ) {
+ PendingDatabase::get()->deleteMessage( $message );
+ }
+
$dbs = wmf_civicrm_get_dbs();
$dbs->push( 'fredge' );
$query = 'SELECT id FROM payments_initial
--
To view, visit https://gerrit.wikimedia.org/r/308898
To unsubscribe, visit https://gerrit.wikimedia.org/r/settings
Gerrit-MessageType: newchange
Gerrit-Change-Id: I60580e79da3568812aecc919530436bcd47e0dfe
Gerrit-PatchSet: 1
Gerrit-Project: wikimedia/fundraising/crm
Gerrit-Branch: master
Gerrit-Owner: Awight <awi...@wikimedia.org>
_______________________________________________
MediaWiki-commits mailing list
MediaWiki-commits@lists.wikimedia.org
https://lists.wikimedia.org/mailman/listinfo/mediawiki-commits
