This is an automated email from the ASF dual-hosted git repository.
zike pushed a change to branch dev
in repository https://gitbox.apache.org/repos/asf/streampipes.git
from e85c398d7 Bump black from 23.3.0 to 23.7.0 in
/streampipes-client-python (#1764)
add 04200fce5 Support pulsar messasging layer (#1576)
No new revisions were added by this update.
Summary of changes:
.../archetype-resources/src/main/java/Init.java | 4 +-
.../src/main/resources/archetype-resources/pom.xml | 2 +-
.../archetype-resources/src/main/java/Init.java | 4 +-
.../src/main/resources/archetype-resources/pom.xml | 2 +-
.../archetype-resources/src/main/java/Init.java | 4 +-
installer/cli/.env | 4 +-
.../{swagger-ui => pulsar}/docker-compose.dev.yml | 5 +-
.../deploy/standalone/pulsar/docker-compose.yml | 113 +++++++++++++++++++++
.../environments/{backend-nats => backend-pulsar} | 4 +-
.../cli/environments/{basic-nats => basic-pulsar} | 4 +-
.../cli/environments/{minimal => lite-pulsar} | 4 +-
.../{minimal => pipeline-element-pulsar} | 9 +-
...-compose.nats.yml => docker-compose.pulsar.yml} | 9 +-
pom.xml | 1 +
.../streampipes/config/backend/BackendConfig.java | 7 +-
.../config/backend/BackendConfigKeys.java | 1 +
.../config/backend/DefaultMessagingSettings.java | 22 ++--
.../connect/management/util/GroundingUtils.java | 14 +++
.../export/utils/EventGroundingProcessor.java | 14 ++-
streampipes-extensions-management/pom.xml | 5 +
.../connect/adapter/AdapterPipelineGenerator.java | 4 +
...apterSink.java => SendToPulsarAdapterSink.java} | 18 ++--
.../extensions/all/iiot/AllExtensionsIIoTInit.java | 4 +-
.../extensions/all/jvm/AllExtensionsInit.java | 4 +-
.../pom.xml | 10 +-
.../messaging/pulsar/PulsarConsumer.java | 86 ++++++++++++++++
.../messaging/pulsar/PulsarProducer.java | 78 ++++++++++++++
.../messaging/pulsar/SpPulsarProtocol.java | 26 +++--
.../messaging/pulsar/SpPulsarProtocolFactory.java | 14 +--
.../streampipes/model/config/SpProtocol.java | 3 +-
...efinition.java => PulsarTransportProtocol.java} | 20 ++--
.../model/grounding/TransportProtocol.java | 3 +-
.../org/apache/streampipes/model/util/Cloner.java | 3 +
.../manager/matching/ProtocolSelector.java | 6 ++
.../runtime/PipelineElementRuntimeInfoFetcher.java | 18 ++++
.../sdk/helpers/SupportedProtocols.java | 5 +
ui/cypress/tests/thirdparty/Kafka.smoke.spec.ts | 2 +-
.../src/lib/model/gen/streampipes-model.ts | 24 ++++-
38 files changed, 485 insertions(+), 75 deletions(-)
copy installer/cli/deploy/standalone/{swagger-ui =>
pulsar}/docker-compose.dev.yml (88%)
create mode 100644 installer/cli/deploy/standalone/pulsar/docker-compose.yml
copy installer/cli/environments/{backend-nats => backend-pulsar} (95%)
copy installer/cli/environments/{basic-nats => basic-pulsar} (95%)
copy installer/cli/environments/{minimal => lite-pulsar} (96%)
copy installer/cli/environments/{minimal => pipeline-element-pulsar} (93%)
copy installer/compose/{docker-compose.nats.yml => docker-compose.pulsar.yml}
(96%)
copy
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect/adapter/preprocessing/elements/{SendToNatsAdapterSink.java
=> SendToPulsarAdapterSink.java} (66%)
copy {streampipes-messaging-nats => streampipes-messaging-pulsar}/pom.xml (84%)
create mode 100644
streampipes-messaging-pulsar/src/main/java/org/apache/streampipes/messaging/pulsar/PulsarConsumer.java
create mode 100644
streampipes-messaging-pulsar/src/main/java/org/apache/streampipes/messaging/pulsar/PulsarProducer.java
copy
streampipes-messaging-jms/src/main/java/org/apache/streampipes/messaging/jms/SpJmsProtocol.java
=>
streampipes-messaging-pulsar/src/main/java/org/apache/streampipes/messaging/pulsar/SpPulsarProtocol.java
(57%)
copy
streampipes-messaging-jms/src/main/java/org/apache/streampipes/messaging/jms/SpJmsProtocolFactory.java
=>
streampipes-messaging-pulsar/src/main/java/org/apache/streampipes/messaging/pulsar/SpPulsarProtocolFactory.java
(72%)
copy
streampipes-model/src/main/java/org/apache/streampipes/model/grounding/{SimpleTopicDefinition.java
=> PulsarTransportProtocol.java} (66%)
