|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectdk.netarkivet.archive.bitarchive.distribute.BitarchiveClient
public class BitarchiveClient
Proxy for remote bitarchive. Establishes a JMS connection to the remote bitarchive
Field Summary | |
---|---|
protected static org.apache.commons.logging.Log |
log
|
Method Summary | |
---|---|
BatchMessage |
batch(BatchMessage bMsg)
Submit an already constructed get message to the archive. |
BatchMessage |
batch(ChannelID replyChannel,
FileBatchJob job)
Submit a batch job to the archive. |
void |
close()
Release jms connections. |
void |
get(GetMessage msg)
Submit an already constructed batch message to the archive. |
GetMessage |
get(java.lang.String arcfile,
long index)
Submit a get request to the bitarchive. |
void |
getFile(GetFileMessage msg)
Submit an already constructed getfile message to the archive. |
static BitarchiveClient |
getInstance(ChannelID all_ba_in,
ChannelID any_ba_in,
ChannelID the_bamon_in)
Factory that establish the connection to the server. |
void |
removeAndGetFile(RemoveAndGetFileMessage msg)
Forward the message to ALL_BA. |
void |
upload(RemoteFile rf)
Submit an upload request to the bitarchive. |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
protected static final org.apache.commons.logging.Log log
Method Detail |
---|
public static BitarchiveClient getInstance(ChannelID all_ba_in, ChannelID any_ba_in, ChannelID the_bamon_in) throws IOFailure
all_ba_in
- topic to all bitarchivesany_ba_in
- queue to one of the bitarchivesthe_bamon_in
- queue to the bitarchive monitor
IOFailure
- If there is a problem making the connection.public GetMessage get(java.lang.String arcfile, long index)
arcfile
- The file containing the requested recordindex
- Offset of the ARC record in the file
public void get(GetMessage msg)
msg
- the message to be processed by the get command.public void getFile(GetFileMessage msg)
msg
- get file message to retrievepublic void removeAndGetFile(RemoveAndGetFileMessage msg)
msg
- the message to forwardpublic void upload(RemoteFile rf)
rf
- The file to upload
IOFailure
- If access to file denied
ArgumentNotValid
- if arcfile is nullpublic BatchMessage batch(BatchMessage bMsg) throws ArgumentNotValid
bMsg
- a BatchMessage
ArgumentNotValid
- if message is null.public BatchMessage batch(ChannelID replyChannel, FileBatchJob job) throws ArgumentNotValid, IOFailure
replyChannel
- The channel that the reply of this job should
be sent to.job
- The job that should be run on the bit archive
handled by this client.
ArgumentNotValid
- if any parameter was null.
IOFailure
- if sending the batch message did not succeed.public void close()
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |