svn commit: r1560190 - in /incubator/streams/trunk/streams-core/src/main/java/org/apache/streams/core: StreamHandler.java StreamState.java

[sb...@apache.org]

Author: sblackmon
Date: Tue Jan 21 21:14:24 2014
New Revision: 1560190

URL: http://svn.apache.org/r1560190
Log:
Switched from Serializable to Object as core document

Added:
    incubator/streams/trunk/streams-core/src/main/java/org/apache/streams/core/StreamHandler.java
    incubator/streams/trunk/streams-core/src/main/java/org/apache/streams/core/StreamState.java

Added: incubator/streams/trunk/streams-core/src/main/java/org/apache/streams/core/StreamHandler.java
URL: http://svn.apache.org/viewvc/incubator/streams/trunk/streams-core/src/main/java/org/apache/streams/core/StreamHandler.java?rev=1560190&view=auto
==============================================================================
--- incubator/streams/trunk/streams-core/src/main/java/org/apache/streams/core/StreamHandler.java (added)
+++ incubator/streams/trunk/streams-core/src/main/java/org/apache/streams/core/StreamHandler.java Tue Jan 21 21:14:24 2014
@@ -0,0 +1,22 @@
+package org.apache.streams.core;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+/**
+ * Created by sblackmon on 1/6/14.
+ */
+public class StreamHandler {
+
+    private static final Logger LOGGER = LoggerFactory.getLogger(StreamHandler.class);
+
+    private volatile StreamState state;
+
+    public void setState(StreamState state) {
+        this.state = state;
+    }
+
+    public StreamState getState() {
+        return this.state;
+    }
+}

Added: incubator/streams/trunk/streams-core/src/main/java/org/apache/streams/core/StreamState.java
URL: http://svn.apache.org/viewvc/incubator/streams/trunk/streams-core/src/main/java/org/apache/streams/core/StreamState.java?rev=1560190&view=auto
==============================================================================
--- incubator/streams/trunk/streams-core/src/main/java/org/apache/streams/core/StreamState.java (added)
+++ incubator/streams/trunk/streams-core/src/main/java/org/apache/streams/core/StreamState.java Tue Jan 21 21:14:24 2014
@@ -0,0 +1,13 @@
+package org.apache.streams.core;
+
+/**
+ * Created by sblackmon on 1/6/14.
+ */
+public enum StreamState {
+    RUNNING,  //Stream is currently connected and running
+    STOPPED,  // Stream has been shut down and is stopped
+    CONNECTING, //Stream is attempting to connect to server
+    SHUTTING_DOWN, //Stream has initialized shutdown
+    DISCONNECTED //Stream has unintentionally lost connection
+}
+