diff --git a/info.go b/info.go
index 8c11db5..5a44d0c 100644
--- a/info.go
+++ b/info.go
@@ -15,8 +15,9 @@
 package psrpc
 
 type RPCInfo struct {
-	Service string
-	Method  string
-	Topic   []string
-	Multi   bool
+	Service  string
+	Method   string
+	Topic    []string
+	Multi    bool
+	Wildcard bool
 }
diff --git a/internal/internal.pb.go b/internal/internal.pb.go
index 257bd9e..789b3a1 100644
--- a/internal/internal.pb.go
+++ b/internal/internal.pb.go
@@ -14,7 +14,7 @@
 
 // Code generated by protoc-gen-go. DO NOT EDIT.
 // versions:
-// 	protoc-gen-go v1.31.0
+// 	protoc-gen-go v1.32.0
 // 	protoc        v4.23.4
 // source: internal.proto
 
diff --git a/pkg/info/channels.go b/pkg/info/channels.go
index 1c858d6..1b11059 100644
--- a/pkg/info/channels.go
+++ b/pkg/info/channels.go
@@ -57,8 +57,8 @@ func GetResponseChannel(service, clientID string) bus.Channel {
 func (i *RequestInfo) GetRPCChannel() bus.Channel {
 	return bus.Channel{
 		Legacy:   formatChannel('|', i.Service, i.Method, i.Topic, "REQ"),
-		Primary:  formatServerChannel(i.Service, i.Topic, i.Method, "REQ"),
-		Wildcard: formatServerWildcard(i.Service, i.Topic),
+		Primary:  formatServerChannel(i.Service, i.Topic, i.Queue, i.Method, "REQ"),
+		Wildcard: formatServerWildcard(i.Service, i.Topic, i.Queue),
 	}
 }
 
@@ -69,16 +69,16 @@ func (i *RequestInfo) GetHandlerKey() string {
 func (i *RequestInfo) GetClaimResponseChannel() bus.Channel {
 	return bus.Channel{
 		Legacy:   formatChannel('|', i.Service, i.Method, i.Topic, "RCLAIM"),
-		Primary:  formatServerChannel(i.Service, i.Topic, i.Method, "RCLAIM"),
-		Wildcard: formatServerWildcard(i.Service, i.Topic),
+		Primary:  formatServerChannel(i.Service, i.Topic, i.Queue, i.Method, "RCLAIM"),
+		Wildcard: formatServerWildcard(i.Service, i.Topic, i.Queue),
 	}
 }
 
 func (i *RequestInfo) GetStreamServerChannel() bus.Channel {
 	return bus.Channel{
 		Legacy:   formatChannel('|', i.Service, i.Method, i.Topic, "STR"),
-		Primary:  formatServerChannel(i.Service, i.Topic, i.Method, "STR"),
-		Wildcard: formatServerWildcard(i.Service, i.Topic),
+		Primary:  formatServerChannel(i.Service, i.Topic, false, i.Method, "STR"),
+		Wildcard: formatServerWildcard(i.Service, i.Topic, false),
 	}
 }
 
@@ -101,26 +101,29 @@ func formatClientChannel(service, clientID, channel string) string {
 	return string(b)
 }
 
-func formatServerChannel(service string, topic []string, method, channel string) string {
+func formatServerChannel(service string, topic []string, queue bool, method, channel string) string {
 	p := scratch.Get().(*[]byte)
 	defer scratch.Put(p)
-	b := appendServerPrefix(*p, service, topic)
+	b := appendServerPrefix(*p, service, topic, queue)
 	b = append(b, method...)
 	b = append(b, '.')
 	b = append(b, channel...)
 	return string(b)
 }
 
-func formatServerWildcard(service string, topic []string) string {
+func formatServerWildcard(service string, topic []string, queue bool) string {
 	p := scratch.Get().(*[]byte)
 	defer scratch.Put(p)
-	b := appendServerPrefix(*p, service, topic)
+	b := appendServerPrefix(*p, service, topic, queue)
 	b = append(b, "*.*"...)
 	return string(b)
 }
 
-func appendServerPrefix(b []byte, service string, topic []string) []byte {
+func appendServerPrefix(b []byte, service string, topic []string, queue bool) []byte {
 	b = append(b, "SRV/"...)
+	if queue {
+		b = append(b, "Q/"...)
+	}
 	b = append(b, service...)
 	if len(topic) > 0 {
 		b = append(b, '/')
diff --git a/pkg/info/channels_test.go b/pkg/info/channels_test.go
index 48af42d..f2941c2 100644
--- a/pkg/info/channels_test.go
+++ b/pkg/info/channels_test.go
@@ -61,5 +61,17 @@ func TestChannelFormatters(t *testing.T) {
 	require.Equal(t, "SRV/foo/a/b/c.bar.STR", i.GetStreamServerChannel().Primary)
 	require.Equal(t, "SRV/foo/a/b/c.*.*", i.GetStreamServerChannel().Wildcard)
 
+	i.Queue = true
+
+	require.Equal(t, "foo|bar|a|b|c|REQ", i.GetRPCChannel().Legacy)
+	require.Equal(t, "SRV/Q/foo/a/b/c.bar.REQ", i.GetRPCChannel().Primary)
+	require.Equal(t, "SRV/Q/foo/a/b/c.*.*", i.GetRPCChannel().Wildcard)
+	require.Equal(t, "foo|bar|a|b|c|RCLAIM", i.GetClaimResponseChannel().Legacy)
+	require.Equal(t, "SRV/Q/foo/a/b/c.bar.RCLAIM", i.GetClaimResponseChannel().Primary)
+	require.Equal(t, "SRV/Q/foo/a/b/c.*.*", i.GetClaimResponseChannel().Wildcard)
+	require.Equal(t, "foo|bar|a|b|c|STR", i.GetStreamServerChannel().Legacy)
+	require.Equal(t, "SRV/foo/a/b/c.bar.STR", i.GetStreamServerChannel().Primary)
+	require.Equal(t, "SRV/foo/a/b/c.*.*", i.GetStreamServerChannel().Wildcard)
+
 	require.Equal(t, "U+0001f680_u+00c9.U+0001f6f0_bar.u+8f6fu+4ef6.END", formatChannel('.', "🚀_É", "🛰_bar", []string{"软件"}, "END"))
 }
diff --git a/protoc-gen-psrpc/options/options.pb.go b/protoc-gen-psrpc/options/options.pb.go
index 70f41c0..336a1eb 100644
--- a/protoc-gen-psrpc/options/options.pb.go
+++ b/protoc-gen-psrpc/options/options.pb.go
@@ -14,7 +14,7 @@
 
 // Code generated by protoc-gen-go. DO NOT EDIT.
 // versions:
-// 	protoc-gen-go v1.31.0
+// 	protoc-gen-go v1.32.0
 // 	protoc        v4.23.4
 // source: options.proto
 
diff --git a/testutils/testutils.pb.go b/testutils/testutils.pb.go
index 7796d5d..fceef99 100644
--- a/testutils/testutils.pb.go
+++ b/testutils/testutils.pb.go
@@ -14,7 +14,7 @@
 
 // Code generated by protoc-gen-go. DO NOT EDIT.
 // versions:
-// 	protoc-gen-go v1.31.0
+// 	protoc-gen-go v1.32.0
 // 	protoc        v4.23.4
 // source: testutils.proto