diff --git a/gossipd/broadcast.c b/gossipd/broadcast.c
index d720c0cdf..41e611ff5 100644
--- a/gossipd/broadcast.c
+++ b/gossipd/broadcast.c
@@ -18,7 +18,7 @@ static void destroy_queued_message(struct queued_message *msg,
 
 static struct queued_message *new_queued_message(const tal_t *ctx,
 						 struct broadcast_state *bstate,
-						 const u8 *payload,
+						 const u8 *payload TAKES,
 						 u64 index)
 {
 	struct queued_message *msg = tal(ctx, struct queued_message);
@@ -32,7 +32,7 @@ static struct queued_message *new_queued_message(const tal_t *ctx,
 bool replace_broadcast(const tal_t *ctx,
 		       struct broadcast_state *bstate,
 		       u64 *index,
-		       const u8 *payload)
+		       const u8 *payload TAKES)
 {
 	struct queued_message *msg;
 	bool evicted = false;
diff --git a/gossipd/broadcast.h b/gossipd/broadcast.h
index 5ba87097b..08c61eee4 100644
--- a/gossipd/broadcast.h
+++ b/gossipd/broadcast.h
@@ -14,7 +14,7 @@ struct queued_message {
 	u64 index;
 
 	/* Serialized payload */
-	u8 *payload;
+	const u8 *payload;
 };
 
 struct broadcast_state {
@@ -31,7 +31,7 @@ struct broadcast_state *new_broadcast_state(tal_t *ctx);
 bool replace_broadcast(const tal_t *ctx,
 		       struct broadcast_state *bstate,
 		       u64 *index,
-		       const u8 *payload);
+		       const u8 *payload TAKES);
 
 
 struct queued_message *next_broadcast_message(struct broadcast_state *bstate, u64 last_index);