public class FileTransportManager extends HttpTransportManager implements ITransportManager
engine, isHttp2Enabled, sessionIdByUri, useHeaderSecurityToken, useSessionAuthextensionService| Constructor and Description |
|---|
FileTransportManager(ISymmetricEngine engine) |
| 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) |
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, writeMessageappend, getAcknowledgementData, getParametersFromQueryUrl, readAcknowledgement, readAcknowledgement, readAcknowledgement, resolveURLclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitgetBandwidthPushTransport, getConfigTransport, getPingTransport, getPushTransport, getRegisterTransport, getRegisterTransport, readAcknowledgement, resolveURL, sendCopyRequest, sendStatusRequestpublic FileTransportManager(ISymmetricEngine engine)
public int sendAcknowledgement(Node remote, java.util.List<IncomingBatch> list, Node local, java.lang.String securityToken, java.lang.String registrationUrl) throws java.io.IOException
sendAcknowledgement in interface ITransportManagersendAcknowledgement in class HttpTransportManagerjava.io.IOExceptionpublic void writeAcknowledgement(java.io.OutputStream out,
Node remote,
java.util.List<IncomingBatch> list,
Node local,
java.lang.String securityToken)
throws java.io.IOException
writeAcknowledgement in interface ITransportManagerwriteAcknowledgement in class HttpTransportManagerjava.io.IOExceptionpublic 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
getFilePullTransport in interface ITransportManagergetFilePullTransport in class HttpTransportManagerjava.io.IOExceptionpublic IOutgoingWithResponseTransport getFilePushTransport(Node remote, Node local, java.lang.String securityToken, java.lang.String registrationUrl) throws java.io.IOException
getFilePushTransport in interface ITransportManagergetFilePushTransport in class HttpTransportManagerjava.io.IOExceptionpublic 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
getPullTransport in interface ITransportManagergetPullTransport in class HttpTransportManagerjava.io.IOExceptionpublic IOutgoingWithResponseTransport getPushTransport(Node remote, Node local, java.lang.String securityToken, java.lang.String registrationUrl) throws java.io.IOException
getPushTransport in interface ITransportManagergetPushTransport in class HttpTransportManagerjava.io.IOExceptionprotected java.lang.String getDirName(java.lang.String paramName,
Node localNode)