fedora.server.journal.readerwriter.multicast.rmi
Class RmiJournalReceiver

java.lang.Object
  java.rmi.server.RemoteObject
      java.rmi.server.RemoteServer
          java.rmi.server.UnicastRemoteObject
              fedora.server.journal.readerwriter.multicast.rmi.RmiJournalReceiver

All Implemented Interfaces:

RmiJournalReceiverInterface, java.io.Serializable, java.rmi.Remote

public class RmiJournalReceiver
extends java.rmi.server.UnicastRemoteObject
implements RmiJournalReceiverInterface

Title: RmiJournalReceiver.java

Description: A free-standing RMI server that receives journal messages from an RmiTransport and writes them to files in a specified directory.

Note: command-line arguments are specified in RmiJournalReceiverArguments.

Version:

$Id: RmiJournalReceiver.java,v 1.4 2007/06/21 15:59:53 jblake Exp $

Author:

jblake

See Also:

Serialized Form

Field Summary

Fields inherited from class java.rmi.server.RemoteObject

ref

Fields inherited from interface fedora.server.journal.readerwriter.multicast.rmi.RmiJournalReceiverInterface

RMI_BINDING_NAME

Constructor Summary

RmiJournalReceiver(RmiJournalReceiverArguments arguments)
On creation, parse the arguments and initialize Log4J for the application.

Method Summary

void	closeFile() Request to close a file.
void	exportAndBind() Create an RMI registry, and bind this object to the expected name.
static void	main(java.lang.String[] args) Main routine: create the receiver from the arguments, and bind the receiver in the registry.
void	openFile(java.lang.String repositoryHash, java.lang.String filename) Request to open a file.
void	writeText(java.lang.String indexedHash, java.lang.String text) Request to write text to the current journal file.

Methods inherited from class java.rmi.server.UnicastRemoteObject

clone, exportObject, exportObject, exportObject, unexportObject

Methods inherited from class java.rmi.server.RemoteServer

getClientHost, getLog, setLog

Methods inherited from class java.rmi.server.RemoteObject

equals, getRef, hashCode, toString, toStub

Methods inherited from class java.lang.Object

finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

RmiJournalReceiver

public RmiJournalReceiver(RmiJournalReceiverArguments arguments)
                   throws java.rmi.RemoteException

On creation, parse the arguments and initialize Log4J for the application.

Throws:

java.rmi.RemoteException

Method Detail

exportAndBind

public void exportAndBind()
                   throws java.rmi.RemoteException,
                          java.rmi.AlreadyBoundException,
                          java.lang.InterruptedException

Create an RMI registry, and bind this object to the expected name.

Throws:

java.rmi.RemoteException

java.rmi.AlreadyBoundException

java.lang.InterruptedException

openFile

public void openFile(java.lang.String repositoryHash,
                     java.lang.String filename)
              throws JournalException

Request to open a file. Check that:

• a file is not already open,
• we can create a TransportOutputFile, and open a Writer on it.

Specified by:

openFile in interface RmiJournalReceiverInterface

Throws:

JournalException

writeText

public void writeText(java.lang.String indexedHash,
                      java.lang.String text)
               throws JournalException

Request to write text to the current journal file. Check that:

• a file is open,
• the supplied indexedHash matches the one we calculate,
• the write is successful.

Increment the itemIndex after a successful write.

Specified by:

writeText in interface RmiJournalReceiverInterface

Throws:

JournalException

closeFile

public void closeFile()
               throws JournalException

Request to close a file. Check that:

• a file is open,
• we are able to close the file.

Specified by:

closeFile in interface RmiJournalReceiverInterface

Throws:

JournalException

main

public static void main(java.lang.String[] args)

Main routine: create the receiver from the arguments, and bind the receiver in the registry.