You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@streampipes.apache.org by ri...@apache.org on 2022/11/18 15:44:26 UTC

[streampipes] branch dev updated (52b3e5ea6 -> 327d01e2b)

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 52b3e5ea6 Merge pull request #141 from apache/STREAMPIPES-633
     new 861ca23f2 [STREAMPIPES-625] Refactor the Pulsar Protocol Adapter
     new 7c08bf5d1 [STREAMPIPES-625] Merge master
     new 327d01e2b Merge pull request #144 from RobertIndie/add-sub

The 9344 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails.  The revisions
listed as "add" were already present in the repository and have only
been added to this reference.


Summary of changes:
 .../protocol/stream/pulsar/PulsarConsumer.java     | 85 ----------------------
 .../protocol/stream/pulsar/PulsarProtocol.java     | 67 +++++++++++------
 .../integration/adapters/PulsarAdapterTester.java  |  2 +
 3 files changed, 48 insertions(+), 106 deletions(-)
 delete mode 100644 streampipes-extensions/streampipes-connect-adapters-iiot/src/main/java/org/apache/streampipes/connect/iiot/protocol/stream/pulsar/PulsarConsumer.java