diff --git a/faststream_app.py b/faststream_app.py index dbdfa57..5ba850b 100644 --- a/faststream_app.py +++ b/faststream_app.py @@ -44,7 +44,7 @@ class DiscoverApiResponseModel(BaseModel): name: str -@broker.subscriber("test_topic.request") +@broker.subscriber("test_topic.publish") async def handle_job(event: Any): print(f"{SUBJECT}.broadcast received job_id={event}") @@ -56,7 +56,7 @@ async def handle_job(event: Any): print(response_msg) #print(f"{response_msg=}") #response_msg = {'name': 'TAS_ZAG', 'probe_type': 'tas server', 'command': 'add node'} - print("===", await broker.publish(response_msg, subject=f"test_topic.response")) + print("===", await broker.publish(response_msg, subject=f"test_topic.request")) #print("===", await broker.publish("neco", subject="mtr")) return f"Hello" diff --git a/faststream_publisher.py b/faststream_publisher.py index 379e284..15afc74 100644 --- a/faststream_publisher.py +++ b/faststream_publisher.py @@ -28,7 +28,7 @@ async def main(): await broker.connect() print("CONNECTED") result = TestResult( - to_server="localhost", + to_server="localhost-1", test_parameters_id=5) @@ -39,7 +39,7 @@ async def main(): #message=str("text"), message=result.model_dump(), #subject="jobs", - subject="test_topic", + subject="test_topic.request", ) await broker.stop()