Commit c5ff965c authored by Constantin Pohl's avatar Constantin Pohl
Browse files

minor fixes

parent 58d6a998
......@@ -3,7 +3,7 @@
There already exist ZeroMQ and REST as network sources, providing tuples via network connection.
In addition, the AMQP (Advanced Message Queuing Protocol) used by RabbitMQ as well as the Apache
Kafka protocol can be used as source. However, there are additional libraries/installs necessary to
run the protocol which are not delivered in PipeFabric per default.
run the protocols which are not delivered in PipeFabric per default.
## RabbitMQ ##
......@@ -45,6 +45,9 @@ If yes, all the messages are gathered and sent downstreams to the subscribers (t
following operator(s)). Then it finishes. However, it can be easily adapted to stay waiting,
repeatedly asking the server if new messages have arrived.
There is an example (test case) provided how to use it properly which can be found in
`/test/RabbitMQSourceTest.cpp` of the source folder.
## Apache Kafka ##
### Preliminaries and Installation ###
......@@ -103,3 +106,6 @@ If yes, all the messages are consecutively gathered and sent downstreams to the
means, the following operator(s)). Then it finishes. However, it can be easily adapted to stay
waiting, repeatedly asking the server if new messages have arrived.
There is an example (test case) provided how to use it properly which can be found in
`/test/KafkaSourceTest.cpp` of the source folder.
......@@ -47,7 +47,6 @@ TEST_CASE("Producing and receiving tuples via Apache Kafka protocol", "[Kafka]")
auto s = t->newStreamFromKafka("127.0.0.1:9092", "PipeFabric", grp)
.extract<InTuplePtr>(',')
.print()
.notify([&resCntr](auto tp, bool outdated) { resCntr++; })
;
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment