You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flume.apache.org by es...@apache.org on 2011/08/26 08:17:50 UTC
svn commit: r1162002 -
/incubator/flume/branches/flume-728/flume-ng-node/src/test/java/org/apache/flume/source/TestNetcatSource.java
Author: esammer
Date: Fri Aug 26 06:17:50 2011
New Revision: 1162002
URL: http://svn.apache.org/viewvc?rev=1162002&view=rev
Log:
- Fixed configuration to be string based.
Modified:
incubator/flume/branches/flume-728/flume-ng-node/src/test/java/org/apache/flume/source/TestNetcatSource.java
Modified: incubator/flume/branches/flume-728/flume-ng-node/src/test/java/org/apache/flume/source/TestNetcatSource.java
URL: http://svn.apache.org/viewvc/incubator/flume/branches/flume-728/flume-ng-node/src/test/java/org/apache/flume/source/TestNetcatSource.java?rev=1162002&r1=1162001&r2=1162002&view=diff
==============================================================================
--- incubator/flume/branches/flume-728/flume-ng-node/src/test/java/org/apache/flume/source/TestNetcatSource.java (original)
+++ incubator/flume/branches/flume-728/flume-ng-node/src/test/java/org/apache/flume/source/TestNetcatSource.java Fri Aug 26 06:17:50 2011
@@ -40,7 +40,7 @@ public class TestNetcatSource {
/* FIXME: Use a random port for testing. */
context.put("logicalNode.name", "test");
- context.put("source.port", 41414);
+ context.put("source.port", "41414");
Configurables.configure(source, context);
@@ -90,9 +90,6 @@ public class TestNetcatSource {
public void testDurability() throws InterruptedException, LifecycleException,
EventDeliveryException, IOException {
- /* FIXME: Use a random port for testing. */
- ((NetcatSource) source).setPort(41414);
-
FileBasedWALManager walManager = new FileBasedWALManager();
walManager.setDirectory(new File("/tmp/flume-ncs-tests", "wal-test"));
@@ -104,7 +101,7 @@ public class TestNetcatSource {
Context context = new Context();
context.put("logicalNode.name", "test");
- context.put("source.port", 41414);
+ context.put("source.port", "41414");
Configurables.configure(source, context);