diff --git a/main.go b/main.go
index 33b5bd5..aeda4c0 100644
--- a/main.go
+++ b/main.go
@@ -165,6 +165,8 @@ func main() {
 			rabbitmq.WithLndInvoiceExchange(c.RabbitMQLndInvoiceExchange),
 			rabbitmq.WithLndHubInvoiceExchange(c.RabbitMQLndhubInvoiceExchange),
 			rabbitmq.WithLndInvoiceConsumerQueueName(c.RabbitMQInvoiceConsumerQueueName),
+            rabbitmq.WithLndPaymentExchange(c.RabbitMQLndPaymentExchange),
+            rabbitmq.WithLndPaymentConsumerQueueName(c.RabbitMQPaymentConsumerQueueName),
 		)
 		if err != nil {
 			logger.Fatal(err)
diff --git a/rabbitmq/rabbitmq.go b/rabbitmq/rabbitmq.go
index 526ab42..f477eac 100644
--- a/rabbitmq/rabbitmq.go
+++ b/rabbitmq/rabbitmq.go
@@ -90,6 +90,18 @@ func WithLndInvoiceConsumerQueueName(name string) ClientOption {
 	}
 }
 
+func WithLndPaymentConsumerQueueName(name string) ClientOption {
+	return func(client *DefaultClient) {
+		client.lndPaymentConsumerQueueName = name
+	}
+}
+
+func WithLndPaymentExchange(exchange string) ClientOption {
+	return func(client *DefaultClient) {
+		client.lndPaymentExchange = exchange
+	}
+}
+
 func WithLogger(logger *lecho.Logger) ClientOption {
 	return func(client *DefaultClient) {
 		client.logger = logger