diff --git a/rocketmq-remoting/src/net/channel.rs b/rocketmq-remoting/src/net/channel.rs index 57b7ea0d8..a89168e54 100644 --- a/rocketmq-remoting/src/net/channel.rs +++ b/rocketmq-remoting/src/net/channel.rs @@ -35,12 +35,14 @@ use crate::base::response_future::ResponseFuture; use crate::connection::Connection; use crate::protocol::remoting_command::RemotingCommand; +pub type ChannelId = CheetahString; + #[derive(Clone)] pub struct Channel { inner: WeakArcMut, local_address: SocketAddr, remote_address: SocketAddr, - channel_id: CheetahString, + channel_id: ChannelId, } impl Channel {