Package org.jumpmind.symmetric.transport.file

Class FileTransportManager

java.lang.Object

org.jumpmind.symmetric.transport.AbstractTransportManager

org.jumpmind.symmetric.transport.http.HttpTransportManager

org.jumpmind.symmetric.transport.file.FileTransportManager

All Implemented Interfaces:

ITransportManager

public class FileTransportManager
extends HttpTransportManager
implements ITransportManager

Field Summary

Fields

Modifier and Type	Field	Description
protected IParameterService	parameterService

Fields inherited from class org.jumpmind.symmetric.transport.http.HttpTransportManager

engine, sessionIdByUri, useHeaderSecurityToken, useSessionAuth

Fields inherited from class org.jumpmind.symmetric.transport.AbstractTransportManager

extensionService

Constructor Summary

Constructors

Constructor	Description
FileTransportManager(ISymmetricEngine engine)

Method Summary

Modifier and Type	Method	Description
protected String	getDirName(String paramName, Node localNode)
IIncomingTransport	getFilePullTransport(Node remote, Node local, String securityToken, Map<String,String> requestProperties, String registrationUrl)
IOutgoingWithResponseTransport	getFilePushTransport(Node remote, Node local, String securityToken, String registrationUrl)
IIncomingTransport	getPullTransport(Node remote, Node local, String securityToken, Map<String,String> requestProperties, String registrationUrl)
IOutgoingWithResponseTransport	getPushTransport(Node remote, Node local, String securityToken, String registrationUrl)
int	sendAcknowledgement(Node remote, List<IncomingBatch> list, Node local, String securityToken, String registrationUrl)
void	writeAcknowledgement(OutputStream out, Node remote, List<IncomingBatch> list, Node local, String securityToken)

Methods inherited from class org.jumpmind.symmetric.transport.http.HttpTransportManager

add, addNodeId, addNodeInfo, buildRegistrationUrl, buildURL, checkForConnectionUpgrade, clearSession, createGetConnectionFor, createGetConnectionFor, getBandwidthPushTransport, getComparePullTransport, getComparePushTransport, getCompressionLevel, getCompressionStrategy, getConfigTransport, getEngine, getHttpConnectTimeOutInMs, getHttpTimeOutInMs, getInputStreamFrom, getOutputStreamSize, getPingTransport, getPushTransport, getReaderFrom, getRegisterPushTransport, getRegisterTransport, getRegisterTransport, getUri, isOutputStreamEnabled, isUseCompression, openConnection, sendAcknowledgement, sendCopyRequest, sendMessage, sendMessage, sendStatusRequest, updateSession, writeMessage

Methods inherited from class org.jumpmind.symmetric.transport.AbstractTransportManager

append, getAcknowledgementData, getParametersFromQueryUrl, readAcknowledgement, readAcknowledgement, readAcknowledgement, readRequestProperties, resolveURL, writeRequestProperties

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.jumpmind.symmetric.transport.ITransportManager

getBandwidthPushTransport, getComparePullTransport, getComparePushTransport, getConfigTransport, getPingTransport, getPushTransport, getRegisterPushTransport, getRegisterTransport, getRegisterTransport, readAcknowledgement, readRequestProperties, resolveURL, sendAcknowledgement, sendCopyRequest, sendStatusRequest, writeRequestProperties

Field Details

parameterService

protected IParameterService parameterService

Constructor Details

FileTransportManager

public FileTransportManager(ISymmetricEngine engine)

Method Details

sendAcknowledgement

public int sendAcknowledgement(Node remote,
 List<IncomingBatch> list,
 Node local,
 String securityToken,
 String registrationUrl)
                        throws IOException

Specified by:

sendAcknowledgement in interface ITransportManager

Overrides:

sendAcknowledgement in class HttpTransportManager

Throws:

IOException

writeAcknowledgement

public void writeAcknowledgement(OutputStream out,
 Node remote,
 List<IncomingBatch> list,
 Node local,
 String securityToken)
                          throws IOException

Specified by:

writeAcknowledgement in interface ITransportManager

Overrides:

writeAcknowledgement in class HttpTransportManager

Throws:

IOException

getFilePullTransport

public IIncomingTransport getFilePullTransport(Node remote,
 Node local,
 String securityToken,
 Map<String,String> requestProperties,
 String registrationUrl)
                                        throws IOException

Specified by:

getFilePullTransport in interface ITransportManager

Overrides:

getFilePullTransport in class HttpTransportManager

Throws:

IOException

getFilePushTransport

public IOutgoingWithResponseTransport getFilePushTransport(Node remote,
 Node local,
 String securityToken,
 String registrationUrl)
                                                    throws IOException

Specified by:

getFilePushTransport in interface ITransportManager

Overrides:

getFilePushTransport in class HttpTransportManager

Throws:

IOException

getPullTransport

public IIncomingTransport getPullTransport(Node remote,
 Node local,
 String securityToken,
 Map<String,String> requestProperties,
 String registrationUrl)
                                    throws IOException

Specified by:

getPullTransport in interface ITransportManager

Overrides:

getPullTransport in class HttpTransportManager

Throws:

IOException

getPushTransport

public IOutgoingWithResponseTransport getPushTransport(Node remote,
 Node local,
 String securityToken,
 String registrationUrl)
                                                throws IOException

Specified by:

getPushTransport in interface ITransportManager

Overrides:

getPushTransport in class HttpTransportManager

Throws:

IOException

getDirName

protected String getDirName(String paramName,
 Node localNode)