Code cleanup & port change for source & sink examples

spring-cloud-stream-samples/source/README.md

@@ -0,0 +1,37 @@
+Spring Cloud Streams Source Sample
+=============================
+
+In this sample for *Spring Cloud Streams* we will post a timestamp to the stream on an interval determined by the fixedDelay configuration.
+
+## Requirements
+
+In order for the sample to run you will need to have installed:
+
+* Java 7 or Above
+
+## Code Tour
+
+This sample is a Spring Boot application that uses Spring Cloud Streams to send time stamp data to a stream. The source module has 3 primary components
+
+* SourceApplication - in which is the Spring Boot Main Application
+* TimeSource - the module that will generate the timestamp and post the message to the stream
+* TimeSourceOptionsMetadata - defines the configurations that are available to setup the TimeSource
+    	 * format - how to render the current time, using SimpleDateFormat
+    	 * fixedDelay - time delay between messages, expressed in TimeUnits (seconds by default)
+    	 * initialDelay - an initial delay when using a fixed delay trigger, expressed in TimeUnits (seconds by default)
+    	 * timeUnit - the time unit for the fixed and initial delays
+    	 * maxMessages - the maximum messages per poll; -1 for unlimited
+
+## Building with Maven
+
+Build the sample simply by executing:
+
+	source>$ mvn clean package
+
+## Running the Sample
+
+This example requires a local instance of Redis to be up an running.
+To start the source module execute the following:
+
+	source>$ java -jar target/spring-cloud-streams-sample-source-1.0.0.BUILD-SNAPSHOT-exec.jar
+

spring-cloud-stream-samples/source/src/main/java/source/TimeSource.java

@@ -16,24 +16,23 @@
 
 package source;
 
-import java.text.SimpleDateFormat;
-import java.util.Date;
-
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.boot.context.properties.EnableConfigurationProperties;
 import org.springframework.cloud.stream.annotation.EnableModule;
 import org.springframework.cloud.stream.annotation.Output;
 import org.springframework.context.annotation.Bean;
-import org.springframework.context.annotation.Configuration;
 import org.springframework.integration.annotation.InboundChannelAdapter;
 import org.springframework.integration.annotation.Poller;
-import org.springframework.integration.channel.DirectChannel;
 import org.springframework.integration.core.MessageSource;
 import org.springframework.messaging.MessageChannel;
 import org.springframework.messaging.support.GenericMessage;
 
+import java.text.SimpleDateFormat;
+import java.util.Date;
+
 /**
  * @author Dave Syer
+ * @author Glenn Renfro
  *
  */
 @EnableModule

spring-cloud-stream-samples/source/src/main/resources/application.yml

@@ -1,5 +1,5 @@
 server:
-  port: 8081
+  port: 8080
 fixedDelay: 5000
 spring:
   cloud: