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 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.Copyright © 2005–2015 The Royal Danish Library, the Danish State and University Library, the National Library of France and the Austrian National Library.. All rights reserved.