10000 use the same topic to send list_changed and resource updated notifica… · emqx/mcp-python-sdk@f098c2a · GitHub
[go: up one dir, main page]
Skip to content

Commit f098c2a

Browse files
terry-xiaoyuterry-xiaoyu
committed
use the same topic to send list_changed and resource updated notifications
1 parent 37e14bd commit f098c2a

File tree

2 files changed

+3
-8
lines changed

2 files changed

+3
-8
lines changed

‎src/mcp/client/mqtt.py

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -370,7 +370,6 @@ def _subscribe_mcp_server_topics(self, server_id: ServerId, server_name: ServerN
370370
after_subscribed: Callable[[Any], Awaitable[None]]):
371371
topic_filters = [
372372
(mqtt_topic.get_server_capability_change_topic(server_id, server_name), SubscribeOptions(qos=QOS)),
373-
(mqtt_topic.get_server_resource_update_topic(server_id, server_name), SubscribeOptions(qos=QOS)),
374373
(mqtt_topic.get_rpc_topic(self.mcp_client_id, server_id, server_name), SubscribeOptions(qos=QOS, noLocal=True))
375374
]
376375
ret, mid = self.client.subscribe(topic=topic_filters)

‎src/mcp/shared/mqtt_topic.py

Lines changed: 3 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -1,22 +1,18 @@
11

22

33
SERVER_CONTROL_BASE: str = '$mcp-server'
4-
SERVER_CAPABILITY_CHANGE_BASE: str = '$mcp-server/capability/list-changed'
5-
SERVER_RESOURCE_UPDATE_BASE: str = '$mcp-server/capability/resource-updated'
4+
SERVER_CAPABILITY_CHANGE_BASE: str = '$mcp-server/capability'
65
SERVER_PRESENCE_BASE: str = '$mcp-server/presence'
76
CLIENT_PRESENCE_BASE: str = '$mcp-client/presence'
8-
CLIENT_CAPABILITY_CHANGE_BASE: str = '$mcp-client/capability/list-changed'
9-
RPC_BASE: str = '$mcp-rpc-endpoint'
7+
CLIENT_CAPABILITY_CHANGE_BASE: str = '$mcp-client/capability'
8+
RPC_BASE: str = '$mcp-rpc'
109

1110
def get_server_control_topic(server_id: str, server_name: str) -> str:
1211
return f"{SERVER_CONTROL_BASE}/{server_id}/{server_name}"
1312

1413
def get_server_capability_change_topic(server_id: str, server_name: str) -> str:
1514
return f"{SERVER_CAPABILITY_CHANGE_BASE}/{server_id}/{server_name}"
1615

17-
def get_server_resource_update_topic(server_id: str, server_name: str) -> str:
18-
return f"{SERVER_RESOURCE_UPDATE_BASE}/{server_id}/{server_name}"
19-
2016
def get_server_presence_topic(server_id: str, server_name: str) -> str:
2117
return f"{SERVER_PRESENCE_BASE}/{server_id}/{server_name}"
2218

0 commit comments

Comments
 (0)
0