org.jumpmind.symmetric.transport.file

Class FileIncomingTransport

java.lang.Object

org.jumpmind.symmetric.transport.file.FileIncomingTransport

All Implemented Interfaces:

IIncomingTransport

public class FileIncomingTransport
extends java.lang.Object
implements IIncomingTransport

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	FileIncomingTransport.FileIncomingFilter

Constructor Summary

Constructors

Constructor and Description
FileIncomingTransport(Node remoteNode, Node localNode, java.lang.String incomingDir, java.lang.String archiveDir, java.lang.String errorDir)

Method Summary

Modifier and Type	Method and Description
void	close()
void	complete(boolean success)
java.util.Map<java.lang.String,java.lang.String>	getHeaders()
protected java.io.File	getIncomingFile(java.lang.String fileExtension)
java.lang.String	getRedirectionUrl()
java.lang.String	getUrl()
boolean	isOpen()
java.io.BufferedReader	openReader()
java.io.InputStream	openStream()

Methods inherited from class java.lang.Object

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

Constructor Detail

FileIncomingTransport

public FileIncomingTransport(Node remoteNode,
                             Node localNode,
                             java.lang.String incomingDir,
                             java.lang.String archiveDir,
                             java.lang.String errorDir)

Method Detail

openReader

public java.io.BufferedReader openReader()
                                  throws java.io.IOException

Specified by:

openReader in interface IIncomingTransport

Throws:

java.io.IOException

openStream

public java.io.InputStream openStream()
                               throws java.io.IOException

Specified by:

openStream in interface IIncomingTransport

Throws:

java.io.IOException

getIncomingFile

protected java.io.File getIncomingFile(java.lang.String fileExtension)

close

public void close()

Specified by:

close in interface IIncomingTransport

isOpen

public boolean isOpen()

Specified by:

isOpen in interface IIncomingTransport

getRedirectionUrl

public java.lang.String getRedirectionUrl()

Specified by:

getRedirectionUrl in interface IIncomingTransport

getUrl

public java.lang.String getUrl()

Specified by:

getUrl in interface IIncomingTransport

complete

public void complete(boolean success)

getHeaders

public java.util.Map<java.lang.String,java.lang.String> getHeaders()

Specified by:

getHeaders in interface IIncomingTransport