diff --git a/broker/src/StreamLoopController.ts b/broker/src/StreamLoopController.ts index 9c109af..e75d3de 100644 --- a/broker/src/StreamLoopController.ts +++ b/broker/src/StreamLoopController.ts @@ -20,7 +20,8 @@ export async function startStreamLoop() { await RedisStreamService.startReadingLoop({ streamName: requireEnv('STREAM_NAME'), delay: { base: 10, empty: 5000 }, - readBlock: 2000 + readBlock: 2000, + consumer: 'consumer_' + process.env.NODE_APP_INSTANCE }, processStreamEvent); } diff --git a/dashboard/app.vue b/dashboard/app.vue index 82c3b99..544f4d3 100644 --- a/dashboard/app.vue +++ b/dashboard/app.vue @@ -12,12 +12,6 @@ const { showDialog, closeDialog, dialogComponent, dialogParams, dialogStyle, dia const { visible } = usePricingDrawer(); -const { data: planData } = useFetch('/api/project/plan', { - ...signHeaders(), - lazy: true -}); - -