|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Uses of ChannelID in dk.netarkivet.archive.arcrepository.distribute |
---|
Constructors in dk.netarkivet.archive.arcrepository.distribute with parameters of type ChannelID | |
---|---|
StoreMessage(ChannelID replyTo,
java.io.File arcfile)
Construct StoreMessage. |
Uses of ChannelID in dk.netarkivet.archive.bitarchive |
---|
Fields in dk.netarkivet.archive.bitarchive declared as ChannelID | |
---|---|
ChannelID |
BitarchiveMonitor.BatchJobStatus.originalRequestReplyTo
The reply channel for the original request. |
Methods in dk.netarkivet.archive.bitarchive with parameters of type ChannelID | |
---|---|
void |
BitarchiveMonitor.registerBatch(java.lang.String requestID,
ChannelID requestReplyTo,
java.lang.String bitarchiveBatchID)
Register a new batch sent to the bitarchives. |
Uses of ChannelID in dk.netarkivet.archive.bitarchive.distribute |
---|
Methods in dk.netarkivet.archive.bitarchive.distribute with parameters of type ChannelID | |
---|---|
BatchMessage |
BitarchiveClient.batch(ChannelID replyChannel,
FileBatchJob job)
Submit a batch job to the archive. |
static BitarchiveClient |
BitarchiveClient.getInstance(ChannelID all_ba_in,
ChannelID any_ba_in,
ChannelID the_bamon_in)
Factory that establish the connection to the server. |
Constructors in dk.netarkivet.archive.bitarchive.distribute with parameters of type ChannelID | |
---|---|
BatchEndedMessage(ChannelID to,
java.lang.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,
java.lang.String BA_ApplicationId,
java.lang.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,
java.lang.String locationName)
Creates a BatchMessage object which can be used to initiate a batch job. |
|
BatchMessage(ChannelID to,
FileBatchJob job,
java.lang.String locationName)
Creates a BatchMessage object which can be used to initiate a batch job. |
|
BatchReplyMessage(ChannelID to,
ChannelID replyTo,
java.lang.String originatingBatchMsgId,
int filesProcessed,
java.util.Collection<java.io.File> filesFailed,
RemoteFile resultFile)
Message to signal from BitarchiveMonitorServer that the batch job identified by originatingBatchMsgId is completed. |
|
GetFileMessage(ChannelID to,
ChannelID replyTo,
java.lang.String arcfileName,
java.lang.String locationName)
Constructor for get file message |
|
GetMessage(ChannelID to,
ChannelID replyTo,
java.lang.String arcfile,
long index)
|
|
HeartBeatMessage(ChannelID in_receiver,
java.lang.String applicationId)
Creates a heartbeat message. |
|
HeartBeatSender(ChannelID in_receiver,
BitarchiveServer in_baServer)
Constructs a HearBeatSender that sends heartbeats. |
|
UploadMessage(ChannelID to,
ChannelID replyTo,
RemoteFile rf)
Construct UploadMessage. |
Uses of ChannelID in dk.netarkivet.archive.distribute |
---|
Constructors in dk.netarkivet.archive.distribute with parameters of type ChannelID | |
---|---|
ArchiveMessage(ChannelID to,
ChannelID replyTo,
java.lang.String id_prefix)
Creates a new ArchiveMessage. |
Uses of ChannelID in dk.netarkivet.common.distribute |
---|
Methods in dk.netarkivet.common.distribute that return ChannelID | |
---|---|
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 (location). |
static ChannelID |
Channels.getAllBa()
Returns the topic that all bitarchive machines on this location are listening on. |
static ChannelID |
Channels.getAnyBa()
Returns the channel where exactly one of all the bitarchive machines at this location will get the message. |
static ChannelID |
Channels.getAnyHighpriorityHaco()
Returns the queue which is used by the scheduler to send doOneCrawl to Harvest Controllers of high priority (selective harvests). |
static ChannelID |
Channels.getAnyLowpriorityHaco()
Returns the queue which is used by the scheduler to send doOneCrawl to Harvest Controllers of low priority (snapshot harvests). |
static ChannelID |
Channels.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 |
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.getTheArcrepos()
Returns the queue on which all messages to the ArcRepository are sent. |
static ChannelID |
Channels.getTheBamon()
Returns the queue for sending messages to bitarchive monitors. |
static ChannelID |
Channels.getTheIndexServer()
Returns the queue for sending messages to the IndexServer application. |
static ChannelID |
Channels.getTheMonitorServer()
Return the queue for the monitor registry. |
static ChannelID |
Channels.getTheSched()
Returns the queue on which HarvestControllers reply with status messages to the HarvestScheduler. |
static ChannelID |
Channels.getThisHaco()
Returns the one-per-HACO queue on which HaCo receives replies from the arcrepository. |
static ChannelID |
Channels.getThisIndexClient()
Returns the queue for getting responses from the IndexServer application. |
ChannelID |
NetarkivetMessage.getTo()
Retrieve initial destination. |
Methods in dk.netarkivet.common.distribute with parameters of type ChannelID | |
---|---|
java.util.List<javax.jms.Message> |
JMSConnection.removeAllMessages(ChannelID mq)
Deprecated. "Method does not work, See bugs 422 and 423. |
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. |
Constructors in dk.netarkivet.common.distribute with parameters of type ChannelID | |
---|---|
NetarkivetMessage(ChannelID to,
ChannelID replyTo,
java.lang.String id_prefix)
Creates a new NetarkivetMessage. |
Uses of ChannelID in dk.netarkivet.common.distribute.arcrepository |
---|
Methods in dk.netarkivet.common.distribute.arcrepository that return ChannelID | |
---|---|
ChannelID |
Location.getChannelID()
Get the BaMon channel id that corresponds to this location. |
Uses of ChannelID in dk.netarkivet.harvester.distribute |
---|
Constructors in dk.netarkivet.harvester.distribute with parameters of type ChannelID | |
---|---|
HarvesterMessage(ChannelID to,
ChannelID replyTo,
java.lang.String id_prefix)
Creates a new HarvesterMessage. |
Uses of ChannelID in dk.netarkivet.harvester.harvesting.distribute |
---|
Constructors in dk.netarkivet.harvester.harvesting.distribute with parameters of type ChannelID | |
---|---|
DoOneCrawlMessage(Job submittedJob,
ChannelID to,
java.util.List<MetadataEntry> metadata)
A NetarkivetMessage that contains a Job for Heritrix. |
Uses of ChannelID in dk.netarkivet.monitor.distribute |
---|
Constructors in dk.netarkivet.monitor.distribute with parameters of type ChannelID | |
---|---|
MonitorMessage(ChannelID to,
ChannelID replyTo,
java.lang.String id_prefix)
Creates a new MonitorMessage. |
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |