summaryrefslogtreecommitdiffstats
path: root/tests/pipelinetest.cpp
diff options
context:
space:
mode:
authorChristian Mollekopf <chrigi_1@fastmail.fm>2016-12-22 22:05:40 +0100
committerChristian Mollekopf <chrigi_1@fastmail.fm>2016-12-22 22:05:40 +0100
commit6b1cf550608c2f17cbed9e375f15a4c14bfe8ace (patch)
tree2e693a731bb2e9ce1a793b14cef98cdc13e382cd /tests/pipelinetest.cpp
parentb2ad8f785e801a35cadf254d827f56d648be510c (diff)
downloadsink-6b1cf550608c2f17cbed9e375f15a4c14bfe8ace.tar.gz
sink-6b1cf550608c2f17cbed9e375f15a4c14bfe8ace.zip
More Log::Context
Diffstat (limited to 'tests/pipelinetest.cpp')
-rw-r--r--tests/pipelinetest.cpp10
1 files changed, 5 insertions, 5 deletions
diff --git a/tests/pipelinetest.cpp b/tests/pipelinetest.cpp
index e68aa53..0268ec5 100644
--- a/tests/pipelinetest.cpp
+++ b/tests/pipelinetest.cpp
@@ -213,7 +213,7 @@ private slots:
213 flatbuffers::FlatBufferBuilder entityFbb; 213 flatbuffers::FlatBufferBuilder entityFbb;
214 auto command = createEntityCommand(createEvent(entityFbb)); 214 auto command = createEntityCommand(createEvent(entityFbb));
215 215
216 Sink::Pipeline pipeline(getContext()); 216 Sink::Pipeline pipeline(getContext(), {"test"});
217 217
218 pipeline.startTransaction(); 218 pipeline.startTransaction();
219 pipeline.newEntity(command.constData(), command.size()); 219 pipeline.newEntity(command.constData(), command.size());
@@ -236,7 +236,7 @@ private slots:
236 flatbuffers::FlatBufferBuilder entityFbb; 236 flatbuffers::FlatBufferBuilder entityFbb;
237 auto command = createEntityCommand(createEvent(entityFbb, "summary", "description")); 237 auto command = createEntityCommand(createEvent(entityFbb, "summary", "description"));
238 238
239 Sink::Pipeline pipeline(getContext()); 239 Sink::Pipeline pipeline(getContext(), {"test"});
240 240
241 auto adaptorFactory = QSharedPointer<TestEventAdaptorFactory>::create(); 241 auto adaptorFactory = QSharedPointer<TestEventAdaptorFactory>::create();
242 242
@@ -282,7 +282,7 @@ private slots:
282 flatbuffers::FlatBufferBuilder entityFbb; 282 flatbuffers::FlatBufferBuilder entityFbb;
283 auto command = createEntityCommand(createEvent(entityFbb)); 283 auto command = createEntityCommand(createEvent(entityFbb));
284 284
285 Sink::Pipeline pipeline(getContext()); 285 Sink::Pipeline pipeline(getContext(), {"test"});
286 286
287 auto adaptorFactory = QSharedPointer<TestEventAdaptorFactory>::create(); 287 auto adaptorFactory = QSharedPointer<TestEventAdaptorFactory>::create();
288 288
@@ -325,7 +325,7 @@ private slots:
325 { 325 {
326 flatbuffers::FlatBufferBuilder entityFbb; 326 flatbuffers::FlatBufferBuilder entityFbb;
327 auto command = createEntityCommand(createEvent(entityFbb)); 327 auto command = createEntityCommand(createEvent(entityFbb));
328 Sink::Pipeline pipeline(getContext()); 328 Sink::Pipeline pipeline(getContext(), {"test"});
329 329
330 // Create the initial revision 330 // Create the initial revision
331 pipeline.startTransaction(); 331 pipeline.startTransaction();
@@ -359,7 +359,7 @@ private slots:
359 359
360 auto testProcessor = new TestProcessor; 360 auto testProcessor = new TestProcessor;
361 361
362 Sink::Pipeline pipeline(getContext()); 362 Sink::Pipeline pipeline(getContext(), {"test"});
363 pipeline.setPreprocessors("event", QVector<Sink::Preprocessor *>() << testProcessor); 363 pipeline.setPreprocessors("event", QVector<Sink::Preprocessor *>() << testProcessor);
364 pipeline.startTransaction(); 364 pipeline.startTransaction();
365 // pipeline.setAdaptorFactory("event", QSharedPointer<TestEventAdaptorFactory>::create()); 365 // pipeline.setAdaptorFactory("event", QSharedPointer<TestEventAdaptorFactory>::create());