diff --git a/faststream_app_jetstream.py b/faststream_app_jetstream.py index 5db5c1e..f6b8119 100644 --- a/faststream_app_jetstream.py +++ b/faststream_app_jetstream.py @@ -8,7 +8,7 @@ from cProfile import run from faststream import FastStream from faststream.specification.asyncapi.v3_0_0.schema import servers from pydantic import BaseModel, Field -from faststream.nats import NatsBroker, JStream +from faststream.nats import NatsBroker, JStream, PullSub from urllib3.util import url NATS_SERVERS = os.getenv('NATS_URL', 'nats://localhost:4222').split(',') @@ -19,17 +19,23 @@ app = FastStream(broker) stream = JStream(name="orders", subjects=["orders.*"]) -@broker.subscriber("orders.created", stream=stream, durable="orders-worker") +@broker.subscriber("orders.created", + stream=stream, + #pull_sub=PullSub(), + queue="orders-queue", + #durable="orders-worker" + ) #event-processor async def handle_order(message: dict): print("received:", message) return {"status": "ok"} -@broker.publisher("orders.created", stream="orders") -async def publish_order(): - return {"order_id": 123, "item": "book"} +# @broker.publisher("orders.created", stream="orders") +# async def publish_order(): +# return {"order_id": 123, "item": "book"} async def main(): + #await publish_order() await app.run() if __name__ == "__main__":