Modifier and Type | Field and Description |
---|---|
static String |
CHANNEL_PART_SEPARATOR
Channel part separator.
|
Modifier and Type | Method and Description |
---|---|
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[] |
getAllArchives_CRs()
Returns the channels for the all Checksum replicas.
|
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 |
getBaMonForReplica(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 Collection<Replica> |
getReplicas()
Method for retrieving the list of replicas used for the channels.
|
static ChannelID |
getTheBamon()
Returns the queue for sending messages to bitarchive monitors.
|
static ChannelID |
getTheCR()
Method for retrieving the 'THE_CR' channel for this replica.
|
static ChannelID |
getTheCrForReplica(String replicaId) |
static ChannelID |
getTheIndexServer()
Returns the queue for sending messages to the IndexServer application.
|
static ChannelID |
getTheMonitorServer()
Return the topic for the monitor registry.
|
static ChannelID |
getTheRepos()
Returns the queue on which all messages to the Repository are sent.
|
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(String name)
Is a given name a ChannelName for a Topic or a Queue.
|
static void |
reset()
Reset the instance to re-read the settings.
|
static ChannelID |
retrieveReplicaChannelFromReplicaId(String replicaId)
The method for retrieving the identification channel for a replica based on the Id of this replica.
|
static String |
retrieveReplicaChannelNameFromReplicaId(String replicaId)
The method for retrieving the name of the identification channel for a replica based on the Id of this replica.
|
static Replica |
retrieveReplicaFromIdentifierChannel(String channelName)
Method for extracting the replica from the name of the identifier channel.
|
public static final String CHANNEL_PART_SEPARATOR
public static Collection<Replica> getReplicas()
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() throws IllegalState
ChannelID
object for this queue.IllegalState
- If the current replica is not a checksum replica.public static final ChannelID[] getAllArchives_CRs()
public static ChannelID getTheCR() throws IllegalState
IllegalState
- If the current replica is not a checksum replica.public static final ChannelID[] getAllArchives_ALL_BAs()
public static ChannelID getAllBa() throws IllegalState
IllegalState
- If the current replica is not a bitarchive replica.public static final ChannelID[] getAllArchives_ANY_BAs()
public static ChannelID getAnyBa() throws IllegalState
IllegalState
- If the current replica is not a bitarchive replica.public static ChannelID getError()
ChannelID
object for this queue.public static ChannelID getBaMonForReplica(String replicaId) throws ArgumentNotValid
replicaId
- The id of the replicaArgumentNotValid
- if the replicaId is null, unknown, or empty stringpublic static ChannelID getTheCrForReplica(String replicaId)
public static Replica retrieveReplicaFromIdentifierChannel(String channelName) throws UnknownID, ArgumentNotValid
channelName
- The name of the identification channel for the replica.UnknownID
- If the replicaId does not point to a know replica.ArgumentNotValid
- If the channelName is either null or empty.public static String retrieveReplicaChannelNameFromReplicaId(String replicaId) throws UnknownID, ArgumentNotValid
replicaId
- The id for the replica whose identification channel name should be retrieved.UnknownID
- If no replica with the given replica id is known.ArgumentNotValid
- If the replicaId is null or empty.public static ChannelID retrieveReplicaChannelFromReplicaId(String replicaId) throws UnknownID, ArgumentNotValid
replicaId
- The id for the replica whose identification channel name should be retrieved.UnknownID
- If no replica with the given replica id is known.ArgumentNotValid
- If the replicaId is null or empty.public 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.public static void reset()
Copyright © 2005–2018 The Royal Danish Library, the National Library of France and the Austrian National Library.. All rights reserved.