public class CreateSessionStage<C extends TorrentContext> extends TerminateOnErrorProcessingStage<C>
Constructor and Description |
---|
CreateSessionStage(ProcessingStage<C> next,
TorrentRegistry torrentRegistry,
EventSource eventSource,
IConnectionSource connectionSource,
IMessageDispatcher messageDispatcher,
Set<Object> messagingAgents,
Config config) |
Modifier and Type | Method and Description |
---|---|
ProcessingEvent |
after() |
protected void |
doExecute(C context)
Perform processing.
|
doExecute
execute
public CreateSessionStage(ProcessingStage<C> next, TorrentRegistry torrentRegistry, EventSource eventSource, IConnectionSource connectionSource, IMessageDispatcher messageDispatcher, Set<Object> messagingAgents, Config config)
protected void doExecute(C context)
TerminateOnErrorProcessingStage
doExecute
in class TerminateOnErrorProcessingStage<C extends TorrentContext>
public ProcessingEvent after()
Copyright © 2016–2021. All rights reserved.