bt.processor.torrent

Class ProcessTorrentStage<C extends TorrentContext>

java.lang.Object

bt.processor.RoutingProcessingStage<C>

bt.processor.TerminateOnErrorProcessingStage<C>

bt.processor.torrent.ProcessTorrentStage<C>

All Implemented Interfaces:

ProcessingStage<C>

Direct Known Subclasses:

ProcessMagnetTorrentStage

public class ProcessTorrentStage<C extends TorrentContext>
extends TerminateOnErrorProcessingStage<C>

Constructor Summary

Constructors

Constructor and Description
ProcessTorrentStage(ProcessingStage<C> next, TorrentRegistry torrentRegistry, IPeerRegistry peerRegistry, ITrackerService trackerService, EventSink eventSink)

Method Summary

Modifier and Type	Method and Description
ProcessingEvent	after()
protected void	doExecute(C context) Perform processing.
protected void	onCompleted(C context)

Methods inherited from class bt.processor.TerminateOnErrorProcessingStage

doExecute

Methods inherited from class bt.processor.RoutingProcessingStage

execute

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ProcessTorrentStage

public ProcessTorrentStage(ProcessingStage<C> next,
                           TorrentRegistry torrentRegistry,
                           IPeerRegistry peerRegistry,
                           ITrackerService trackerService,
                           EventSink eventSink)

Method Detail

doExecute

protected void doExecute(C context)
                  throws InterruptedException

Description copied from class: TerminateOnErrorProcessingStage

Perform processing. Implementations are free to throw exceptions, in which case the processing chain will be terminated.

Specified by:

doExecute in class TerminateOnErrorProcessingStage<C extends TorrentContext>

Throws:

InterruptedException

onCompleted

protected void onCompleted(C context)

after

public ProcessingEvent after()

Returns:

Type of event, that should be triggered after this stage has completed.