You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@streampipes.apache.org by ze...@apache.org on 2023/04/01 06:11:43 UTC
[streampipes] branch remove-set-adapters updated (9617649db -> 3fc2d63f7)
This is an automated email from the ASF dual-hosted git repository.
zehnder pushed a change to branch remove-set-adapters
in repository https://gitbox.apache.org/repos/asf/streampipes.git
from 9617649db [#1289] Started to migrate the API
add 3fc2d63f7 [#1289] Deactivate old protocol API
No new revisions were added by this update.
Summary of changes:
.../simulator/machine/v2/FileReplayAdapter.java | 35 +-
.../machine/v2/NewMachineDataSimulatorAdapter.java | 26 +-
.../iiot/protocol/stream/FileStreamProtocol.java | 577 ++++++++++-----------
.../iiot/protocol/stream/HttpServerProtocol.java | 271 +++++-----
.../iiot/protocol/stream/HttpStreamProtocol.java | 229 ++++----
.../iiot/protocol/stream/KafkaProtocol.java | 472 ++++++++---------
.../connect/iiot/protocol/stream/MqttProtocol.java | 183 +++----
.../connect/iiot/protocol/stream/NatsProtocol.java | 300 +++++------
.../iiot/protocol/stream/TubeMQProtocol.java | 346 ++++++------
.../protocol/stream/pulsar/PulsarProtocol.java | 291 +++++------
.../protocol/stream/rocketmq/RocketMQProtocol.java | 282 +++++-----
.../builder/adapter/AdapterDescriptionBuilder.java | 28 +-
.../adapter/ProtocolDescriptionBuilder.java | 83 ---
.../streampipes/sdk/helpers/AdapterSourceType.java | 33 --
14 files changed, 1371 insertions(+), 1785 deletions(-)
delete mode 100644 streampipes-sdk/src/main/java/org/apache/streampipes/sdk/builder/adapter/ProtocolDescriptionBuilder.java
delete mode 100644 streampipes-sdk/src/main/java/org/apache/streampipes/sdk/helpers/AdapterSourceType.java