package com.cloudera.flume.collector;
import static org.junit.Assert.fail;
import java.io.IOException;
import org.junit.Test;
import com.cloudera.flume.conf.Context;
import com.cloudera.flume.conf.FlumeBuilder;
import com.cloudera.flume.conf.FlumeSpecException;
import com.cloudera.flume.core.EventImpl;
import com.cloudera.flume.core.EventSink;
import com.cloudera.flume.core.EventSource;
@Test
String src = "collectorSource";
FlumeBuilder.buildSource(src);
String src2 = "collectorSource(5150)";
FlumeBuilder.buildSource(src2);
try {
FlumeBuilder.buildSource("collectorSource(99, \"red luftballoons\")");
} catch (Exception e) {
return;
}
fail("should have caught aproblem");
}
@Test
EventSource src = FlumeBuilder.buildSource("collectorSource(34568)");
EventSink snk = FlumeBuilder.buildSink(new Context(),
"rpcSink(\"localhost\", 34568)");
src.open();
snk.open();
snk.append(new EventImpl("foo".getBytes()));
src.next();
snk.close();
src.close();
}
}