Skip to content
Snippets Groups Projects
Commit 165895e6 authored by Christian Wulf's avatar Christian Wulf
Browse files

removed logging in Relay

parent 6aaa8e43
No related branches found
No related tags found
No related merge requests found
#FindBugs User Preferences #FindBugs User Preferences
#Wed Feb 04 15:13:53 CET 2015 #Mon Feb 09 10:32:26 CET 2015
detector_threshold=3 detector_threshold=3
effort=max effort=max
excludefilter0=.fbExcludeFilterFile|true excludefilter0=.fbExcludeFilterFile|true
......
...@@ -20,31 +20,16 @@ import teetime.framework.OutputPort; ...@@ -20,31 +20,16 @@ import teetime.framework.OutputPort;
public final class Relay<T> extends AbstractConsumerStage<T> { public final class Relay<T> extends AbstractConsumerStage<T> {
// private final InputPort<T> inputPort = this.createInputPort();
private final OutputPort<T> outputPort = this.createOutputPort(); private final OutputPort<T> outputPort = this.createOutputPort();
// private AbstractInterThreadPipe cachedCastedInputPipe;
@Override @Override
protected void execute(final T element) { protected void execute(final T element) {
if (null == element) { if (null == element) {
// if (this.cachedCastedInputPipe.getSignal() instanceof TerminatingSignal) {
// this.terminate();
// }
// Thread.yield();
// return;
logger.trace("relay: returnNoElement");
returnNoElement(); returnNoElement();
} }
outputPort.send(element); outputPort.send(element);
} }
// @Override
// public void onStarting() throws Exception {
// super.onStarting();
// this.cachedCastedInputPipe = (AbstractInterThreadPipe) this.inputPort.getPipe();
// }
public OutputPort<T> getOutputPort() { public OutputPort<T> getOutputPort() {
return outputPort; return outputPort;
} }
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment