dk.netarkivet.harvester.distribute
Class HarvesterChannels

java.lang.Object
  extended by dk.netarkivet.harvester.distribute.HarvesterChannels

public class HarvesterChannels
extends java.lang.Object

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


Constructor Summary
HarvesterChannels()
           
 
Method Summary
static ChannelID getHarvesterRegistrationRequestChannel()
          Return the queue for sending HarvesterRegistrationRequests.
static ChannelID getHarvesterRegistrationResponseChannel()
          Return the queue for sending HarvesterRegistrationResponses.
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(java.lang.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.
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

HarvesterChannels

public HarvesterChannels()
Method Detail

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 HarvesterRegistrationResponses.

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.

Returns:
That channel (queue)

getHarvestJobChannelId

public static ChannelID getHarvestJobChannelId(java.lang.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.

Returns:
That channel (queue)