-
Process
{{ number(activeSincePrevTick) }}
-
Active
{{ number(active) }}
-
Waiting
{{ number(waiting) }}
-
Delayed
{{ number(delayed) }}
+
+
+
+
Process
{{ number(activeSincePrevTick) }}
+
Active
{{ number(active) }}
+
Waiting
{{ number(waiting) }}
+
Delayed
{{ number(delayed) }}
+
+
+
+
+
+
+ {{ job[0] }}
+ ({{ number(job[1]) }} jobs)
-
-
-
-
-
-
- {{ job[0] }}
- ({{ number(job[1]) }} jobs)
-
-
-
{{ $ts.noJobs }}
-
+
{{ $ts.noJobs }}
diff --git a/packages/client/src/pages/admin/queue.vue b/packages/client/src/pages/admin/queue.vue
index c2865525ab..d091fe647c 100644
--- a/packages/client/src/pages/admin/queue.vue
+++ b/packages/client/src/pages/admin/queue.vue
@@ -1,14 +1,9 @@
-
+
-
- In
-
-
- Out
-
- {{ i18n.ts.clearQueue }}
+
+
@@ -19,12 +14,11 @@ import XQueue from './queue.chart.vue';
import XHeader from './_header_.vue';
import MkButton from '@/components/ui/button.vue';
import * as os from '@/os';
-import { stream } from '@/stream';
import * as config from '@/config';
import { i18n } from '@/i18n';
import { definePageMetadata } from '@/scripts/page-metadata';
-const connection = markRaw(stream.useChannel('queueStats'));
+let tab = $ref('deliver');
function clear() {
os.confirm({
@@ -38,19 +32,6 @@ function clear() {
});
}
-onMounted(() => {
- nextTick(() => {
- connection.send('requestLog', {
- id: Math.random().toString().substr(2, 8),
- length: 200,
- });
- });
-});
-
-onBeforeUnmount(() => {
- connection.dispose();
-});
-
const headerActions = $computed(() => [{
asFullButton: true,
icon: 'fas fa-up-right-from-square',
@@ -60,7 +41,13 @@ const headerActions = $computed(() => [{
},
}]);
-const headerTabs = $computed(() => []);
+const headerTabs = $computed(() => [{
+ key: 'deliver',
+ title: 'Deliver',
+}, {
+ key: 'inbox',
+ title: 'Inbox',
+}]);
definePageMetadata({
title: i18n.ts.jobQueue,