Skip to content

Commit d0c16eb

Browse files
committed
[ISSUE #1639] ⚡️ Add #[inline] for MessageClientExt struct method
1 parent 49cba24 commit d0c16eb

File tree

1 file changed

+18
-0
lines changed

1 file changed

+18
-0
lines changed

rocketmq-common/src/common/message/message_client_ext.rs

+18
Original file line numberDiff line numberDiff line change
@@ -67,75 +67,93 @@ impl Display for MessageClientExt {
6767
}
6868

6969
impl MessageTrait for MessageClientExt {
70+
#[inline]
7071
fn put_property(&mut self, key: CheetahString, value: CheetahString) {
7172
self.message_ext_inner.put_property(key, value);
7273
}
7374

75+
#[inline]
7476
fn clear_property(&mut self, name: &str) {
7577
self.message_ext_inner.clear_property(name);
7678
}
7779

80+
#[inline]
7881
fn get_property(&self, name: &CheetahString) -> Option<CheetahString> {
7982
self.message_ext_inner.get_property(name)
8083
}
8184

85+
#[inline]
8286
fn get_topic(&self) -> &CheetahString {
8387
self.message_ext_inner.get_topic()
8488
}
8589

90+
#[inline]
8691
fn set_topic(&mut self, topic: CheetahString) {
8792
self.message_ext_inner.set_topic(topic);
8893
}
8994

95+
#[inline]
9096
fn get_flag(&self) -> i32 {
9197
self.message_ext_inner.get_flag()
9298
}
9399

100+
#[inline]
94101
fn set_flag(&mut self, flag: i32) {
95102
self.message_ext_inner.set_flag(flag);
96103
}
97104

105+
#[inline]
98106
fn get_body(&self) -> Option<&Bytes> {
99107
self.message_ext_inner.get_body()
100108
}
101109

110+
#[inline]
102111
fn set_body(&mut self, body: Bytes) {
103112
self.message_ext_inner.set_body(body);
104113
}
105114

115+
#[inline]
106116
fn get_properties(&self) -> &HashMap<CheetahString, CheetahString> {
107117
self.message_ext_inner.get_properties()
108118
}
109119

120+
#[inline]
110121
fn set_properties(&mut self, properties: HashMap<CheetahString, CheetahString>) {
111122
self.message_ext_inner.set_properties(properties);
112123
}
113124

125+
#[inline]
114126
fn get_transaction_id(&self) -> Option<&CheetahString> {
115127
self.message_ext_inner.get_transaction_id()
116128
}
117129

130+
#[inline]
118131
fn set_transaction_id(&mut self, transaction_id: CheetahString) {
119132
self.message_ext_inner.set_transaction_id(transaction_id);
120133
}
121134

135+
#[inline]
122136
fn get_compressed_body_mut(&mut self) -> &mut Option<Bytes> {
123137
self.message_ext_inner.get_compressed_body_mut()
124138
}
125139

140+
#[inline]
126141
fn get_compressed_body(&self) -> Option<&Bytes> {
127142
self.message_ext_inner.get_compressed_body()
128143
}
129144

145+
#[inline]
130146
fn set_compressed_body_mut(&mut self, compressed_body: Bytes) {
131147
self.message_ext_inner
132148
.set_compressed_body_mut(compressed_body);
133149
}
134150

151+
#[inline]
135152
fn as_any(&self) -> &dyn Any {
136153
self
137154
}
138155

156+
#[inline]
139157
fn as_any_mut(&mut self) -> &mut dyn Any {
140158
self
141159
}

0 commit comments

Comments
 (0)