Package dk.netarkivet.harvester.distribute

Class HarvesterChannels

java.lang.Object

dk.netarkivet.harvester.distribute.HarvesterChannels

public class HarvesterChannels
extends Object

This singleton class is in charge of giving out the correct channels.

Field Summary

Fields

Modifier and Type	Field	Description
ChannelID	THE_SCHED

Constructor Summary

Constructors

Constructor	Description
HarvesterChannels()

Method Summary

Modifier and Type	Method	Description
static ChannelID	getHarvesterRegistrationRequestChannel()	Return the queue for sending HarvesterRegistrationRequests.
static ChannelID	getHarvesterRegistrationResponseChannel()	Return the queue for sending HarvesterRegistrationResponse s.
static ChannelID	getHarvesterStatusChannel()
static ChannelID	getHarvestJobChannelId(HarvestChannel harvestChannel)	Returns the queue which is used by the scheduler to send doOneCrawl to Harvest Controllers listening on the given harvest channel.
static ChannelID	getHarvestJobChannelId(String harvestChannelName, boolean isSnapshot)	Returns the queue which is used by the scheduler to send doOneCrawl to Harvest Controllers listening on the given harvest channel.
static ChannelID	getHarvestMonitorChannel()	Return the queue for the harvest monitor registry.
static ChannelID	getTheSched()

Methods inherited from class java.lang.Object

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

Field Detail

THE_SCHED

public final ChannelID THE_SCHED

Constructor Detail

HarvesterChannels

public HarvesterChannels()

Method Detail

getTheSched

public static ChannelID getTheSched()

Returns:

the ChannelID for the queue on which HarvestControllers send harvest status messages

getHarvestMonitorChannel

public static ChannelID getHarvestMonitorChannel()

Return the queue for the harvest monitor registry.

Returns:

the ChannelID object for the queue.

getHarvesterStatusChannel

public static ChannelID getHarvesterStatusChannel()

Returns:

the ChannelID object for the topic used by the harvesters to call in ready for new jobs.

getHarvesterRegistrationRequestChannel

public static ChannelID getHarvesterRegistrationRequestChannel()

Return the queue for sending HarvesterRegistrationRequests.

Returns:

the ChannelID object for the queue.

getHarvesterRegistrationResponseChannel

public static ChannelID getHarvesterRegistrationResponseChannel()

Return the queue for sending HarvesterRegistrationResponse s.

Returns:

the ChannelID object for the queue.

getHarvestJobChannelId

public static ChannelID getHarvestJobChannelId(HarvestChannel harvestChannel)

Returns the queue which is used by the scheduler to send doOneCrawl to Harvest Controllers listening on the given harvest channel.

Parameters:

harvestChannel -

Returns:

That channel (queue)

getHarvestJobChannelId

public static ChannelID getHarvestJobChannelId(String harvestChannelName,
                                               boolean isSnapshot)

Returns the queue which is used by the scheduler to send doOneCrawl to Harvest Controllers listening on the given harvest channel.

Parameters:

harvestChannelName -

isSnapshot -

Returns:

That channel (queue)