diff --git a/pay-api/src/pay_api/services/base_payment_system.py b/pay-api/src/pay_api/services/base_payment_system.py index 80f30193a..0e6cd920f 100644 --- a/pay-api/src/pay_api/services/base_payment_system.py +++ b/pay-api/src/pay_api/services/base_payment_system.py @@ -241,7 +241,7 @@ def _publish_refund_to_mailer(invoice: InvoiceModel): gcp_queue_publisher.publish_to_queue( gcp_queue_publisher.QueueMessage( source=QueueSources.PAY_API.value, - message_type=f'bc.registry.{invoice.payment_method_code.lower()}.refundRequest', + message_type=QueueMessageTypes.REFUND_DRAWDOWN_REQUEST.value, payload=payload, topic=current_app.config.get('ACCOUNT_MAILER_TOPIC') )