[ISSUE #1676] Optimize MessageListenerConcurrentlyFn signature (#2423)

* [ISSUE #1676] Optimize MessageListenerConcurrentlyFn signature * [ISSUE #1676] Optimize MessageListenerConcurrentlyFn signature
mxsm · Jan 28, 2025 · 35f6e2a · 35f6e2a
1 parent 840d3a6
commit 35f6e2a
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/rocketmq-client/src/consumer/listener/message_listener_concurrently.rs b/rocketmq-client/src/consumer/listener/message_listener_concurrently.rs
@@ -33,7 +33,7 @@ pub trait MessageListenerConcurrently: Sync + Send {
 pub type ArcBoxMessageListenerConcurrently = Arc<Box<dyn MessageListenerConcurrently>>;
 
 pub type MessageListenerConcurrentlyFn = Arc<
-    dyn Fn(Vec<MessageExt>, ConsumeConcurrentlyContext) -> Result<ConsumeConcurrentlyStatus>
+    dyn Fn(&[&MessageExt], &ConsumeConcurrentlyContext) -> Result<ConsumeConcurrentlyStatus>
         + Send
         + Sync,
 >;
diff --git a/rocketmq-client/src/consumer/listener/message_listener_orderly.rs b/rocketmq-client/src/consumer/listener/message_listener_orderly.rs
@@ -33,5 +33,5 @@ pub trait MessageListenerOrderly: Sync + Send {
 pub type ArcBoxMessageListenerOrderly = Arc<Box<dyn MessageListenerOrderly>>;
 
 pub type MessageListenerOrderlyFn = Arc<
-    dyn Fn(&[MessageExt], &ConsumeOrderlyContext) -> Result<ConsumeOrderlyStatus> + Send + Sync,
+    dyn Fn(&[&MessageExt], &ConsumeOrderlyContext) -> Result<ConsumeOrderlyStatus> + Send + Sync,
 >;