package com.stratio.streaming.commons.constants;

public interface STREAMING {
	public static final int    DURATION_MS				= 2000;
	public static final String ZK_BASE_PATH				= "/stratio/streaming";
	public static final String STREAM_STATUS_MAP 		= "stratio_stream_map";
	public static final String INTERNAL_LISTEN_TOPIC 	= "stratio_listen"; 
	public static final String ZK_EPHEMERAL_NODE_PATH			= "/stratio/streaming/engine";



}

@@ -118,16 +118,18 @@
 N_MS%09%09%09%09
+%09%09
 = 2000;%0D
@@ -173,16 +173,18 @@
 PATH%09%09%09%09
+%09%09
 = %22/stra
@@ -248,16 +248,18 @@
 S_MAP %09%09
+%09%09
 = %22strat
@@ -326,16 +326,18 @@
 _TOPIC %09
+%09%09
 = %22strat
@@ -347,17 +347,104 @@
 listen%22;
- 
+%0D%0A%09public static final String INTERNAL_SAVE2CASSANDRA_TOPIC %09= %22stratio_save2cassandra%22;
 %0D%0A%09publi

ADD SAVE2CASSANDRA TOPIC