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

java.lang.Object
  java.io.Writer
      fedora.server.journal.readerwriter.multicast.rmi.RmiTransportWriter

All Implemented Interfaces:

java.io.Closeable, java.io.Flushable, java.lang.Appendable

public class RmiTransportWriter
extends java.io.Writer

Title: RmiTransportWriter.java

Description: A writer that passes characters on to an RmiTransportSink. You should wrap this in a BufferedWriter to reduce network traffic to something manageable.

Version:

$Id: RmiTransportWriter.java,v 1.3 2007/06/01 17:21:32 jblake Exp $

Author:

jblake

Field Summary

Fields inherited from class java.io.Writer

lock

Constructor Summary

RmiTransportWriter(RmiJournalReceiverInterface receiver, java.lang.String repositoryHash, java.lang.String filename)
When the writer is created, open the connection to the receiver.

Method Summary

void	close() Time to close the file? Tell the receiver.
void	flush() Flush has no effect.
void	write(char[] cbuf, int off, int len) Each time characters are written, send them to the receiver.

Methods inherited from class java.io.Writer

append, append, append, write, write, write, write

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

RmiTransportWriter

public RmiTransportWriter(RmiJournalReceiverInterface receiver,
                          java.lang.String repositoryHash,
                          java.lang.String filename)
                   throws JournalException

When the writer is created, open the connection to the receiver.

Throws:

JournalException

Method Detail

write

public void write(char[] cbuf,
                  int off,
                  int len)
           throws java.io.IOException

Each time characters are written, send them to the receiver. Keep track of how many writes, so we can create a proper item hash.

Specified by:

write in class java.io.Writer

Throws:

java.io.IOException

close

public void close()
           throws java.io.IOException

Time to close the file? Tell the receiver.

Specified by:

close in interface java.io.Closeable

Specified by:

close in class java.io.Writer

Throws:

java.io.IOException

flush

public void flush()
           throws java.io.IOException

Flush has no effect. Everything is written as it comes in.

Specified by:

flush in interface java.io.Flushable

Specified by:

flush in class java.io.Writer

Throws:

java.io.IOException