diff --git a/ui-ngx/src/app/core/http/entity.service.ts b/ui-ngx/src/app/core/http/entity.service.ts index f0ce94c574..6402aebe8a 100644 --- a/ui-ngx/src/app/core/http/entity.service.ts +++ b/ui-ngx/src/app/core/http/entity.service.ts @@ -270,9 +270,7 @@ export class EntityService { observable = this.notificationService.getNotificationTargetsByIds(entityIds, config); break; case EntityType.QUEUE_STATS: - observable = this.getEntitiesByIdsObservable( - (id) => this.queueService.getQueueStatisticsById(id, config), - entityIds); + observable = this.queueService.getQueueStatisticsByIds(entityIds, config); break; } return observable; diff --git a/ui-ngx/src/app/core/http/queue.service.ts b/ui-ngx/src/app/core/http/queue.service.ts index 1fe42efa2e..b106b1afb4 100644 --- a/ui-ngx/src/app/core/http/queue.service.ts +++ b/ui-ngx/src/app/core/http/queue.service.ts @@ -21,6 +21,7 @@ import { Observable } from 'rxjs'; import { QueueInfo, QueueStatisticsInfo, ServiceType } from '@shared/models/queue.models'; import { PageLink } from '@shared/models/page/page-link'; import { PageData } from '@shared/models/page/page-data'; +import { Asset } from '@shared/models/asset.models'; @Injectable({ providedIn: 'root' @@ -62,4 +63,9 @@ export class QueueService { public getQueueStatisticsById(queueStatId: string, config?: RequestConfig): Observable { return this.http.get(`/api/queueStats/${queueStatId}`, defaultHttpOptionsFromConfig(config)); } + + public getQueueStatisticsByIds(queueStatIds: Array, config?: RequestConfig): Observable> { + return this.http.get>(`/api/queueStats?strQueueStatsIds=${queueStatIds.join(',')}`, + defaultHttpOptionsFromConfig(config)); + } }