Skip to content

Commit da4e6ab

Browse files
committed
using abstract channel not blocking channel
1 parent f95221d commit da4e6ab

File tree

1 file changed

+3
-2
lines changed

1 file changed

+3
-2
lines changed

backend/app/routers/feeds.py

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -4,7 +4,8 @@
44
from beanie.operators import Or, RegEx
55
from fastapi import APIRouter, Depends, HTTPException
66
from pika.adapters.blocking_connection import BlockingChannel
7-
7+
import aio_pika
8+
from aio_pika.abc import AbstractChannel
89
from app.deps.authorization_deps import FeedAuthorization, ListenerAuthorization
910
from app.keycloak_auth import get_current_user, get_current_username
1011
from app.models.feeds import FeedDB, FeedIn, FeedOut
@@ -41,7 +42,7 @@ async def check_feed_listeners(
4142
es_client,
4243
file_out: FileOut,
4344
user: UserOut,
44-
rabbitmq_client: BlockingChannel,
45+
rabbitmq_client: AbstractChannel,
4546
):
4647
"""Automatically submit new file to listeners on feeds that fit the search criteria."""
4748
listener_ids_found = []

0 commit comments

Comments
 (0)