Constructor and Description |
---|
StoreMessage(ChannelID replyTo,
File arcfile)
Construct StoreMessage.
|
Modifier and Type | Field and Description |
---|---|
ChannelID |
BitarchiveMonitor.BatchJobStatus.originalRequestReplyTo
The reply channel for the original request.
|
Modifier and Type | Method and Description |
---|---|
void |
BitarchiveMonitor.registerBatch(String requestID,
ChannelID requestReplyTo,
String bitarchiveBatchID,
long timeout)
Register a new batch sent to the bitarchives.
|
Modifier and Type | Method and Description |
---|---|
static BitarchiveClient |
BitarchiveClient.getInstance(ChannelID allBaIn,
ChannelID anyBaIn,
ChannelID theBamonIn)
Factory that establish the connection to the server.
|
BatchMessage |
BitarchiveClient.sendBatchJob(ChannelID replyChannel,
FileBatchJob job)
Submit a batch job to the archive.
|
GetChecksumMessage |
BitarchiveClient.sendGetChecksumMessage(ChannelID replyChannel,
String filename)
Method for retrieving the checksum of a specific arcfile within the archive.
|
Constructor and Description |
---|
BatchEndedMessage(ChannelID to,
String originatingBatchMsgId,
BatchStatus status)
Message to signal from a BitarchiveServer to the BitarchiveMonitorServer that the Bit Archive Application
identified by BA_ApplicationId has completed its part of the batch job.
|
BatchEndedMessage(ChannelID to,
String baAppId,
String originatingBatchMsgId,
RemoteFile rf)
Message to signal from a BitarchiveServer to the BitarchiveMonitorServer that the Bit Archive Application
identified by BA_ApplicationId has completed its part of the batch job.
|
BatchMessage(ChannelID to,
ChannelID replyTo,
FileBatchJob job,
String replicaId,
String... arguments)
Creates a BatchMessage object which can be used to initiate a batch job.
|
BatchMessage(ChannelID to,
ChannelID replyTo,
FileBatchJob job,
String replicaId,
String batchId,
String... arguments)
Creates a BatchMessage object which can be used to initiate a batch job.
|
BatchMessage(ChannelID to,
FileBatchJob job,
String replicaId)
Creates a BatchMessage object which can be used to initiate a batch job.
|
BatchReplyMessage(ChannelID to,
ChannelID replyTo,
String originatingBatchMsgId,
int filesProcessed,
Collection<File> failedFiles,
RemoteFile resultFile)
Message to signal from BitarchiveMonitorServer that the batch job identified by originatingBatchMsgId is
completed.
|
BatchTerminationMessage(ChannelID to,
ChannelID replyTo,
String batchID)
Constructor.
|
BatchTerminationMessage(ChannelID to,
String batchID)
Constructor.
|
GetFileMessage(ChannelID to,
ChannelID replyTo,
String arcfileName,
String replicaId)
Constructor for get file message.
|
GetMessage(ChannelID to,
ChannelID replyTo,
String arcfile,
long index)
Constructor.
|
HeartBeatMessage(ChannelID inReceiver,
String applicationId)
Creates a heartbeat message.
|
HeartBeatSender(ChannelID inReceiver,
BitarchiveServer inBaServer)
Constructs a HearBeatSender that sends heartbeats.
|
RemoveAndGetFileMessage(ChannelID to,
ChannelID replyTo,
String fileName,
String replicaId,
String checksum,
String credentials)
Constructor.
|
UploadMessage(ChannelID to,
ChannelID replyTo,
RemoteFile rf)
Construct UploadMessage.
|
Modifier and Type | Field and Description |
---|---|
protected ChannelID |
ChecksumArchiveServer.theCR
The channel used for communication.
|
Modifier and Type | Method and Description |
---|---|
static ChecksumClient |
ChecksumClient.getInstance(ChannelID theCRin)
The method for invoking an instance of this class.
|
BatchMessage |
ChecksumClient.sendBatchJob(ChannelID replyChannel,
FileBatchJob job)
Method for sending batch job messages to the replica.
|
GetChecksumMessage |
ChecksumClient.sendGetChecksumMessage(ChannelID replyChannel,
String filename)
Method for retrieving the checksum of a specific arcfile within the archive.
|
Constructor and Description |
---|
CorrectMessage(ChannelID to,
ChannelID replyTo,
String badChecksum,
RemoteFile rf,
String repId,
String cred)
Constructor.
|
GetAllChecksumsMessage(ChannelID to,
ChannelID replyTo,
String repId)
Constructor.
|
GetAllFilenamesMessage(ChannelID to,
ChannelID replyTo,
String repId)
Constructor.
|
GetChecksumMessage(ChannelID to,
ChannelID replyTo,
String filename,
String repId)
Constructor.
|
Modifier and Type | Method and Description |
---|---|
BatchMessage |
ReplicaClient.sendBatchJob(ChannelID replyChannel,
FileBatchJob job)
Method for sending batch message and retrieving the results.
|
GetChecksumMessage |
ReplicaClient.sendGetChecksumMessage(ChannelID replyChannel,
String filename)
Retrieves the checksum for a specific file.
|
Constructor and Description |
---|
ArchiveMessage(ChannelID to,
ChannelID replyTo)
Creates a new ArchiveMessage.
|
Modifier and Type | Method and Description |
---|---|
static ChannelID[] |
Channels.getAllArchives_ALL_BAs()
Returns ALL_BA channels for every known bitarchive.
|
static ChannelID[] |
Channels.getAllArchives_ANY_BAs()
Returns ANY_BA channels for every known bitarchive.
|
static ChannelID[] |
Channels.getAllArchives_BAMONs()
Returns BAMON channels for every known bitarchive (replica).
|
static ChannelID[] |
Channels.getAllArchives_CRs()
Returns the channels for the all Checksum replicas.
|
static ChannelID |
Channels.getAllBa()
Returns the topic that all bitarchive machines on this replica are listening on.
|
static ChannelID |
Channels.getAnyBa()
Returns the channel where exactly one of all the bitarchive machines at this replica will get the message.
|
static ChannelID |
Channels.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 |
Channels.getError()
Returns the queue on which to put errors which are not handled elsewhere.
|
ChannelID |
NetarkivetMessage.getReplyTo()
Retrieve specified reply channel.
|
static ChannelID |
Channels.getTheBamon()
Returns the queue for sending messages to bitarchive monitors.
|
static ChannelID |
Channels.getTheCR()
Method for retrieving the 'THE_CR' channel for this replica.
|
static ChannelID |
Channels.getTheCrForReplica(String replicaId) |
static ChannelID |
Channels.getTheIndexServer()
Returns the queue for sending messages to the IndexServer application.
|
static ChannelID |
Channels.getTheMonitorServer()
Return the topic for the monitor registry.
|
static ChannelID |
Channels.getTheRepos()
Returns the queue on which all messages to the Repository are sent.
|
static ChannelID |
Channels.getThisIndexClient()
Returns the queue for getting responses from the IndexServer application.
|
static ChannelID |
Channels.getThisReposClient()
Returns the one-per-client queue on which client receives replies from the arcrepository.
|
ChannelID |
NetarkivetMessage.getTo()
Retrieve initial destination.
|
static ChannelID |
Channels.retrieveReplicaChannelFromReplicaId(String replicaId)
The method for retrieving the identification channel for a replica based on the Id of this replica.
|
Modifier and Type | Method and Description |
---|---|
javax.jms.QueueBrowser |
JMSConnection.createQueueBrowser(ChannelID queueID)
Creates a QueueBrowser object to peek at the messages on the specified queue.
|
List<javax.jms.MessageListener> |
JMSConnectionMockupMQ.getListeners(ChannelID channel)
Returns a list of all MessageListeners listening to a particular channel
|
boolean |
JMSConnectionMockupMQ.isSentToChannel(TestChecksumJob job,
ChannelID channelID) |
void |
JMSConnection.removeListener(ChannelID mq,
javax.jms.MessageListener ml)
Removes the specified MessageListener from the given queue or topic.
|
void |
JMSConnection.resend(NetarkivetMessage msg,
ChannelID to)
Sends a message msg to the channel defined by the parameter to - NOT the channel defined in the message.
|
protected void |
JMSConnection.sendMessage(NetarkivetMessage nMsg,
ChannelID to)
Submit an ObjectMessage to the destination channel.
|
void |
JMSConnection.setListener(ChannelID mq,
javax.jms.MessageListener ml)
Method adds a listener to the given queue or topic.
|
Constructor and Description |
---|
NetarkivetMessage(ChannelID to,
ChannelID replyTo)
Creates a new NetarkivetMessage.
|
Modifier and Type | Method and Description |
---|---|
ChannelID |
Replica.getIdentificationChannel()
Get the identification channel that corresponds to this replica.
|
Modifier and Type | Field and Description |
---|---|
ChannelID |
HarvesterChannels.THE_SCHED |
Modifier and Type | Method and Description |
---|---|
static ChannelID |
HarvesterChannels.getHarvesterRegistrationRequestChannel()
Return the queue for sending
HarvesterRegistrationRequest s. |
static ChannelID |
HarvesterChannels.getHarvesterRegistrationResponseChannel()
Return the queue for sending
HarvesterRegistrationResponse
s. |
static ChannelID |
HarvesterChannels.getHarvesterStatusChannel() |
static ChannelID |
HarvesterChannels.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 |
HarvesterChannels.getHarvestJobChannelId(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 |
HarvesterChannels.getHarvestMonitorChannel()
Return the queue for the harvest monitor registry.
|
static ChannelID |
HarvesterChannels.getTheSched() |
Constructor and Description |
---|
HarvesterMessage(ChannelID to,
ChannelID replyTo)
Creates a new HarvesterMessage.
|
IndexReadyMessage(Long harvestId,
boolean indexIsOK,
ChannelID to,
ChannelID replyTo)
Constructor for the IndexReadyMessage.
|
Modifier and Type | Field and Description |
---|---|
static ChannelID |
HarvestControllerServer.HARVEST_CHAN_VALID_RESP_ID
The JMS channel on which to listen for
HarvesterRegistrationResponse s. |
Constructor and Description |
---|
DoOneCrawlMessage(Job submittedJob,
ChannelID to,
HarvestDefinitionInfo harvestInfo,
List<MetadataEntry> metadata)
A NetarkivetMessage that contains a Job for Heritrix.
|
Modifier and Type | Field and Description |
---|---|
static ChannelID |
HarvestMonitor.HARVEST_MONITOR_CHANNEL_ID
The JMS channel on which to listen for
CrawlProgressMessage s. |
Modifier and Type | Field and Description |
---|---|
static ChannelID |
HarvestControllerServer.HARVEST_CHAN_VALID_RESP_ID
The JMS channel on which to listen for
HarvesterRegistrationResponse s. |
Constructor and Description |
---|
IndexRequestMessage(RequestType requestType,
Set<Long> jobSet,
ChannelID replyTo,
boolean returnIndex,
Long harvestId)
Generate an IndexRequestMessage that can send its reply to a specific channel.
|
Constructor and Description |
---|
MonitorMessage(ChannelID to,
ChannelID replyTo)
Creates a new MonitorMessage.
|
Copyright © 2005–2016 The Royal Danish Library, the Danish State and University Library, the National Library of France and the Austrian National Library.. All rights reserved.