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 inherited from class org.jumpmind.symmetric.transport.http.HttpTransportManager

engine, isHttp2Enabled, sessionIdByUri, useHeaderSecurityToken, useSessionAuth

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

extensionService

Constructor Summary

Constructors

Constructor and Description
FileTransportManager(ISymmetricEngine engine)

Method Summary

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

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

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

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

append, getAcknowledgementData, getParametersFromQueryUrl, readAcknowledgement, readAcknowledgement, readAcknowledgement, resolveURL

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, getConfigTransport, getPingTransport, getPushTransport, getRegisterTransport, getRegisterTransport, readAcknowledgement, resolveURL, sendCopyRequest, sendStatusRequest

Constructor Detail

FileTransportManager

public FileTransportManager(ISymmetricEngine engine)

Method Detail

sendAcknowledgement

public int sendAcknowledgement(Node remote,
                               java.util.List<IncomingBatch> list,
                               Node local,
                               java.lang.String securityToken,
                               java.lang.String registrationUrl)
                        throws java.io.IOException

Specified by:

sendAcknowledgement in interface ITransportManager

Overrides:

sendAcknowledgement in class HttpTransportManager

Throws:

java.io.IOException

writeAcknowledgement

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

Specified by:

writeAcknowledgement in interface ITransportManager

Overrides:

writeAcknowledgement in class HttpTransportManager

Throws:

java.io.IOException

getFilePullTransport

public IIncomingTransport getFilePullTransport(Node remote,
                                               Node local,
                                               java.lang.String securityToken,
                                               java.util.Map<java.lang.String,java.lang.String> requestProperties,
                                               java.lang.String registrationUrl)
                                        throws java.io.IOException

Specified by:

getFilePullTransport in interface ITransportManager

Overrides:

getFilePullTransport in class HttpTransportManager

Throws:

java.io.IOException

getFilePushTransport

public IOutgoingWithResponseTransport getFilePushTransport(Node remote,
                                                           Node local,
                                                           java.lang.String securityToken,
                                                           java.lang.String registrationUrl)
                                                    throws java.io.IOException

Specified by:

getFilePushTransport in interface ITransportManager

Overrides:

getFilePushTransport in class HttpTransportManager

Throws:

java.io.IOException

getPullTransport

public IIncomingTransport getPullTransport(Node remote,
                                           Node local,
                                           java.lang.String securityToken,
                                           java.util.Map<java.lang.String,java.lang.String> requestProperties,
                                           java.lang.String registrationUrl)
                                    throws java.io.IOException

Specified by:

getPullTransport in interface ITransportManager

Overrides:

getPullTransport in class HttpTransportManager

Throws:

java.io.IOException

getPushTransport

public IOutgoingWithResponseTransport getPushTransport(Node remote,
                                                       Node local,
                                                       java.lang.String securityToken,
                                                       java.lang.String registrationUrl)
                                                throws java.io.IOException

Specified by:

getPushTransport in interface ITransportManager

Overrides:

getPushTransport in class HttpTransportManager

Throws:

java.io.IOException

getDirName

protected java.lang.String getDirName(java.lang.String paramName,
                                      Node localNode)