|
||||||||||
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.
Field Summary | |
---|---|
static java.lang.String |
CHANNEL_PART_SEPARATOR
Channel part separator. |
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 (replica). |
static ChannelID |
getAllBa()
Returns the topic that all bitarchive machines on this replica are listening on. |
static ChannelID |
getAnyBa()
Returns the channel where exactly one of all the bitarchive machines at this replica 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 |
getBaMonForReplica(java.lang.String replicaId)
Given an replica, returns the BAMON queue to which batch jobs must be sent in order to run them on that bitarchive. |
static ChannelID |
getError()
Returns the queue on which to put errors which are not handled elsewhere. |
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 |
getTheMonitorServer()
Return the queue for the monitor registry. |
static ChannelID |
getTheRepos()
Returns the queue on which all messages to the Repository are sent. |
static ChannelID |
getTheSched()
Returns the queue on which HarvestControllers reply with status messages to the HarvestScheduler. |
static ChannelID |
getThisIndexClient()
Returns the queue for getting responses from the IndexServer application. |
static ChannelID |
getThisReposClient()
Returns the one-per-client queue on which client receives replies from the arcrepository. |
static boolean |
isTopic(java.lang.String name)
Is a given name a ChannelName for a Topic or a Queue. |
(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 |
Field Detail |
---|
public static final java.lang.String CHANNEL_PART_SEPARATOR
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 getThisReposClient()
ChannelID
object for this queue.public static ChannelID getTheRepos()
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 getBaMonForReplica(java.lang.String replicaId) throws ArgumentNotValid
replicaId
- The id of the replica
ArgumentNotValid
- if the replicaId is null, unknown, or empty stringpublic static ChannelID getTheIndexServer()
ChannelID
object for this queue.public static ChannelID getThisIndexClient()
ChannelID
object for this queue.public static ChannelID getTheMonitorServer()
ChannelID
object for the queue.static void reset()
public static boolean isTopic(java.lang.String name)
name
- a given name
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |