diff --git a/ui/src/app/configuration/consul-service/consul-service.component.ts b/ui/src/app/configuration/consul-service/consul-service.component.ts
deleted file mode 100644
index ef595de7b6..0000000000
--- a/ui/src/app/configuration/consul-service/consul-service.component.ts
+++ /dev/null
@@ -1,42 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- *
- */
-
-import { Component, EventEmitter, Input, Output } from '@angular/core';
-import { StreampipesPeContainer } from '../shared/streampipes-pe-container.model';
-
-@Component({
- selector: 'sp-consul-service',
- templateUrl: './consul-service.component.html',
- styleUrls: ['./consul-service.component.css'],
-})
-export class ConsulServiceComponent {
- @Input() consulService: StreampipesPeContainer;
- @Output() updateConsulService: EventEmitter =
- new EventEmitter();
- showConfiguration = false;
-
- constructor() {}
-
- toggleConfiguration(): void {
- this.showConfiguration = !this.showConfiguration;
- }
-
- updateConfiguration(): void {
- this.updateConsulService.emit(this.consulService);
- }
-}
diff --git a/ui/src/app/configuration/datalake-configuration/datalake-configuration.component.ts b/ui/src/app/configuration/datalake-configuration/datalake-configuration.component.ts
index 783f8b0937..5a0b63bfaa 100644
--- a/ui/src/app/configuration/datalake-configuration/datalake-configuration.component.ts
+++ b/ui/src/app/configuration/datalake-configuration/datalake-configuration.component.ts
@@ -20,12 +20,10 @@ import { Component, OnInit, ViewChild } from '@angular/core';
import { MatTableDataSource } from '@angular/material/table';
import { DataLakeConfigurationEntry } from './datalake-configuration-entry';
import {
- DataExplorerDataConfig,
DatalakeQueryParameterBuilder,
DatalakeQueryParameters,
DatalakeRestService,
DataViewDataExplorerService,
- DateRange,
EventSchema,
FieldConfig,
SpQueryResult,
diff --git a/ui/src/app/configuration/email-configuration/email-configuration.component.ts b/ui/src/app/configuration/email-configuration/email-configuration.component.ts
index 7bd12f433d..1013d0d653 100644
--- a/ui/src/app/configuration/email-configuration/email-configuration.component.ts
+++ b/ui/src/app/configuration/email-configuration/email-configuration.component.ts
@@ -56,7 +56,7 @@ export class EmailConfigurationComponent implements OnInit {
ngOnInit(): void {
this.breadcrumbService.updateBreadcrumb([
SpConfigurationRoutes.BASE,
- { label: SpConfigurationTabs.getTabs()[2].itemTitle },
+ { label: SpConfigurationTabs.getTabs()[5].itemTitle },
]);
this.loadMailConfig(true);
}
diff --git a/ui/src/app/configuration/export/data-export.service.ts b/ui/src/app/configuration/export/data-export.service.ts
index 5fe23cf692..61082b7612 100644
--- a/ui/src/app/configuration/export/data-export.service.ts
+++ b/ui/src/app/configuration/export/data-export.service.ts
@@ -19,8 +19,8 @@
import { Injectable } from '@angular/core';
import {
AssetExportConfiguration,
- PlatformServicesCommons,
ExportConfiguration,
+ PlatformServicesCommons,
} from '@streampipes/platform-services';
import {
HttpClient,
diff --git a/ui/src/app/configuration/extensions-service-management/extensions-service-configuration/extensions-service-configuration.component.html b/ui/src/app/configuration/extensions-service-management/extensions-service-configuration/extensions-service-configuration.component.html
new file mode 100644
index 0000000000..18dd75698d
--- /dev/null
+++ b/ui/src/app/configuration/extensions-service-management/extensions-service-configuration/extensions-service-configuration.component.html
@@ -0,0 +1,127 @@
+
+
+
+
+
+
+ Service Name
+
+
+ {{ element.serviceGroup }}
+
+
+
+
+
+ Service Name
+
+
+ {{ element.serviceName }}
+
+
+
+
+
+ Action
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
diff --git a/streampipes-service-discovery-api/src/main/java/org/apache/streampipes/svcdiscovery/api/ISpKvManagement.java b/ui/src/app/configuration/extensions-service-management/extensions-service-configuration/extensions-service-configuration.component.scss
similarity index 74%
rename from streampipes-service-discovery-api/src/main/java/org/apache/streampipes/svcdiscovery/api/ISpKvManagement.java
rename to ui/src/app/configuration/extensions-service-management/extensions-service-configuration/extensions-service-configuration.component.scss
index 4b859f3c67..5fc34db9de 100644
--- a/streampipes-service-discovery-api/src/main/java/org/apache/streampipes/svcdiscovery/api/ISpKvManagement.java
+++ b/ui/src/app/configuration/extensions-service-management/extensions-service-configuration/extensions-service-configuration.component.scss
@@ -1,4 +1,4 @@
-/*
+/*!
* Licensed to the Apache Software Foundation (ASF) under one or more
* contributor license agreements. See the NOTICE file distributed with
* this work for additional information regarding copyright ownership.
@@ -15,16 +15,27 @@
* limitations under the License.
*
*/
-package org.apache.streampipes.svcdiscovery.api;
-import java.util.Map;
+table {
+ width: 100%;
+}
-public interface ISpKvManagement {
+tr.consul-configuration-detail-row {
+ height: 0;
+}
- Map getKeyValue(String route);
+.consul-configuration-row td {
+ border-bottom-width: 0;
+}
- void updateConfig(String key, String entry, boolean password);
+.consul-configuration-detail {
+ overflow: hidden;
+ display: flex;
+}
- void deleteConfig(String key);
+.mat-table {
+}
+.consul-service {
+ padding: 5px;
}
diff --git a/ui/src/app/configuration/extensions-service-management/extensions-service-configuration/extensions-service-configuration.component.ts b/ui/src/app/configuration/extensions-service-management/extensions-service-configuration/extensions-service-configuration.component.ts
new file mode 100644
index 0000000000..38bdad6055
--- /dev/null
+++ b/ui/src/app/configuration/extensions-service-management/extensions-service-configuration/extensions-service-configuration.component.ts
@@ -0,0 +1,115 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *
+ */
+
+import { Component, ViewChild } from '@angular/core';
+import { MatPaginator } from '@angular/material/paginator';
+import { MatTableDataSource } from '@angular/material/table';
+import { ConfigurationService } from '../../shared/configuration.service';
+import {
+ animate,
+ state,
+ style,
+ transition,
+ trigger,
+} from '@angular/animations';
+import { SpServiceConfiguration } from '@streampipes/platform-services';
+
+@Component({
+ selector: 'sp-extensions-service-configuration',
+ templateUrl: './extensions-service-configuration.component.html',
+ styleUrls: ['./extensions-service-configuration.component.scss'],
+ animations: [
+ trigger('detailExpand', [
+ state(
+ 'collapsed',
+ style({ height: '0px', minHeight: '0', display: 'none' }),
+ ),
+ state('expanded', style({ height: '*' })),
+ transition(
+ 'expanded <=> collapsed',
+ animate('225ms cubic-bezier(0.4, 0.0, 0.2, 1)'),
+ ),
+ ]),
+ ],
+})
+export class SpExtensionsServiceConfigurationComponent {
+ displayedColumns: string[] = ['group', 'name', 'action'];
+ @ViewChild(MatPaginator, { static: false }) paginator: MatPaginator;
+ dataSource = new MatTableDataSource();
+
+ expandedElement: any;
+ consulServices: SpServiceConfiguration[];
+
+ constructor(private configurationService: ConfigurationService) {
+ this.getConsulServices();
+ }
+
+ getConsulServices(): void {
+ this.configurationService.getExtensionsServiceConfigs().subscribe(
+ response => {
+ const sortedServices = this.sort(response);
+ this.consulServices = sortedServices;
+ this.dataSource.data = sortedServices;
+ console.log(this.consulServices);
+ },
+ error => {
+ console.error(error);
+ },
+ );
+ }
+
+ sort(consulServices: SpServiceConfiguration[]): SpServiceConfiguration[] {
+ if (!consulServices || consulServices.length === 0) {
+ return null;
+ }
+
+ consulServices.sort(
+ (a: SpServiceConfiguration, b: SpServiceConfiguration) => {
+ if (a.serviceGroup < b.serviceGroup) {
+ return -1;
+ } else if (a.serviceGroup > b.serviceGroup) {
+ return 1;
+ } else {
+ return 0;
+ }
+ },
+ );
+ return consulServices;
+ }
+
+ updateConsulService(config: SpServiceConfiguration): void {
+ this.configurationService
+ .updateExtensionsServiceConfigs(config)
+ .subscribe(
+ () => {
+ this.getConsulServices();
+ },
+ error => {
+ console.error(error);
+ },
+ );
+ }
+
+ expand(element: SpServiceConfiguration) {
+ if (this.expandedElement === element) {
+ this.expandedElement = undefined;
+ } else {
+ this.expandedElement = element;
+ }
+ }
+}
diff --git a/ui/src/app/configuration/consul-configs-boolean/consul-configs-boolean.component.html b/ui/src/app/configuration/extensions-service-management/extensions-service-configuration/service-configs/service-configs-boolean/service-configs-boolean.component.html
similarity index 100%
rename from ui/src/app/configuration/consul-configs-boolean/consul-configs-boolean.component.html
rename to ui/src/app/configuration/extensions-service-management/extensions-service-configuration/service-configs/service-configs-boolean/service-configs-boolean.component.html
diff --git a/ui/src/app/configuration/consul-configs-boolean/consul-configs-boolean.component.ts b/ui/src/app/configuration/extensions-service-management/extensions-service-configuration/service-configs/service-configs-boolean/service-configs-boolean.component.ts
similarity index 72%
rename from ui/src/app/configuration/consul-configs-boolean/consul-configs-boolean.component.ts
rename to ui/src/app/configuration/extensions-service-management/extensions-service-configuration/service-configs/service-configs-boolean/service-configs-boolean.component.ts
index 856edc6837..cf69fa2e33 100644
--- a/ui/src/app/configuration/consul-configs-boolean/consul-configs-boolean.component.ts
+++ b/ui/src/app/configuration/extensions-service-management/extensions-service-configuration/service-configs/service-configs-boolean/service-configs-boolean.component.ts
@@ -17,16 +17,15 @@
*/
import { Component, Input } from '@angular/core';
-import { StreampipesPeContainerConifgs } from '../shared/streampipes-pe-container-configs';
-import { ConfigurationService } from '../shared/configuration.service';
+import { ConfigurationService } from '../../../../shared/configuration.service';
+import { ConfigItem } from '@streampipes/platform-services';
@Component({
selector: 'sp-consul-configs-boolean',
- templateUrl: './consul-configs-boolean.component.html',
- styleUrls: ['./consul-configs-boolean.component.css'],
+ templateUrl: './service-configs-boolean.component.html',
providers: [ConfigurationService],
})
-export class ConsulConfigsBooleanComponent {
- @Input() configuration: StreampipesPeContainerConifgs;
+export class ServiceConfigsBooleanComponent {
+ @Input() configuration: ConfigItem;
constructor(public configService: ConfigurationService) {}
}
diff --git a/ui/src/app/configuration/consul-configs-number/consul-configs-number.component.html b/ui/src/app/configuration/extensions-service-management/extensions-service-configuration/service-configs/service-configs-number/service-configs-number.component.html
similarity index 94%
rename from ui/src/app/configuration/consul-configs-number/consul-configs-number.component.html
rename to ui/src/app/configuration/extensions-service-management/extensions-service-configuration/service-configs/service-configs-number/service-configs-number.component.html
index 2ea4ba0227..d0220e7838 100644
--- a/ui/src/app/configuration/consul-configs-number/consul-configs-number.component.html
+++ b/ui/src/app/configuration/extensions-service-management/extensions-service-configuration/service-configs/service-configs-number/service-configs-number.component.html
@@ -16,7 +16,7 @@
~
-->
-
+
-
+ {{ configuration.key }}
{
- let fixture: ComponentFixture;
+ let fixture: ComponentFixture;
let configurationServiceStub: Partial;
- let component: ConsulConfigsPasswordComponent;
+ let component: ServiceConfigsPasswordComponent;
let configurationServcie: ConfigurationService;
@@ -68,7 +68,7 @@ describe('ConsulConfigsPasswordComponent', () => {
FormsModule,
HttpClientTestingModule,
],
- declarations: [ConsulConfigsPasswordComponent],
+ declarations: [ServiceConfigsPasswordComponent],
providers: [
{
provide: ConfigurationService,
@@ -77,7 +77,7 @@ describe('ConsulConfigsPasswordComponent', () => {
],
}).compileComponents();
- fixture = TestBed.createComponent(ConsulConfigsPasswordComponent);
+ fixture = TestBed.createComponent(ServiceConfigsPasswordComponent);
configurationServcie =
fixture.debugElement.injector.get(ConfigurationService);
diff --git a/ui/src/app/configuration/consul-configs-password/consul-configs-password.component.ts b/ui/src/app/configuration/extensions-service-management/extensions-service-configuration/service-configs/service-configs-password/service-configs-password.component.ts
similarity index 80%
rename from ui/src/app/configuration/consul-configs-password/consul-configs-password.component.ts
rename to ui/src/app/configuration/extensions-service-management/extensions-service-configuration/service-configs/service-configs-password/service-configs-password.component.ts
index 0923c2f938..cccf0d7e73 100644
--- a/ui/src/app/configuration/consul-configs-password/consul-configs-password.component.ts
+++ b/ui/src/app/configuration/extensions-service-management/extensions-service-configuration/service-configs/service-configs-password/service-configs-password.component.ts
@@ -17,19 +17,19 @@
*/
import { Component, Input } from '@angular/core';
-import { StreampipesPeContainerConifgs } from '../shared/streampipes-pe-container-configs';
-import { ConfigurationService } from '../shared/configuration.service';
+import { ConfigurationService } from '../../../../shared/configuration.service';
+import { ConfigItem } from '@streampipes/platform-services';
const hiddenPasswordString = '*****';
@Component({
selector: 'sp-consul-configs-password',
- templateUrl: './consul-configs-password.component.html',
- styleUrls: ['./consul-configs-password.component.css'],
+ templateUrl: './service-configs-password.component.html',
+ styleUrls: ['./service-configs-password.component.css'],
providers: [ConfigurationService],
})
-export class ConsulConfigsPasswordComponent {
- @Input() configuration: StreampipesPeContainerConifgs;
+export class ServiceConfigsPasswordComponent {
+ @Input() configuration: ConfigItem;
password: string;
show: boolean;
diff --git a/ui/src/app/configuration/consul-configs-text/consul-configs-text.component.html b/ui/src/app/configuration/extensions-service-management/extensions-service-configuration/service-configs/service-configs-text/service-configs-text.component.html
similarity index 95%
rename from ui/src/app/configuration/consul-configs-text/consul-configs-text.component.html
rename to ui/src/app/configuration/extensions-service-management/extensions-service-configuration/service-configs/service-configs-text/service-configs-text.component.html
index 5a8894efaa..9b9b56c7a8 100644
--- a/ui/src/app/configuration/consul-configs-text/consul-configs-text.component.html
+++ b/ui/src/app/configuration/extensions-service-management/extensions-service-configuration/service-configs/service-configs-text/service-configs-text.component.html
@@ -16,7 +16,7 @@
~
-->
-
+
+
+
+
+
diff --git a/ui/src/app/configuration/consul-configs/consul-configs.component.ts b/ui/src/app/configuration/extensions-service-management/extensions-service-configuration/service-configs/service-configs.component.ts
similarity index 71%
rename from ui/src/app/configuration/consul-configs/consul-configs.component.ts
rename to ui/src/app/configuration/extensions-service-management/extensions-service-configuration/service-configs/service-configs.component.ts
index b260d2fc05..8bfce5ba12 100644
--- a/ui/src/app/configuration/consul-configs/consul-configs.component.ts
+++ b/ui/src/app/configuration/extensions-service-management/extensions-service-configuration/service-configs/service-configs.component.ts
@@ -17,19 +17,18 @@
*/
import { Component, EventEmitter, Input, Output } from '@angular/core';
-import { StreampipesPeContainer } from '../shared/streampipes-pe-container.model';
-import { XsService } from '../../NS/xs.service';
+import { XsService } from '../../../../NS/xs.service';
+import { SpServiceConfiguration } from '@streampipes/platform-services';
@Component({
selector: 'sp-consul-configs',
- templateUrl: './consul-configs.component.html',
- styleUrls: ['./consul-configs.component.css'],
+ templateUrl: './service-configs.component.html',
providers: [XsService],
})
-export class ConsulConfigsComponent {
- @Input() consulService: StreampipesPeContainer;
- @Output() updateConsulService: EventEmitter =
- new EventEmitter();
+export class ServiceConfigsComponent {
+ @Input() consulService: SpServiceConfiguration;
+ @Output() updateConsulService: EventEmitter =
+ new EventEmitter();
constructor(private service: XsService) {}
diff --git a/ui/src/app/configuration/extensions-service-management/extensions-service-management.component.html b/ui/src/app/configuration/extensions-service-management/extensions-service-management.component.html
new file mode 100644
index 0000000000..3958c34611
--- /dev/null
+++ b/ui/src/app/configuration/extensions-service-management/extensions-service-management.component.html
@@ -0,0 +1,39 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
+
diff --git a/ui/src/app/configuration/extensions-service-management/extensions-service-management.component.ts b/ui/src/app/configuration/extensions-service-management/extensions-service-management.component.ts
new file mode 100644
index 0000000000..13190bd02f
--- /dev/null
+++ b/ui/src/app/configuration/extensions-service-management/extensions-service-management.component.ts
@@ -0,0 +1,39 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *
+ */
+
+import { Component, OnInit } from '@angular/core';
+import { SpConfigurationTabs } from '../configuration-tabs';
+import { SpBreadcrumbService } from '@streampipes/shared-ui';
+import { SpConfigurationRoutes } from '../configuration.routes';
+
+@Component({
+ selector: 'sp-extensions-service-management',
+ templateUrl: './extensions-service-management.component.html',
+})
+export class ExtensionsServiceManagementComponent implements OnInit {
+ tabs = SpConfigurationTabs.getTabs();
+
+ constructor(private breadcrumbService: SpBreadcrumbService) {}
+
+ ngOnInit() {
+ this.breadcrumbService.updateBreadcrumb([
+ SpConfigurationRoutes.BASE,
+ { label: SpConfigurationTabs.getTabs()[3].itemTitle },
+ ]);
+ }
+}
diff --git a/ui/src/app/configuration/extensions-service-management/registrered-extensions-services/registered-extensions-services.component.html b/ui/src/app/configuration/extensions-service-management/registrered-extensions-services/registered-extensions-services.component.html
new file mode 100644
index 0000000000..8cea7ddc60
--- /dev/null
+++ b/ui/src/app/configuration/extensions-service-management/registrered-extensions-services/registered-extensions-services.component.html
@@ -0,0 +1,84 @@
+
+
+
+
+
+
+ Status
+
+
+
+ lens
+
+
+ lens
+
+
+
+
+
+
+ Service ID
+
+
+ {{ element.svcId }}
+
+
+
+
+
+
+
+
diff --git a/ui/src/app/configuration/consul-configs/consul-configs.component.css b/ui/src/app/configuration/extensions-service-management/registrered-extensions-services/registered-extensions-services.component.scss
similarity index 85%
rename from ui/src/app/configuration/consul-configs/consul-configs.component.css
rename to ui/src/app/configuration/extensions-service-management/registrered-extensions-services/registered-extensions-services.component.scss
index 13cbc4aacb..c75dfb8bca 100644
--- a/ui/src/app/configuration/consul-configs/consul-configs.component.css
+++ b/ui/src/app/configuration/extensions-service-management/registrered-extensions-services/registered-extensions-services.component.scss
@@ -15,3 +15,13 @@
* limitations under the License.
*
*/
+
+.service-icon-passing {
+ cursor: default;
+ color: #4caf50;
+}
+
+.service-icon-critical {
+ cursor: default;
+ color: #f44336;
+}
diff --git a/ui/src/app/configuration/extensions-service-management/registrered-extensions-services/registered-extensions-services.component.ts b/ui/src/app/configuration/extensions-service-management/registrered-extensions-services/registered-extensions-services.component.ts
new file mode 100644
index 0000000000..cb1f3a50cf
--- /dev/null
+++ b/ui/src/app/configuration/extensions-service-management/registrered-extensions-services/registered-extensions-services.component.ts
@@ -0,0 +1,46 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *
+ */
+
+import { Component, ViewChild } from '@angular/core';
+import { MatPaginator } from '@angular/material/paginator';
+import { MatTableDataSource } from '@angular/material/table';
+import { SpServiceRegistration } from '@streampipes/platform-services';
+import { ConfigurationService } from '../../shared/configuration.service';
+
+@Component({
+ selector: 'sp-registered-extensions-services',
+ templateUrl: './registered-extensions-services.component.html',
+ styleUrls: ['./registered-extensions-services.component.scss'],
+})
+export class SpRegisteredExtensionsServiceComponent {
+ displayedColumns: string[] = ['status', 'name'];
+ @ViewChild(MatPaginator, { static: false }) paginator: MatPaginator;
+ dataSource = new MatTableDataSource();
+
+ constructor(private configurationService: ConfigurationService) {
+ this.getRegisteredServices();
+ }
+
+ getRegisteredServices(): void {
+ this.configurationService
+ .getRegisteredExtensionsServices()
+ .subscribe(res => {
+ this.dataSource.data = res;
+ });
+ }
+}
diff --git a/ui/src/app/configuration/messaging-configuration/broker-config/broker-config.component.html b/ui/src/app/configuration/messaging-configuration/broker-config/broker-config.component.html
new file mode 100644
index 0000000000..d97c4bd56b
--- /dev/null
+++ b/ui/src/app/configuration/messaging-configuration/broker-config/broker-config.component.html
@@ -0,0 +1,35 @@
+
+
+
+
{{ title }}
+
+
+
+ Host
+
+
+
+
+
+ Port
+
+
+
+
+
diff --git a/streampipes-extensions/streampipes-pipeline-elements-all-jvm/src/main/java/org/apache/streampipes/pe/jvm/config/ConfigKeys.java b/ui/src/app/configuration/messaging-configuration/broker-config/broker-config.component.ts
similarity index 72%
rename from streampipes-extensions/streampipes-pipeline-elements-all-jvm/src/main/java/org/apache/streampipes/pe/jvm/config/ConfigKeys.java
rename to ui/src/app/configuration/messaging-configuration/broker-config/broker-config.component.ts
index 77412c1b7f..9a00398bb4 100644
--- a/streampipes-extensions/streampipes-pipeline-elements-all-jvm/src/main/java/org/apache/streampipes/pe/jvm/config/ConfigKeys.java
+++ b/ui/src/app/configuration/messaging-configuration/broker-config/broker-config.component.ts
@@ -15,10 +15,20 @@
* limitations under the License.
*
*/
-package org.apache.streampipes.pe.jvm.config;
-public class ConfigKeys {
- static final String HOST = "SP_HOST";
- static final String PORT = "SP_PORT";
- static final String SERVICE_NAME_KEY = "SP_SERVICE_NAME";
+import { Component, Input } from '@angular/core';
+
+@Component({
+ selector: 'sp-messaging-broker-config',
+ templateUrl: './broker-config.component.html',
+})
+export class SpMessagingBrokerConfigComponent {
+ @Input()
+ title: string;
+
+ @Input()
+ host: string;
+
+ @Input()
+ port: number;
}
diff --git a/ui/src/app/configuration/messaging-configuration/messaging-configuration.component.html b/ui/src/app/configuration/messaging-configuration/messaging-configuration.component.html
index 7afdeffa6f..8f96bc8864 100644
--- a/ui/src/app/configuration/messaging-configuration/messaging-configuration.component.html
+++ b/ui/src/app/configuration/messaging-configuration/messaging-configuration.component.html
@@ -167,5 +167,58 @@
+
+
+
+
+
+
+