1
1
import argparse
2
2
import logging
3
+ import sys
3
4
4
5
from fastmcp import FastMCP
5
6
@@ -63,6 +64,7 @@ def enqueue(queue: str, message: str) -> str:
63
64
handle_enqueue (rabbitmq , queue , message )
64
65
return "Message successfully enqueued"
65
66
except Exception as e :
67
+ print (e , file = sys .stderr )
66
68
self .logger .error (f"{ e } " )
67
69
return f"Failed to enqueue message: { e } "
68
70
@@ -87,6 +89,7 @@ def fanout(exchange: str, message: str) -> str:
87
89
@self .mcp .tool ()
88
90
def list_queues () -> str :
89
91
"""List all the queues in the broker."""
92
+ print ("triggered list queues" , file = sys .stderr )
90
93
try :
91
94
admin = RabbitMQAdmin (
92
95
self .rabbitmq_host ,
@@ -98,6 +101,7 @@ def list_queues() -> str:
98
101
result = handle_list_queues (admin )
99
102
return str (result )
100
103
except Exception as e :
104
+ print (e , file = sys .stderr )
101
105
self .logger .error (f"{ e } " )
102
106
return f"Failed to list queues: { e } "
103
107
@@ -240,7 +244,7 @@ def main():
240
244
"--use-tls" , type = bool , default = False , help = "Is the connection using TLS/SSL"
241
245
)
242
246
parser .add_argument (
243
- "--api-port" , type = int , default = 15672 , help = "Port for the RabbitMQ management API"
247
+ "--api-port" , type = int , default = 15671 , help = "Port for the RabbitMQ management API"
244
248
)
245
249
parser .add_argument ("--sse" , action = "store_true" , help = "Use SSE transport" )
246
250
parser .add_argument (
0 commit comments