|
|
@ -15,7 +15,7 @@ |
|
|
limitations under the License. |
|
|
limitations under the License. |
|
|
|
|
|
|
|
|
--> |
|
|
--> |
|
|
<form [formGroup]="queueFormGroup" fxLayout="column"> |
|
|
<form [formGroup]="queueFormGroup" class="flex flex-col"> |
|
|
<mat-form-field class="mat-block" appearance="fill"> |
|
|
<mat-form-field class="mat-block" appearance="fill"> |
|
|
<mat-label translate>admin.queue-name</mat-label> |
|
|
<mat-label translate>admin.queue-name</mat-label> |
|
|
<input matInput formControlName="name" required> |
|
|
<input matInput formControlName="name" required> |
|
|
@ -37,10 +37,10 @@ |
|
|
</mat-panel-title> |
|
|
</mat-panel-title> |
|
|
</mat-expansion-panel-header> |
|
|
</mat-expansion-panel-header> |
|
|
<ng-template matExpansionPanelContent> |
|
|
<ng-template matExpansionPanelContent> |
|
|
<div fxFlex fxLayout="row" fxLayout.lt-md="column" fxLayoutGap="16px" formGroupName="submitStrategy"> |
|
|
<div class="flex-1 flex flex-row lt-md:flex-col gap-4" formGroupName="submitStrategy"> |
|
|
<div fxFlex> |
|
|
<div class="flex-1"> |
|
|
<label class="group-label" translate>queue.submit-strategy</label> |
|
|
<label class="group-label" translate>queue.submit-strategy</label> |
|
|
<mat-radio-group fxFlex fxLayout="column" formControlName="type" required> |
|
|
<mat-radio-group class="flex-1 flex flex-col" formControlName="type" required> |
|
|
<mat-radio-button *ngFor="let strategy of submitStrategies" [value]="strategy"> |
|
|
<mat-radio-button *ngFor="let strategy of submitStrategies" [value]="strategy"> |
|
|
{{ queueSubmitStrategyTypesMap.get(queueSubmitStrategyTypes[strategy]).label | translate }} |
|
|
{{ queueSubmitStrategyTypesMap.get(queueSubmitStrategyTypes[strategy]).label | translate }} |
|
|
<mat-icon |
|
|
<mat-icon |
|
|
@ -51,7 +51,7 @@ |
|
|
</mat-radio-button> |
|
|
</mat-radio-button> |
|
|
</mat-radio-group> |
|
|
</mat-radio-group> |
|
|
</div> |
|
|
</div> |
|
|
<div fxFlex *ngIf="hideBatchSize"> |
|
|
<div class="flex-1" *ngIf="hideBatchSize"> |
|
|
<label class="group-label" translate>queue.grouping-parameter</label> |
|
|
<label class="group-label" translate>queue.grouping-parameter</label> |
|
|
<mat-form-field class="mat-block"> |
|
|
<mat-form-field class="mat-block"> |
|
|
<mat-label translate>queue.batch-size</mat-label> |
|
|
<mat-label translate>queue.batch-size</mat-label> |
|
|
@ -75,10 +75,10 @@ |
|
|
</mat-panel-title> |
|
|
</mat-panel-title> |
|
|
</mat-expansion-panel-header> |
|
|
</mat-expansion-panel-header> |
|
|
<ng-template matExpansionPanelContent> |
|
|
<ng-template matExpansionPanelContent> |
|
|
<div fxFlex fxLayout="row" fxLayout.lt-md="column" fxLayoutGap="16px" formGroupName="processingStrategy"> |
|
|
<div class="flex-1 flex flex-row lt-md:flex-col gap-4" formGroupName="processingStrategy"> |
|
|
<div fxFlex> |
|
|
<div class="flex-1"> |
|
|
<label class="group-label" translate>queue.processing-strategy</label> |
|
|
<label class="group-label" translate>queue.processing-strategy</label> |
|
|
<mat-radio-group fxFlex fxLayout="column" formControlName="type" required> |
|
|
<mat-radio-group class="flex-1 flex flex-col" formControlName="type" required> |
|
|
<mat-radio-button *ngFor="let strategy of processingStrategies" [value]="strategy"> |
|
|
<mat-radio-button *ngFor="let strategy of processingStrategies" [value]="strategy"> |
|
|
{{ queueProcessingStrategyTypesMap.get(queueProcessingStrategyTypes[strategy]).label | translate }} |
|
|
{{ queueProcessingStrategyTypesMap.get(queueProcessingStrategyTypes[strategy]).label | translate }} |
|
|
<mat-icon |
|
|
<mat-icon |
|
|
@ -89,7 +89,7 @@ |
|
|
</mat-radio-button> |
|
|
</mat-radio-button> |
|
|
</mat-radio-group> |
|
|
</mat-radio-group> |
|
|
</div> |
|
|
</div> |
|
|
<div fxFlex> |
|
|
<div class="flex-1"> |
|
|
<label class="group-label" translate>queue.retries-settings</label> |
|
|
<label class="group-label" translate>queue.retries-settings</label> |
|
|
<mat-form-field class="mat-block" subscriptSizing="dynamic"> |
|
|
<mat-form-field class="mat-block" subscriptSizing="dynamic"> |
|
|
<mat-label translate>queue.retries</mat-label> |
|
|
<mat-label translate>queue.retries</mat-label> |
|
|
@ -156,11 +156,11 @@ |
|
|
</mat-panel-title> |
|
|
</mat-panel-title> |
|
|
</mat-expansion-panel-header> |
|
|
</mat-expansion-panel-header> |
|
|
<ng-template matExpansionPanelContent> |
|
|
<ng-template matExpansionPanelContent> |
|
|
<div fxFlex fxLayout="column" fxLayoutGap="10px"> |
|
|
<div class="flex-1 flex flex-col gap-2.5"> |
|
|
<div fxFlex> |
|
|
<div class="flex-1"> |
|
|
<label class="group-label" translate>queue.batch-processing</label> |
|
|
<label class="group-label" translate>queue.batch-processing</label> |
|
|
<div fxFlex fxLayout="row" fxLayout.xs="column" fxLayoutGap="10px"> |
|
|
<div class="flex-1 flex flex-row xs:flex-col gap-2.5"> |
|
|
<mat-form-field fxFlex class="mat-block"> |
|
|
<mat-form-field class="mat-block flex-1"> |
|
|
<mat-label translate>queue.poll-interval</mat-label> |
|
|
<mat-label translate>queue.poll-interval</mat-label> |
|
|
<input type="number" matInput formControlName="pollInterval" required> |
|
|
<input type="number" matInput formControlName="pollInterval" required> |
|
|
<mat-error *ngIf="queueFormGroup.get('pollInterval').hasError('required')"> |
|
|
<mat-error *ngIf="queueFormGroup.get('pollInterval').hasError('required')"> |
|
|
@ -171,7 +171,7 @@ |
|
|
{{ 'queue.poll-interval-min-value' | translate }} |
|
|
{{ 'queue.poll-interval-min-value' | translate }} |
|
|
</mat-error> |
|
|
</mat-error> |
|
|
</mat-form-field> |
|
|
</mat-form-field> |
|
|
<mat-form-field fxFlex class="mat-block"> |
|
|
<mat-form-field class="mat-block flex-1"> |
|
|
<mat-label translate>queue.partitions</mat-label> |
|
|
<mat-label translate>queue.partitions</mat-label> |
|
|
<input type="number" matInput formControlName="partitions" required> |
|
|
<input type="number" matInput formControlName="partitions" required> |
|
|
<mat-error *ngIf="queueFormGroup.get('partitions').hasError('required')"> |
|
|
<mat-error *ngIf="queueFormGroup.get('partitions').hasError('required')"> |
|
|
@ -184,13 +184,13 @@ |
|
|
</mat-form-field> |
|
|
</mat-form-field> |
|
|
</div> |
|
|
</div> |
|
|
</div> |
|
|
</div> |
|
|
<div fxFlex> |
|
|
<div class="flex-1"> |
|
|
<label class="group-label" translate>queue.immediate-processing</label> |
|
|
<label class="group-label" translate>queue.immediate-processing</label> |
|
|
<div fxFlex fxLayout="row" fxLayout.xs="column" fxLayoutGap="10px"> |
|
|
<div class="flex-1 flex flex-row xs:flex-col gap-2.5"> |
|
|
<mat-checkbox fxFlex fxFlexAlign.gt-xs="center" formControlName="consumerPerPartition"> |
|
|
<mat-checkbox class="flex-1 gt-xs:flex gt-xs:justify-center gt-xs:items-stretch" formControlName="consumerPerPartition"> |
|
|
{{ 'queue.consumer-per-partition' | translate }} |
|
|
{{ 'queue.consumer-per-partition' | translate }} |
|
|
</mat-checkbox> |
|
|
</mat-checkbox> |
|
|
<mat-form-field fxFlex class="mat-block"> |
|
|
<mat-form-field class="mat-block flex-1"> |
|
|
<mat-label translate>queue.processing-timeout</mat-label> |
|
|
<mat-label translate>queue.processing-timeout</mat-label> |
|
|
<input type="number" matInput formControlName="packProcessingTimeout" required> |
|
|
<input type="number" matInput formControlName="packProcessingTimeout" required> |
|
|
<mat-error *ngIf="queueFormGroup.get('packProcessingTimeout').hasError('required')"> |
|
|
<mat-error *ngIf="queueFormGroup.get('packProcessingTimeout').hasError('required')"> |
|
|
@ -208,7 +208,7 @@ |
|
|
</mat-expansion-panel> |
|
|
</mat-expansion-panel> |
|
|
</mat-accordion> |
|
|
</mat-accordion> |
|
|
<div formGroupName="additionalInfo"> |
|
|
<div formGroupName="additionalInfo"> |
|
|
<mat-checkbox fxFlex formControlName="duplicateMsgToAllPartitions" style="padding-bottom: 16px;"> |
|
|
<mat-checkbox class="flex-1" formControlName="duplicateMsgToAllPartitions" style="padding-bottom: 16px;"> |
|
|
{{ 'queue.duplicate-msg-to-all-partitions' | translate }} |
|
|
{{ 'queue.duplicate-msg-to-all-partitions' | translate }} |
|
|
</mat-checkbox> |
|
|
</mat-checkbox> |
|
|
<mat-form-field class="mat-block" subscriptSizing="dynamic"> |
|
|
<mat-form-field class="mat-block" subscriptSizing="dynamic"> |
|
|
|