Skip to content

Commit a51557b

Browse files
authored
🐛 #2758 exclusive queue cannot be reacquired (#2780)
1 parent fec7a1f commit a51557b

File tree

2 files changed

+2
-4
lines changed

2 files changed

+2
-4
lines changed

Makefile

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -228,6 +228,7 @@ printf "$$rows" Redis 'http://$(get_my_ip).nip.io:18081';\
228228
printf "$$rows" 'Docker Registry' $${REGISTRY_URL} $${REGISTRY_USER} $${REGISTRY_PW};\
229229
printf "$$rows" "Dask Dashboard" "http://$(get_my_ip).nip.io:8787";
230230
printf "$$rows" "Traefik Dashboard" "http://$(get_my_ip).nip.io:8080/dashboard/";
231+
printf "$$rows" "Rabbit Dashboard" "http://$(get_my_ip).nip.io:15762" admin adminadmin;
231232
printf "\n%s\n" "⚠️ if a DNS is not used (as displayed above), the interactive services started via dynamic-sidecar";\
232233
echo "⚠️ will not be shown. The frontend accesses them via the uuid.services.YOUR_IP.nip.io:9081";
233234
endef

services/web/server/src/simcore_service_webserver/computation_subscribe.py

Lines changed: 1 addition & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -172,15 +172,12 @@ async def exchange_consumer(
172172
# Declaring queue
173173
queue = await channel.declare_queue(
174174
f"webserver_{exchange_name}_{socket.gethostname()}_{os.getpid()}",
175-
exclusive=True,
176175
arguments={"x-message-ttl": 60000},
177176
)
178177
# Binding the queue to the exchange
179178
await queue.bind(exchange)
180179
# process
181-
async with queue.iterator(
182-
exclusive=True, **consumer_kwargs
183-
) as queue_iter:
180+
async with queue.iterator(**consumer_kwargs) as queue_iter:
184181
async for message in queue_iter:
185182
log.debug(
186183
"Received message from exchange %s", exchange_name

0 commit comments

Comments
 (0)