This is an automated email from the ASF dual-hosted git repository.
riemer pushed a change to branch dev
in repository https://gitbox.apache.org/repos/asf/streampipes.git
from 75e4d76578 refactor: migrate core-ui components to signals (#4267)
add 80ae050bb7 feat(#4252): Support broker-based core-extension
communication mode (#4242)
No new revisions were added by this update.
Summary of changes:
installer/cli/.env | 3 +
installer/cli/README.md | 8 +
.../deploy/standalone/backend/docker-compose.yml | 1 +
.../extensions-all-jvm/docker-compose.yml | 1 +
.../{nats => nats-auth}/docker-compose.dev.yml | 0
.../{nats => nats-auth}/docker-compose.yml | 3 +
.../environments/{backend => backend-nats-auth} | 2 +-
.../cli/environments/{basic => basic-nats-auth} | 2 +-
.../cli/environments/{lite => lite-nats-auth} | 2 +-
...ine-element-nats => pipeline-element-nats-auth} | 2 +-
installer/compose/.env | 4 +
installer/compose/README.md | 14 +-
.../docker-compose.minimal.nats-auth.yml} | 26 +-
.../docker-compose.nats-auth.yml} | 16 +-
pom.xml | 8 +-
.../apache/streampipes/client/api/IAdminApi.java | 3 -
streampipes-client-e2e/docker-compose.yml | 2 +
.../go-client-e2e/pipelines/pipelines.json | 96 +-----
.../streampipes/model/pipeline/pipeline.go | 2 -
.../apache/streampipes/client/api/AdminApi.java | 12 -
.../apache/streampipes/commons/constants/Envs.java | 7 +
.../commons/environment/DefaultEnvironment.java | 20 ++
.../commons/environment/Environment.java | 8 +
.../management/compact/AdapterGenerationSteps.java | 8 +-
.../management/compact/PersistPipelineHandler.java | 6 +-
.../management/AdapterMasterManagement.java | 40 ++-
.../management/AdapterMigrationManager.java | 27 +-
.../management/AdapterUpdateManagement.java | 19 +-
.../management/DescriptionManagement.java | 22 +-
.../management/management/GuessManagement.java | 41 ++-
.../management/WorkerAdministrationManagement.java | 8 +-
.../management/management/WorkerRestClient.java | 182 +++++-----
.../connect/management/util/WorkerPaths.java | 51 ---
.../management/AdapterMasterManagementTest.java | 26 +-
streampipes-connect-shared/pom.xml | 6 -
.../streampipes/export/AssetLinkResolver.java | 12 +-
.../apache/streampipes/export/ExportManager.java | 12 +-
.../apache/streampipes/export/ImportManager.java | 12 +-
.../export/dataimport/PerformImportGenerator.java | 10 +-
.../export/dataimport/PreviewImportGenerator.java | 14 +-
.../export/generator/ExportPackageGenerator.java | 10 +-
.../export/resolver/AdapterResolver.java | 12 +-
.../export/resolver/PipelineResolver.java | 9 +-
.../export/utils/EventGroundingProcessor.java | 77 +----
.../management/ExtensionAdapterManagement.java | 4 +-
.../management/connect/AdapterAssetManagement.java | 71 ++++
...ider.java => AdapterDescriptionManagement.java} | 41 ++-
.../connect/AdapterWorkerRequestManagement.java | 77 +++++
.../AdapterWorkerSampleDataRequestManagement.java | 69 ++++
.../connect/ConnectWorkerDescriptionProvider.java | 8 +-
.../HttpServerAdapterRequestManagement.java | 17 +-
.../connect/RuntimeResolvableManagement.java | 55 +++
.../elements/SendToBrokerAdapterSink.java | 15 +-
.../management/init/DeclarersSingleton.java | 31 +-
.../migration/AbstractMigrationHandler.java | 67 +---
.../migration/AdapterMigrationHandler.java | 14 +-
.../migration/DataProcessorMigrationHandler.java | 28 +-
.../migration/DataSinkMigrationHandler.java | 20 +-
.../extensions/management}/model/Description.java | 2 +-
.../management/model/SpServiceDefinition.java | 4 -
.../monitoring/HealthCheckManagement.java | 41 ++-
.../monitoring/MonitoringManagement.java | 29 +-
.../monitoring/ServiceMonitorManagement.java | 32 +-
.../pe/AbstractPipelineElementManagement.java | 84 +++++
.../pe/DataProcessorPipelineElementManagement.java | 19 +-
.../pe/DataSinkPipelineElementManagement.java | 18 +-
.../DataStreamPipelineElementManagement.java} | 27 +-
.../pe/InvocablePipelineElementManagement.java | 158 +++++++++
.../management/init/DeclarersSingletonTest.java | 6 +-
.../extensions/all/iiot/AllExtensionsIIoTInit.java | 2 -
.../extensions/all/jvm/AllExtensionsInit.java | 2 -
.../siddhi/trend/TestTrendProcessor.java | 2 -
.../streampipes-sinks-brokers-jvm/pom.xml | 9 +-
.../sinks/brokers/jvm}/jms/ActiveMQPublisher.java | 38 ++-
.../sinks/brokers/jvm}/jms/ActiveMQUtils.java | 9 +-
.../sinks/brokers/jvm/jms/JmsPublisherSink.java | 7 +-
.../sinks/internal/jvm/datalake/DataLakeSink.java | 2 +-
.../INotificationDataSinkMigratorTest.java | 6 +-
.../notifications/jvm/msteams/TestMSTeamsSink.java | 10 +-
.../health/monitoring/AdapterHealthCheck.java | 1 -
.../health/monitoring/ExtensionHealthCheck.java | 19 +-
.../ExtensionInstanceAvailabilityCheck.java | 46 ++-
.../health/monitoring/PipelineHealthCheck.java | 19 +-
.../health/monitoring/ResourceProvider.java | 8 +-
.../health/monitoring/ServiceHealthCheck.java | 21 +-
.../monitoring/ServiceRegistrationManager.java | 8 +-
.../service/ExtensionServiceExecutions.java | 86 -----
.../service/ExtensionsServiceReportExecutor.java | 39 +--
streampipes-messaging-jms/pom.xml | 54 ---
.../messaging/jms/ActiveMQConnectionProvider.java | 49 ---
.../messaging/jms/ActiveMQConsumer.java | 111 ------
.../streampipes/messaging/jms/SpJmsProtocol.java | 37 --
.../messaging/jms/SpJmsProtocolFactory.java | 42 ---
.../messaging/kafka/SpKafkaConsumer.java | 2 +-
.../messaging/kafka/SpKafkaProducer.java | 6 +-
.../messaging/nats/AbstractNatsConnector.java | 17 +-
.../streampipes/messaging/SpProtocolManager.java | 4 -
.../streampipes/model/api/EndpointSelectable.java | 4 +
.../model/base/ConsumableStreamPipesEntity.java | 15 -
.../model/base/InvocableStreamPipesEntity.java | 23 +-
.../configuration/DefaultMessagingSettings.java | 71 ----
.../configuration/DefaultSpCoreConfiguration.java | 1 -
.../model/configuration/MessagingSettings.java | 187 -----------
.../model/configuration/SpCoreConfiguration.java | 9 -
.../model/configuration/SpProtocol.java | 1 -
.../model/connect/adapter/AdapterDescription.java | 9 +
.../svcdiscovery/SpServiceTagPrefix.java | 9 -
.../ExtensionServiceBrokerErrorEnvelope.java} | 20 +-
.../transport/ExtensionServiceBrokerOperation.java | 32 +-
.../ExtensionServiceBrokerOperations.java | 70 ++++
.../ExtensionServiceBrokerRequestEnvelope.java | 72 ++++
.../ExtensionServiceBrokerResponseEnvelope.java | 90 +++++
.../transport/ExtensionServiceBrokerTopics.java | 158 +++++++++
.../ExtensionServicePipelineDetachRequest.java} | 32 +-
.../transport/ExtensionServiceTransportMode.java | 35 +-
.../model/graph/DataProcessorDescription.java | 2 -
.../model/graph/DataProcessorInvocation.java | 3 -
.../model/graph/DataSinkDescription.java | 2 -
.../model/graph/DataSinkInvocation.java | 3 -
.../model/grounding/JmsTransportProtocol.java | 53 ---
.../model/grounding/KafkaTransportProtocol.java | 7 +
.../model/grounding/MqttTransportProtocol.java | 7 +
.../model/grounding/NatsTransportProtocol.java | 17 +
.../model/grounding/PulsarTransportProtocol.java | 7 +
.../model/grounding/TransportFormat.java | 54 ---
.../model/grounding/TransportProtocol.java | 3 +-
.../org/apache/streampipes/model/util/Cloner.java | 3 -
.../ExtensionServiceBrokerTopicsTest.java | 87 +++++
.../ExtensionServiceTransportModeTest.java | 52 +++
streampipes-nats-extensions/README.md | 123 +++++++
.../pom.xml | 30 +-
.../ExtensionBrokerOperationHandler.java | 18 +-
.../extensions/ExtensionBrokerRequestContext.java | 5 +-
.../extensions/ExtensionBrokerRequestReceiver.java | 372 +++++++++++++++++++++
.../operation/ExtensionBrokerConstants.java | 26 +-
.../operation/ExtensionBrokerResponseFactory.java | 110 ++++++
.../operation/ExtensionBrokerTopicParser.java | 92 +++++
.../connect/AdapterAssetOperationHandler.java | 96 ++++++
.../AdapterStateChangeOperationHandler.java | 92 +++++
.../connect/RuntimeOptionsOperationHandler.java | 115 +++++++
.../connect/SampleDataOperationHandler.java | 104 ++++++
.../function/FunctionStopOperationHandler.java | 67 ++++
.../migration/MigrationOperationHandler.java | 141 ++++++++
.../ExtensionInstanceHealthOperationHandler.java | 69 ++++
.../monitoring/ServiceHealthOperationHandler.java | 69 ++++
.../monitoring/ServiceLoadOperationHandler.java | 55 +++
.../ContainerProvidedOptionsOperationHandler.java | 136 ++++++++
.../operation/pe/DescriptionOperationHandler.java | 125 +++++++
.../operation/pe/OutputSchemaOperationHandler.java | 150 +++++++++
.../pe/PipelineElementAssetsOperationHandler.java | 165 +++++++++
.../pe/PipelineElementDetachOperationHandler.java | 120 +++++++
.../PipelineElementInvocationOperationHandler.java | 120 +++++++
.../operation/ExtensionBrokerTopicParserTest.java | 88 +++++
.../connect/AdapterAssetOperationHandlerTest.java | 129 +++++++
...r.java => ExtensionServiceOperationResult.java} | 28 +-
.../api/extensions/ExtensionServiceRequest.java | 53 +++
.../extensions/ExtensionServiceRequestManager.java | 11 +-
.../extensions/ExtensionServiceRequestMethod.java | 9 +-
.../extensions/ExtensionServiceRequestTarget.java | 94 ++++++
.../extensions/ExtensionServiceRequestTargets.java | 257 ++++++++++++++
.../api/extensions/ExtensionServiceRequests.java | 133 ++++++++
.../IExtensionsServiceEndpointGenerator.java | 19 +-
.../streampipes/manager/assets/AssetFetcher.java | 34 +-
.../streampipes/manager/assets/AssetManager.java | 6 +-
.../execution/ExtensionServiceExecutions.java | 75 -----
.../HttpExtensionServiceRequestManager.java | 107 ++++++
.../execution/PipelineExecutionTaskFactory.java | 11 +-
.../manager/execution/PipelineExecutor.java | 10 +-
.../ExtensionsServiceEndpointGenerator.java | 29 +-
.../http/BasePipelineElementSubmitter.java | 16 +-
.../execution/http/DetachExtensionRequest.java | 65 ++++
.../manager/execution/http/DetachHttpRequest.java | 42 ---
.../http/DetachPipelineElementSubmitter.java | 6 +-
...ttpRequest.java => InvokeExtensionRequest.java} | 37 +-
.../http/InvokePipelineElementSubmitter.java | 9 +-
...t.java => PipelineElementExtensionRequest.java} | 46 ++-
.../execution/task/DiscoverEndpointsTask.java | 12 +-
.../manager/extensions/ExtensionItemInstaller.java | 41 ++-
.../extensions/ExtensionsResourceUrlProvider.java | 74 ----
.../manager/function/FunctionManager.java | 34 +-
.../manager/matching/GroundingSelector.java | 46 ---
.../matching/PipelineVerificationHandlerV2.java | 8 +-
.../manager/matching/ProtocolSelector.java | 103 +-----
.../CustomTransformOutputSchemaGenerator.java | 50 ++-
.../matching/output/OutputSchemaFactory.java | 12 +-
.../manager/matching/v2/ElementVerification.java | 52 ---
.../manager/matching/v2/GroundingMatch.java | 53 ---
.../manager/matching/v2/ProtocolMatch.java | 44 ---
.../manager/matching/v2/StreamMatch.java | 16 +-
.../matching/v2/pipeline/ApplyGroundingStep.java | 58 +---
.../matching/v2/pipeline/ComputeOutputStep.java | 9 +-
.../v2/pipeline/PipelineValidationSteps.java | 6 +-
.../migration/AbstractMigrationManager.java | 61 ++--
.../AdapterDescriptionMigration093Provider.java | 45 ---
.../manager/migration/MigrationUtils.java | 11 +-
.../migration/PipelineElementMigrationManager.java | 34 +-
.../pipeline/ExtensionsServiceLogExecutor.java | 74 ++--
.../manager/pipeline/PipelineManager.java | 16 +-
.../compact/CompactPipelineManagement.java | 8 +-
.../manager/preview/PipelinePreview.java | 41 ++-
.../manager/recommender/ElementRecommender.java | 10 +-
.../remote/ContainerProvidedOptionsHandler.java | 33 +-
.../runtime/DataStreamRuntimeInfoProvider.java | 10 +
.../manager/setup/AutoInstallation.java | 11 +-
.../manager/setup/ExtensionsInstallationTask.java | 9 +-
.../manager/setup/InstallationConfiguration.java | 11 +-
.../setup/PipelineElementInstallationStep.java | 23 +-
.../compact/CompactPipelineTemplateManagement.java | 8 +-
.../streampipes/manager}/util/GroundingUtils.java | 95 +++---
.../manager/verification/TypedElementVerifier.java | 12 +-
.../verification/extractor/TypeExtractor.java | 14 +-
.../manager/matching/v2/TestGroundingMatch.java | 78 -----
.../manager/matching/v2/TestProtocolMatch.java | 55 ---
.../streampipes/manager/matching/v2/TestUtils.java | 34 --
.../manager/verification/TypeExtractorTest.java | 15 +-
streampipes-rest-extensions/pom.xml | 15 -
.../AbstractPipelineElementResource.java | 102 +-----
.../streampipes/rest/extensions/WelcomePage.java | 72 ----
.../extensions/connect/AdapterAssetResource.java | 62 ++--
.../connect/AdapterDescriptionResource.java | 48 ++-
.../extensions/connect/AdapterWorkerResource.java | 36 +-
.../connect/AdapterWorkerSampleDataResource.java | 10 +-
.../connect/HttpServerAdapterResource.java | 14 +-
.../connect/RuntimeResolvableResource.java | 31 +-
.../rest/extensions/html/HTMLGenerator.java | 82 -----
.../rest/extensions/html/JSONGenerator.java | 61 ----
.../extensions/html/page/WelcomePageGenerator.java | 154 ---------
.../migration/AdapterMigrationResource.java | 28 +-
.../migration/DataProcessorMigrationResource.java | 28 +-
.../migration/DataSinkMigrationResource.java | 29 +-
.../extensions/monitoring/HealthCheckResource.java | 40 +--
.../extensions/monitoring/MonitoringResource.java | 18 +-
.../monitoring/ServiceMonitorResource.java | 15 +-
.../pe/DataProcessorPipelineElementResource.java | 52 +--
.../pe/DataSinkPipelineElementResource.java | 50 +--
.../pe/DataStreamPipelineElementResource.java | 20 +-
.../pe/InvocablePipelineElementResource.java | 121 +------
.../migration/MigrateExtensionsResourceTest.java | 13 +-
.../apache/streampipes/rest/ResetManagement.java | 25 +-
.../rest/impl/AbstractMonitoringResource.java | 11 +-
.../rest/impl/AdapterMonitoringResource.java | 10 +-
.../rest/impl/CompactPipelineResource.java | 10 +-
.../rest/impl/ContainerProvidedOptions.java | 9 +-
.../streampipes/rest/impl/PipelineMonitoring.java | 12 +-
.../streampipes/rest/impl/PipelineResource.java | 16 +-
.../streampipes/rest/impl/PipelineTemplate.java | 6 +-
.../streampipes/rest/impl/ResetResource.java | 21 +-
.../rest/impl/admin/DataExportResource.java | 11 +-
.../rest/impl/admin/DataImportResource.java | 15 +-
.../impl/admin/ExtensionsInstallationResource.java | 34 +-
.../admin/ExtensionsServiceEndpointResource.java | 51 ++-
.../impl/admin/MessagingConfigurationResource.java | 55 ---
.../rest/impl/admin/MigrationResource.java | 19 +-
.../rest/impl/connect/AdapterResource.java | 18 +-
.../rest/impl/connect/CompactAdapterResource.java | 31 +-
.../rest/impl/connect/DescriptionResource.java | 23 +-
.../rest/impl/connect/GuessResource.java | 6 +-
.../impl/connect/RuntimeResolvableResource.java | 8 +-
.../rest/impl/runtime/PipelinePreviewResource.java | 10 +-
streampipes-sdk-bundle/pom.xml | 5 -
.../builder/AbstractProcessingElementBuilder.java | 37 --
.../apache/streampipes/sdk/helpers/Protocols.java | 14 -
.../sdk/helpers/SupportedProtocols.java | 62 ----
streampipes-service-core-minimal/pom.xml | 4 -
streampipes-service-core/pom.xml | 5 -
.../streampipes/service/core/PostStartupTask.java | 24 +-
.../service/core/StreamPipesCoreApplication.java | 98 ++++--
.../extensions/CoreExtensionTransportMode.java | 26 +-
.../extensions/CoreNatsRequestReplyClient.java | 111 ++++++
.../ExtensionServiceRequestConfiguration.java | 88 +++++
.../NatsExtensionServiceRequestManager.java | 124 +++++++
...ansportAwareExtensionServiceRequestManager.java | 109 ++++++
.../svcdiscovery/api/ISpServiceDiscovery.java | 12 -
.../api/model/SpServiceUrlProvider.java | 12 -
.../svcdiscovery/SpServiceDiscoveryCore.java | 13 -
streampipes-service-extensions/pom.xml | 5 +
.../StreamPipesExtensionsServiceBase.java | 70 +++-
.../test/generator/InvocationGraphGenerator.java | 2 -
.../distributed/runtime/DistributedRuntime.java | 9 -
.../standalone/manager/ProtocolManager.java | 17 +-
.../tests/chart/dynamicColumnFilter.smoke.spec.ts | 5 +-
.../configuration-sections.providers.ts | 10 -
.../endpoint-item/endpoint-item.component.html | 29 +-
.../endpoint-item/endpoint-item.component.scss | 122 ++++++-
.../endpoint-item/endpoint-item.component.ts | 27 +-
.../extensions-installation.component.html | 5 +-
.../broker-config/broker-config.component.html | 44 ---
.../broker-config/broker-config.component.ts | 60 ----
.../messaging-configuration.component.html | 200 -----------
.../messaging-configuration.component.scss | 70 ----
.../messaging-configuration.component.ts | 116 -------
291 files changed, 7013 insertions(+), 4641 deletions(-)
copy installer/cli/deploy/standalone/{nats =>
nats-auth}/docker-compose.dev.yml (100%)
copy installer/cli/deploy/standalone/{nats => nats-auth}/docker-compose.yml
(90%)
copy installer/cli/environments/{backend => backend-nats-auth} (98%)
copy installer/cli/environments/{basic => basic-nats-auth} (98%)
copy installer/cli/environments/{lite => lite-nats-auth} (98%)
copy installer/cli/environments/{pipeline-element-nats =>
pipeline-element-nats-auth} (98%)
copy installer/{cli/deploy/standalone/crate/docker-compose.yml =>
compose/docker-compose.minimal.nats-auth.yml} (74%)
copy installer/{cli/deploy/standalone/pulsar/docker-compose.dev.yml =>
compose/docker-compose.nats-auth.yml} (75%)
delete mode 100644
streampipes-connect-management/src/main/java/org/apache/streampipes/connect/management/util/WorkerPaths.java
copy
streampipes-connect-transformer-api/src/main/java/org/apache/streampipes/connect/transformer/api/Context.java
=>
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/ExtensionAdapterManagement.java
(89%)
create mode 100644
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect/AdapterAssetManagement.java
copy
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect/{ConnectWorkerDescriptionProvider.java
=> AdapterDescriptionManagement.java} (56%)
create mode 100644
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect/AdapterWorkerRequestManagement.java
create mode 100644
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect/AdapterWorkerSampleDataRequestManagement.java
copy
streampipes-client-api/src/main/java/org/apache/streampipes/client/api/constants/InputStreamIndex.java
=>
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect/HttpServerAdapterRequestManagement.java
(71%)
create mode 100644
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect/RuntimeResolvableManagement.java
rename
streampipes-rest-extensions/src/main/java/org/apache/streampipes/rest/extensions/migration/MigrateExtensionsResource.java
=>
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/migration/AbstractMigrationHandler.java
(59%)
copy
streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/migration/IAdapterMigrator.java
=>
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/migration/AdapterMigrationHandler.java
(63%)
copy
streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/pe/param/IDataProcessorParameters.java
=>
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/migration/DataProcessorMigrationHandler.java
(61%)
copy
streampipes-sdk/src/main/java/org/apache/streampipes/sdk/extractor/DataSinkParameterExtractor.java
=>
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/migration/DataSinkMigrationHandler.java
(63%)
rename
{streampipes-rest-extensions/src/main/java/org/apache/streampipes/rest/extensions/html
=>
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management}/model/Description.java
(98%)
copy
streampipes-rest-extensions/src/main/java/org/apache/streampipes/rest/extensions/monitoring/HealthCheckResource.java
=>
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/monitoring/HealthCheckManagement.java
(63%)
copy
streampipes-rest-extensions/src/main/java/org/apache/streampipes/rest/extensions/monitoring/MonitoringResource.java
=>
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/monitoring/MonitoringManagement.java
(56%)
copy
streampipes-integration-tests/src/test/java/org/apache/streampipes/integration/containers/SpKafkaTestContainer.java
=>
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/monitoring/ServiceMonitorManagement.java
(59%)
create mode 100644
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/pe/AbstractPipelineElementManagement.java
copy
streampipes-rest-extensions/src/main/java/org/apache/streampipes/rest/extensions/pe/DataProcessorPipelineElementResource.java
=>
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/pe/DataProcessorPipelineElementManagement.java
(81%)
copy
streampipes-rest-extensions/src/main/java/org/apache/streampipes/rest/extensions/pe/DataSinkPipelineElementResource.java
=>
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/pe/DataSinkPipelineElementManagement.java
(79%)
copy
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/{connect/RuntimeResovable.java
=> pe/DataStreamPipelineElementManagement.java} (55%)
create mode 100644
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/pe/InvocablePipelineElementManagement.java
rename
{streampipes-messaging-jms/src/main/java/org/apache/streampipes/messaging =>
streampipes-extensions/streampipes-sinks-brokers-jvm/src/main/java/org/apache/streampipes/sinks/brokers/jvm}/jms/ActiveMQPublisher.java
(75%)
rename
{streampipes-messaging-jms/src/main/java/org/apache/streampipes/messaging =>
streampipes-extensions/streampipes-sinks-brokers-jvm/src/main/java/org/apache/streampipes/sinks/brokers/jvm}/jms/ActiveMQUtils.java
(77%)
delete mode 100644
streampipes-load-balancer/src/main/java/org/apache/streampipes/loadbalance/service/ExtensionServiceExecutions.java
delete mode 100644 streampipes-messaging-jms/pom.xml
delete mode 100644
streampipes-messaging-jms/src/main/java/org/apache/streampipes/messaging/jms/ActiveMQConnectionProvider.java
delete mode 100644
streampipes-messaging-jms/src/main/java/org/apache/streampipes/messaging/jms/ActiveMQConsumer.java
delete mode 100644
streampipes-messaging-jms/src/main/java/org/apache/streampipes/messaging/jms/SpJmsProtocol.java
delete mode 100644
streampipes-messaging-jms/src/main/java/org/apache/streampipes/messaging/jms/SpJmsProtocolFactory.java
delete mode 100644
streampipes-model/src/main/java/org/apache/streampipes/model/configuration/DefaultMessagingSettings.java
delete mode 100644
streampipes-model/src/main/java/org/apache/streampipes/model/configuration/MessagingSettings.java
copy
streampipes-model/src/main/java/org/apache/streampipes/model/{datalake/importer/CsvImportValidationMessage.java
=> extensions/transport/ExtensionServiceBrokerErrorEnvelope.java} (70%)
copy
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/data/PipelineGraphHelpers.java
=>
streampipes-model/src/main/java/org/apache/streampipes/model/extensions/transport/ExtensionServiceBrokerOperation.java
(55%)
create mode 100644
streampipes-model/src/main/java/org/apache/streampipes/model/extensions/transport/ExtensionServiceBrokerOperations.java
create mode 100644
streampipes-model/src/main/java/org/apache/streampipes/model/extensions/transport/ExtensionServiceBrokerRequestEnvelope.java
create mode 100644
streampipes-model/src/main/java/org/apache/streampipes/model/extensions/transport/ExtensionServiceBrokerResponseEnvelope.java
create mode 100644
streampipes-model/src/main/java/org/apache/streampipes/model/extensions/transport/ExtensionServiceBrokerTopics.java
copy
streampipes-model/src/main/java/org/apache/streampipes/model/{pipeline/PipelineElementRecommendation.java
=> extensions/transport/ExtensionServicePipelineDetachRequest.java} (63%)
copy
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/data/PipelineGraphHelpers.java
=>
streampipes-model/src/main/java/org/apache/streampipes/model/extensions/transport/ExtensionServiceTransportMode.java
(57%)
delete mode 100644
streampipes-model/src/main/java/org/apache/streampipes/model/grounding/JmsTransportProtocol.java
delete mode 100644
streampipes-model/src/main/java/org/apache/streampipes/model/grounding/TransportFormat.java
create mode 100644
streampipes-model/src/test/java/org/apache/streampipes/model/extensions/transport/ExtensionServiceBrokerTopicsTest.java
create mode 100644
streampipes-model/src/test/java/org/apache/streampipes/model/extensions/transport/ExtensionServiceTransportModeTest.java
create mode 100644 streampipes-nats-extensions/README.md
copy {streampipes-extensions-api => streampipes-nats-extensions}/pom.xml (78%)
copy
streampipes-client-api/src/main/java/org/apache/streampipes/client/api/CRUDApi.java
=>
streampipes-nats-extensions/src/main/java/org/apache/streampipes/nats/extensions/ExtensionBrokerOperationHandler.java
(61%)
copy
streampipes-commons/src/main/java/org/apache/streampipes/commons/environment/variable/EnvResolver.java
=>
streampipes-nats-extensions/src/main/java/org/apache/streampipes/nats/extensions/ExtensionBrokerRequestContext.java
(85%)
create mode 100644
streampipes-nats-extensions/src/main/java/org/apache/streampipes/nats/extensions/ExtensionBrokerRequestReceiver.java
copy
streampipes-messaging-nats/src/main/java/org/apache/streampipes/messaging/nats/SpNatsProtocol.java
=>
streampipes-nats-extensions/src/main/java/org/apache/streampipes/nats/extensions/operation/ExtensionBrokerConstants.java
(59%)
create mode 100644
streampipes-nats-extensions/src/main/java/org/apache/streampipes/nats/extensions/operation/ExtensionBrokerResponseFactory.java
create mode 100644
streampipes-nats-extensions/src/main/java/org/apache/streampipes/nats/extensions/operation/ExtensionBrokerTopicParser.java
create mode 100644
streampipes-nats-extensions/src/main/java/org/apache/streampipes/nats/extensions/operation/connect/AdapterAssetOperationHandler.java
create mode 100644
streampipes-nats-extensions/src/main/java/org/apache/streampipes/nats/extensions/operation/connect/AdapterStateChangeOperationHandler.java
create mode 100644
streampipes-nats-extensions/src/main/java/org/apache/streampipes/nats/extensions/operation/connect/RuntimeOptionsOperationHandler.java
create mode 100644
streampipes-nats-extensions/src/main/java/org/apache/streampipes/nats/extensions/operation/connect/SampleDataOperationHandler.java
create mode 100644
streampipes-nats-extensions/src/main/java/org/apache/streampipes/nats/extensions/operation/function/FunctionStopOperationHandler.java
create mode 100644
streampipes-nats-extensions/src/main/java/org/apache/streampipes/nats/extensions/operation/migration/MigrationOperationHandler.java
create mode 100644
streampipes-nats-extensions/src/main/java/org/apache/streampipes/nats/extensions/operation/monitoring/ExtensionInstanceHealthOperationHandler.java
create mode 100644
streampipes-nats-extensions/src/main/java/org/apache/streampipes/nats/extensions/operation/monitoring/ServiceHealthOperationHandler.java
create mode 100644
streampipes-nats-extensions/src/main/java/org/apache/streampipes/nats/extensions/operation/monitoring/ServiceLoadOperationHandler.java
create mode 100644
streampipes-nats-extensions/src/main/java/org/apache/streampipes/nats/extensions/operation/pe/ContainerProvidedOptionsOperationHandler.java
create mode 100644
streampipes-nats-extensions/src/main/java/org/apache/streampipes/nats/extensions/operation/pe/DescriptionOperationHandler.java
create mode 100644
streampipes-nats-extensions/src/main/java/org/apache/streampipes/nats/extensions/operation/pe/OutputSchemaOperationHandler.java
create mode 100644
streampipes-nats-extensions/src/main/java/org/apache/streampipes/nats/extensions/operation/pe/PipelineElementAssetsOperationHandler.java
create mode 100644
streampipes-nats-extensions/src/main/java/org/apache/streampipes/nats/extensions/operation/pe/PipelineElementDetachOperationHandler.java
create mode 100644
streampipes-nats-extensions/src/main/java/org/apache/streampipes/nats/extensions/operation/pe/PipelineElementInvocationOperationHandler.java
create mode 100644
streampipes-nats-extensions/src/test/java/org/apache/streampipes/nats/extensions/operation/ExtensionBrokerTopicParserTest.java
create mode 100644
streampipes-nats-extensions/src/test/java/org/apache/streampipes/nats/extensions/operation/connect/AdapterAssetOperationHandlerTest.java
rename
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/api/extensions/{IExtensionsResourceUrlProvider.java
=> ExtensionServiceOperationResult.java} (57%)
create mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/api/extensions/ExtensionServiceRequest.java
copy
streampipes-service-core/src/main/java/org/apache/streampipes/service/core/migrations/Migration.java
=>
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/api/extensions/ExtensionServiceRequestManager.java
(80%)
copy
streampipes-commons/src/main/java/org/apache/streampipes/commons/environment/variable/EnvResolver.java
=>
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/api/extensions/ExtensionServiceRequestMethod.java
(86%)
create mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/api/extensions/ExtensionServiceRequestTarget.java
create mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/api/extensions/ExtensionServiceRequestTargets.java
create mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/api/extensions/ExtensionServiceRequests.java
delete mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/execution/ExtensionServiceExecutions.java
create mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/execution/HttpExtensionServiceRequestManager.java
create mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/execution/http/DetachExtensionRequest.java
delete mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/execution/http/DetachHttpRequest.java
rename
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/execution/http/{InvokeHttpRequest.java
=> InvokeExtensionRequest.java} (52%)
rename
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/execution/http/{PipelineElementHttpRequest.java
=> PipelineElementExtensionRequest.java} (58%)
delete mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/extensions/ExtensionsResourceUrlProvider.java
delete mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/matching/GroundingSelector.java
delete mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/matching/v2/ElementVerification.java
delete mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/matching/v2/GroundingMatch.java
delete mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/matching/v2/ProtocolMatch.java
delete mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/migration/AdapterDescriptionMigration093Provider.java
rename
{streampipes-load-balancer/src/main/java/org/apache/streampipes/loadbalance =>
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager}/pipeline/ExtensionsServiceLogExecutor.java
(68%)
rename
{streampipes-connect-management/src/main/java/org/apache/streampipes/connect/management
=>
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager}/util/GroundingUtils.java
(57%)
delete mode 100644
streampipes-pipeline-management/src/test/java/org/apache/streampipes/manager/matching/v2/TestGroundingMatch.java
delete mode 100644
streampipes-pipeline-management/src/test/java/org/apache/streampipes/manager/matching/v2/TestProtocolMatch.java
delete mode 100644
streampipes-pipeline-management/src/test/java/org/apache/streampipes/manager/matching/v2/TestUtils.java
delete mode 100644
streampipes-rest-extensions/src/main/java/org/apache/streampipes/rest/extensions/WelcomePage.java
delete mode 100644
streampipes-rest-extensions/src/main/java/org/apache/streampipes/rest/extensions/html/HTMLGenerator.java
delete mode 100644
streampipes-rest-extensions/src/main/java/org/apache/streampipes/rest/extensions/html/JSONGenerator.java
delete mode 100644
streampipes-rest-extensions/src/main/java/org/apache/streampipes/rest/extensions/html/page/WelcomePageGenerator.java
delete mode 100644
streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/admin/MessagingConfigurationResource.java
delete mode 100644
streampipes-sdk/src/main/java/org/apache/streampipes/sdk/helpers/SupportedProtocols.java
copy
streampipes-commons/src/main/java/org/apache/streampipes/commons/environment/Environments.java
=>
streampipes-service-core/src/main/java/org/apache/streampipes/service/core/extensions/CoreExtensionTransportMode.java
(65%)
create mode 100644
streampipes-service-core/src/main/java/org/apache/streampipes/service/core/extensions/CoreNatsRequestReplyClient.java
create mode 100644
streampipes-service-core/src/main/java/org/apache/streampipes/service/core/extensions/ExtensionServiceRequestConfiguration.java
create mode 100644
streampipes-service-core/src/main/java/org/apache/streampipes/service/core/extensions/NatsExtensionServiceRequestManager.java
create mode 100644
streampipes-service-core/src/main/java/org/apache/streampipes/service/core/extensions/TransportAwareExtensionServiceRequestManager.java
delete mode 100644
ui/src/app/configuration/messaging-configuration/broker-config/broker-config.component.html
delete mode 100644
ui/src/app/configuration/messaging-configuration/broker-config/broker-config.component.ts
delete mode 100644
ui/src/app/configuration/messaging-configuration/messaging-configuration.component.html
delete mode 100644
ui/src/app/configuration/messaging-configuration/messaging-configuration.component.scss
delete mode 100644
ui/src/app/configuration/messaging-configuration/messaging-configuration.component.ts
