commit bb5350147a65bebec0c34c8fbac16a8551195498
author Christian Schneider <chris@die-schneider.net> Mon Jun 26 16:02:47 2017 +0200
committer Christian Schneider <chris@die-schneider.net> Mon Jun 26 16:02:47 2017 +0200
tree 612646f9812133a7db28225b086626c5c97f7e98
parent 69f8180f89806d8289848835bf5750fd1e67013e

Use destination instead of topic

reactortest/src/main/java/component/api/MComponent.java

diff --git a/reactortest/src/main/java/component/api/MComponent.java b/reactortest/src/main/java/component/api/MComponent.java
index 776e7a3..1a9943b 100644
--- a/reactortest/src/main/java/component/api/MComponent.java
+++ b/reactortest/src/main/java/component/api/MComponent.java
@@ -6,6 +6,6 @@
 import org.reactivestreams.Publisher;
 
 public interface MComponent<F> {
-    <T> Publisher<T> from(String topic, Function<F, T> converter) throws Exception;
-    <T> Consumer<T> to(String topic, Function<T, F> converter) throws Exception;
+    <T> Publisher<T> from(String destination, Function<F, T> converter) throws Exception;
+    <T> Consumer<T> to(String destination, Function<T, F> converter) throws Exception;
 }