Package jetbrains.buildServer.serverSide.messages.codeDuplicates

Class DuplicatesMessageProcessor

java.lang.Object

jetbrains.buildServer.serverSide.stat.BaseMessageProcessor

jetbrains.buildServer.serverSide.messages.codeDuplicates.DuplicatesMessageProcessor

All Implemented Interfaces:

MessageProcessor

public class DuplicatesMessageProcessor
extends BaseMessageProcessor

User: anna Date: 20-Apr-2006

Field Summary

Fields

Modifier and Type	Field	Description
static GenericQuery	CLEANUP_DIFF_QUERY
static GenericQuery	CLEANUP_STATS_QUERY
static GenericQuery	INSERT_NEW_STATS_QUERY

Constructor Summary

Constructors

Constructor	Description
DuplicatesMessageProcessor(SQLRunnerEx sqlRunner, InsertDuplicatesQuery insertDuplicatesQuery, SRunningBuild build)

Method Summary

Modifier and Type	Method	Description
protected void	doProcessMessage(BuildMessage1 message)
String	getSourceId()
void	onBuildFinish()	Called when last message has been received for the build from the agent.

Methods inherited from class jetbrains.buildServer.serverSide.stat.BaseMessageProcessor

canProcess, persistState, processMessage

Methods inherited from class java.lang.Object

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

Methods inherited from interface jetbrains.buildServer.serverSide.MessageProcessor

onShutdown

Field Detail

CLEANUP_STATS_QUERY

public static final GenericQuery CLEANUP_STATS_QUERY

CLEANUP_DIFF_QUERY

public static final GenericQuery CLEANUP_DIFF_QUERY

INSERT_NEW_STATS_QUERY

public static final GenericQuery INSERT_NEW_STATS_QUERY

Constructor Detail

DuplicatesMessageProcessor

public DuplicatesMessageProcessor(@NotNull
                                  SQLRunnerEx sqlRunner,
                                  @NotNull
                                  InsertDuplicatesQuery insertDuplicatesQuery,
                                  @NotNull
                                  SRunningBuild build)

Method Detail

getSourceId

@NotNull
public String getSourceId()

Returns:

message source id to be processed by this instance of processor.

doProcessMessage

protected void doProcessMessage(BuildMessage1 message)

Specified by:

doProcessMessage in class BaseMessageProcessor

onBuildFinish

public void onBuildFinish()

Description copied from interface: MessageProcessor

Called when last message has been received for the build from the agent. Can be used to destroy state which was associated with the build.

Specified by:

onBuildFinish in interface MessageProcessor

Overrides:

onBuildFinish in class BaseMessageProcessor