Upate AMQP receive to marshall message before passing to the broker

cshannon · cshannon · commit 6002d18b0f17 · 2026-03-28T09:44:23.000-04:00
diff --git a/activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/protocol/AmqpReceiver.java b/activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/protocol/AmqpReceiver.java
@@ -205,6 +205,7 @@ protected void processDelivery(final Delivery delivery, Buffer deliveryBytes) th
             }
 
             message.onSend();
+            message.beforeMarshall(null);
 
             sendsInFlight++;
 

Original file line number	Diff line number	Diff line change
`@@ -205,6 +205,7 @@ protected void processDelivery(final Delivery delivery, Buffer deliveryBytes) th`
`205`	`205`	`}`
`206`	`206`
`207`	`207`	`message.onSend();`
	`208`	`+ message.beforeMarshall(null);`
`208`	`209`
`209`	`210`	`sendsInFlight++;`
`210`	`211`