Javadoc fixes.

Author: tekul

extensions/spring-xd-extension-hdfs/src/main/java/org/springframework/data/hadoop/store/support/StreamsHolder.java

@@ -18,7 +18,6 @@
 
 import java.io.Closeable;
 import java.io.IOException;
-import java.io.InputStream;
 
 import org.springframework.util.Assert;
 
@@ -57,8 +56,8 @@ public StreamsHolder(T stream, T wrappedStream) {
 	/**
 	 * Close both streams in this holder. Possible {@code IOException} by closing wrapped stream is not thrown.
 	 * 
-	 * @see InputStream#close()
-	 * @see OutputStream#close()
+	 * @see java.io.InputStream#close()
+	 * @see java.io.OutputStream#close()
 	 */
 	@Override
 	public void close() throws IOException {

spring-xd-dirt/src/main/java/org/springframework/integration/x/bus/MessageBus.java

@@ -47,7 +47,7 @@ void bindConsumer(String name, MessageChannel moduleInputChannel, Collection<Med
 	 * Bind a message consumer on a pub/sub channel
 	 * 
 	 * @param name the logical identity of the message source
-	 * @param moduleInputChannel the channel bound as a pub/sub consumer
+	 * @param inputChannel the channel bound as a pub/sub consumer
 	 * @param acceptedMediaTypes the media types supported by the channel
 	 */
 	void bindPubSubConsumer(final String name, MessageChannel inputChannel,
@@ -67,7 +67,7 @@ void bindPubSubConsumer(final String name, MessageChannel inputChannel,
 	 * Bind a message producer on a pub/sub channel.
 	 * 
 	 * @param name the logical identity of the message target
-	 * @param moduleOutputChannel the channel bound as a producer
+	 * @param outputChannel the channel bound as a producer
 	 */
 	void bindPubSubProducer(final String name, MessageChannel outputChannel);
 
@@ -97,7 +97,7 @@ void bindPubSubConsumer(final String name, MessageChannel inputChannel,
 	 * Unbind a specific p2p or pub/sub message producer
 	 * 
 	 * @param name the logical identity of the message target
-	 * @param moduleOutputChannel the channel bound as a producer
+	 * @param channel the channel bound as a producer
 	 */
 	void unbindProducer(String name, MessageChannel channel);
 

spring-xd-dirt/src/main/java/org/springframework/integration/x/bus/serializer/AbstractCodec.java

@@ -34,7 +34,6 @@ public abstract class AbstractCodec<T> implements Serializer<T>, Deserializer<T>
 	 * Deserialize a byte array.
 	 * 
 	 * @param bytes
-	 * @return
 	 * @throws IOException
 	 */
 	public T deserialize(byte[] bytes) throws IOException {

spring-xd-dirt/src/main/java/org/springframework/xd/dirt/job/BatchJobAlreadyExistsException.java

@@ -26,9 +26,6 @@
 @SuppressWarnings("serial")
 public class BatchJobAlreadyExistsException extends XDRuntimeException {
 
-	/**
-	 * @param message exception message
-	 */
 	public BatchJobAlreadyExistsException(String name) {
 		super("Batch Job with the name " + name + " already exists");
 	}

spring-xd-dirt/src/main/java/org/springframework/xd/dirt/job/NoSuchBatchJobException.java

@@ -25,9 +25,6 @@
 @SuppressWarnings("serial")
 public class NoSuchBatchJobException extends XDRuntimeException {
 
-	/**
-	 * @param message exception message
-	 */
 	public NoSuchBatchJobException(String name) {
 		super("Batch Job with the name " + name + " doesn't exist");
 	}

spring-xd-dirt/src/main/java/org/springframework/xd/dirt/module/DelegatingModuleRegistry.java

@@ -37,10 +37,6 @@ public class DelegatingModuleRegistry implements ModuleRegistry {
 
 	private final List<ModuleRegistry> delegates = new ArrayList<ModuleRegistry>();
 
-	/**
-	 * @param cp
-	 * @param file
-	 */
 	public DelegatingModuleRegistry(ModuleRegistry... delegates) {
 		this.delegates.addAll(Arrays.asList(delegates));
 	}

spring-xd-dirt/src/main/java/org/springframework/xd/dirt/plugins/stream/ModuleTypeConversionPlugin.java

@@ -38,6 +38,7 @@
 import org.springframework.xd.dirt.plugins.ModuleConfigurationException;
 import org.springframework.xd.module.Module;
 import org.springframework.xd.module.ModuleType;
+import org.springframework.xd.module.Plugin;
 import org.springframework.xd.module.PluginAdapter;
 import org.springframework.xd.module.SimpleModule;
 

spring-xd-dirt/src/main/java/org/springframework/xd/dirt/rest/XDController.java

@@ -46,8 +46,8 @@
  * Base Class for XD Controllers.
  * 
  * @param <D> the kind of definition entity this controller deals with
- * @param <V> a resource assembler that knows how to build Ts out of Ds
- * @param <T> the resource class for D
+ * @param <A> a resource assembler that knows how to build Ts out of Ds
+ * @param <R> the resource class for D
  * 
  * @author Glenn Renfro
  * @author Ilayaperumal Gopinathan

spring-xd-dirt/src/main/java/org/springframework/xd/dirt/server/options/ContainerOptions.java

@@ -23,15 +23,10 @@
  */
 public class ContainerOptions extends AbstractOptions {
 
-	/**
-	 * @param defaultTransport
-	 * @param defaultAnalytics
-	 */
 	public ContainerOptions() {
 		super(Transport.redis, Analytics.redis);
 	}
 
-
 	@Option(name = "--" + STORE, usage = "How to persist container/modules data (default: redis)")
 	private Store store = Store.redis;
 

spring-xd-dirt/src/main/java/org/springframework/xd/dirt/server/options/OptionUtils.java

@@ -30,7 +30,6 @@ public class OptionUtils {
 	 * 
 	 * @param options - the options
 	 * @param explicit - true if explicit options are included, false otherwise
-	 * @return
 	 */
 	static Properties optionsToProperties(AbstractOptions options, boolean explicit) {
 		Properties xdProperties = new Properties();