X-Git-Url: http://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Fde%2Fjuplo%2Fkafka%2Fchat%2Fbackend%2Fimplementation%2Fkafka%2FChannel.java;fp=src%2Fmain%2Fjava%2Fde%2Fjuplo%2Fkafka%2Fchat%2Fbackend%2Fimplementation%2Fkafka%2FChannel.java;h=6ba42cc9e1c54506aa3a0ff65437b76cfb38bcc0;hb=5168b2e2a25b5890fe39ea5fba16688f81b3d3a2;hp=0000000000000000000000000000000000000000;hpb=eaec0e92a1887c6b1c0059de1b5db44039dc1dd4;p=demos%2Fkafka%2Fchat

diff --git a/src/main/java/de/juplo/kafka/chat/backend/implementation/kafka/Channel.java b/src/main/java/de/juplo/kafka/chat/backend/implementation/kafka/Channel.java
new file mode 100644
index 00000000..6ba42cc9
--- /dev/null
+++ b/src/main/java/de/juplo/kafka/chat/backend/implementation/kafka/Channel.java
@@ -0,0 +1,6 @@
+package de.juplo.kafka.chat.backend.implementation.kafka;
+
+public interface Channel extends Runnable
+{
+  ChannelState getChannelState();
+}