This is an automated email from the ASF dual-hosted git repository.
riemer pushed a change to branch add-broker-communication-mode
in repository https://gitbox.apache.org/repos/asf/streampipes.git
from d2d2146180 feat: Add initial version of broker communication mode
add 5ab0c8e79f Refactor request receiver, support pipeline elements
No new revisions were added by this update.
Summary of changes:
.../ExtensionServicePipelineDetachRequest.java} | 32 ++--
.../AdapterStateChangeOperationHandler.java | 91 ++++++++++++
.../ExtensionBrokerOperationHandler.java | 18 +--
.../extensions/ExtensionBrokerRequestContext.java | 7 +-
.../extensions/ExtensionBrokerRequestReceiver.java | 163 +++++++++------------
.../operation/ExtensionBrokerResponseFactory.java | 60 ++++++++
.../operation/ExtensionBrokerTopicParser.java | 70 +++++++++
.../PipelineElementDetachOperationHandler.java | 119 +++++++++++++++
.../PipelineElementInvocationOperationHandler.java | 120 +++++++++++++++
.../operation/ServiceLoadOperationHandler.java | 53 +++++++
.../core/ExtensionServiceRequestConfiguration.java | 25 +++-
.../NatsExtensionServiceRequestManager.java | 134 +++++++++++++++++
...ansportAwareExtensionServiceRequestManager.java | 79 ++--------
13 files changed, 769 insertions(+), 202 deletions(-)
copy
streampipes-model/src/main/java/org/apache/streampipes/model/{pipeline/PipelineElementRecommendation.java
=> extensions/transport/ExtensionServicePipelineDetachRequest.java} (63%)
create mode 100644
streampipes-nats-extensions/src/main/java/org/apache/streampipes/nats/extensions/AdapterStateChangeOperationHandler.java
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-client/src/main/java/org/apache/streampipes/client/paths/ApiPath.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/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/PipelineElementDetachOperationHandler.java
create mode 100644
streampipes-nats-extensions/src/main/java/org/apache/streampipes/nats/extensions/operation/PipelineElementInvocationOperationHandler.java
create mode 100644
streampipes-nats-extensions/src/main/java/org/apache/streampipes/nats/extensions/operation/ServiceLoadOperationHandler.java
create mode 100644
streampipes-service-core/src/main/java/org/apache/streampipes/service/core/extensions/NatsExtensionServiceRequestManager.java
