diff --git a/rust-arroyo/src/processing/dlq.rs b/rust-arroyo/src/processing/dlq.rs index 9864fbbb..3d5a4373 100644 --- a/rust-arroyo/src/processing/dlq.rs +++ b/rust-arroyo/src/processing/dlq.rs @@ -418,7 +418,7 @@ impl BufferedMessages { gauge!( "Number of elements that can be held in buffer deque without reallocating", - buffered.capacity() + buffered.capacity() as u64 ); } @@ -432,7 +432,7 @@ impl BufferedMessages { let first = messages.pop_front(); gauge!( "Number of elements that can be held in buffer deque without reallocating", - messages.capacity() + messages.capacity() as u64 ); return first; } @@ -443,7 +443,7 @@ impl BufferedMessages { messages.pop_front(); gauge!( "Number of elements that can be held in buffer deque without reallocating", - messages.capacity() + messages.capacity() as u64 ); } };