Uses of Class
dk.netarkivet.common.distribute.ChannelID

Packages that use ChannelID
dk.netarkivet.archive.arcrepository.distribute   
dk.netarkivet.archive.bitarchive   
dk.netarkivet.archive.bitarchive.distribute   
dk.netarkivet.archive.distribute   
dk.netarkivet.common.distribute   
dk.netarkivet.common.distribute.arcrepository   
dk.netarkivet.harvester.distribute   
dk.netarkivet.harvester.harvesting.distribute   
dk.netarkivet.monitor.distribute   
 

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.