File tree Expand file tree Collapse file tree 1 file changed +2
-2
lines changed
rocketmq-client/src/consumer/consumer_impl Expand file tree Collapse file tree 1 file changed +2
-2
lines changed Original file line number Diff line number Diff line change @@ -143,7 +143,7 @@ mod tests {
143
143
144
144
#[ test]
145
145
fn pop_process_queue_updates_last_pop_timestamp ( ) {
146
- let mut queue = PopProcessQueue :: new ( ) ;
146
+ let queue = PopProcessQueue :: new ( ) ;
147
147
let new_timestamp = queue. get_last_pop_timestamp ( ) + 1000 ;
148
148
queue. set_last_pop_timestamp ( new_timestamp) ;
149
149
assert_eq ! ( queue. get_last_pop_timestamp( ) , new_timestamp) ;
@@ -181,7 +181,7 @@ mod tests {
181
181
182
182
#[ test]
183
183
fn pop_process_queue_detects_pull_expired ( ) {
184
- let mut queue = PopProcessQueue :: new ( ) ;
184
+ let queue = PopProcessQueue :: new ( ) ;
185
185
queue. set_last_pop_timestamp ( queue. get_last_pop_timestamp ( ) - * PULL_MAX_IDLE_TIME - 1 ) ;
186
186
assert ! ( queue. is_pull_expired( ) ) ;
187
187
}
You can’t perform that action at this time.
0 commit comments