|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectdk.netarkivet.common.distribute.Channels
public class Channels
This singleton class is in charge of giving out the correct channels.
Method Summary | |
---|---|
static ChannelID[] |
getAllArchives_ALL_BAs()
Returns ALL_BA channels for every known bitarchive. |
static ChannelID[] |
getAllArchives_ANY_BAs()
Returns ANY_BA channels for every known bitarchive. |
static ChannelID[] |
getAllArchives_BAMONs()
Returns BAMON channels for every known bitarchive (location). |
static ChannelID |
getAllBa()
Returns the topic that all bitarchive machines on this location are listening on. |
static ChannelID |
getAnyBa()
Returns the channel where exactly one of all the bitarchive machines at this location will get the message. |
static ChannelID |
getAnyHighpriorityHaco()
Returns the queue which is used by the scheduler to send doOneCrawl to Harvest Controllers of high priority (selective harvests). |
static ChannelID |
getAnyLowpriorityHaco()
Returns the queue which is used by the scheduler to send doOneCrawl to Harvest Controllers of low priority (snapshot harvests). |
static ChannelID |
getBaMonForLocation(java.lang.String location)
Given an location, returns the BAMON queue to which batch jobs must be sent in order to run them on that locations bitarchive. |
static ChannelID |
getError()
Returns the queue on which to put errors which are not handled elsewhere. |
static ChannelID |
getTheArcrepos()
Returns the queue on which all messages to the ArcRepository are sent. |
static ChannelID |
getTheBamon()
Returns the queue for sending messages to bitarchive monitors. |
static ChannelID |
getTheIndexServer()
Returns the queue for sending messages to the IndexServer application. |
static ChannelID |
getTheSched()
Returns the queue on which HarvestControllers reply with status messages to the HarvestScheduler. |
static ChannelID |
getThisHaco()
Returns the one-per-HACO queue on which HaCo receives replies from the arcrepository. |
static ChannelID |
getThisIndexClient()
Returns the queue for getting responses from the IndexServer application. |
(package private) static void |
reset()
Reset the instance to re-read the settings. |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Method Detail |
---|
public static ChannelID getTheSched()
ChannelID
object for the queue on which
HarvestControllers reply with status messages to the
HarvestSchedulerpublic static ChannelID getAnyHighpriorityHaco()
public static ChannelID getAnyLowpriorityHaco()
public static ChannelID getThisHaco()
ChannelID
object for this queue.public static ChannelID getTheArcrepos()
ChannelID
object for this queue.public static final ChannelID[] getAllArchives_BAMONs()
public static ChannelID getTheBamon()
ChannelID
object for this queue.public static final ChannelID[] getAllArchives_ALL_BAs()
public static ChannelID getAllBa()
public static final ChannelID[] getAllArchives_ANY_BAs()
public static ChannelID getAnyBa()
public static ChannelID getError()
ChannelID
object for this queue.public static ChannelID getBaMonForLocation(java.lang.String location) throws ArgumentNotValid
location
- the location
ArgumentNotValid
- if the location is null, unknown, or empty stringpublic static ChannelID getTheIndexServer()
ChannelID
object for this queue.public static ChannelID getThisIndexClient()
ChannelID
object for this queue.static void reset()
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |