public class InternalTransportManager extends AbstractTransportManager implements ITransportManager
| Modifier and Type | Field and Description |
|---|---|
protected ISymmetricEngine |
symmetricEngine |
extensionService| Constructor and Description |
|---|
InternalTransportManager(ISymmetricEngine engine) |
| Modifier and Type | Method and Description |
|---|---|
IOutgoingWithResponseTransport |
getBandwidthPushTransport(Node remote,
Node local,
java.lang.String securityToken,
java.util.Map<java.lang.String,java.lang.String> requestProperties,
java.lang.String registrationUrl) |
IIncomingTransport |
getConfigTransport(Node remote,
Node local,
java.lang.String securityToken,
java.lang.String symmetricVersion,
java.lang.String configVersion,
java.lang.String registrationUrl) |
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 targetNode,
Node sourceNode,
java.lang.String securityToken,
java.lang.String registrationUrl) |
IIncomingTransport |
getPingTransport(Node remote,
Node local,
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.util.Map<java.lang.String,java.lang.String> requestProperties,
java.lang.String registrationUrl) |
IOutgoingWithResponseTransport |
getPushTransport(Node targetNode,
Node sourceNode,
java.lang.String securityToken,
java.lang.String registrationUrl) |
IIncomingTransport |
getRegisterTransport(Node client,
java.lang.String registrationUrl) |
IIncomingTransport |
getRegisterTransport(Node client,
java.lang.String registrationUrl,
java.util.Map<java.lang.String,java.lang.String> requestProperties) |
int |
sendAcknowledgement(Node remote,
java.util.List<IncomingBatch> list,
Node local,
java.lang.String securityToken,
java.lang.String registrationUrl) |
int |
sendCopyRequest(Node local) |
int |
sendStatusRequest(Node local,
java.util.Map<java.lang.String,java.lang.String> statuses) |
void |
writeAcknowledgement(java.io.OutputStream out,
Node remote,
java.util.List<IncomingBatch> list,
Node local,
java.lang.String securityToken) |
append, getAcknowledgementData, getParametersFromQueryUrl, readAcknowledgement, readAcknowledgement, readAcknowledgement, resolveURLclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitreadAcknowledgement, resolveURLprotected ISymmetricEngine symmetricEngine
public InternalTransportManager(ISymmetricEngine engine)
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
getFilePullTransport in interface ITransportManagerjava.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 ITransportManagerjava.io.IOExceptionpublic IIncomingTransport getPingTransport(Node remote, Node local, java.lang.String registrationUrl) throws java.io.IOException
getPingTransport in interface ITransportManagerjava.io.IOExceptionpublic IOutgoingWithResponseTransport getPushTransport(Node targetNode, Node sourceNode, java.lang.String securityToken, java.lang.String registrationUrl) throws java.io.IOException
getPushTransport in interface ITransportManagerjava.io.IOExceptionpublic IOutgoingWithResponseTransport getPushTransport(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
getPushTransport in interface ITransportManagerjava.io.IOExceptionpublic IOutgoingWithResponseTransport getFilePushTransport(Node targetNode, Node sourceNode, java.lang.String securityToken, java.lang.String registrationUrl) throws java.io.IOException
getFilePushTransport in interface ITransportManagerjava.io.IOExceptionpublic IIncomingTransport getRegisterTransport(Node client, java.lang.String registrationUrl) throws java.io.IOException
getRegisterTransport in interface ITransportManagerjava.io.IOExceptionpublic IIncomingTransport getRegisterTransport(Node client, java.lang.String registrationUrl, java.util.Map<java.lang.String,java.lang.String> requestProperties) throws java.io.IOException
getRegisterTransport in interface ITransportManagerjava.io.IOExceptionpublic int sendCopyRequest(Node local) throws java.io.IOException
sendCopyRequest in interface ITransportManagerjava.io.IOExceptionpublic int sendStatusRequest(Node local, java.util.Map<java.lang.String,java.lang.String> statuses) throws java.io.IOException
sendStatusRequest in interface ITransportManagerjava.io.IOExceptionpublic 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 ITransportManagerjava.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 ITransportManagerjava.io.IOExceptionpublic IIncomingTransport getConfigTransport(Node remote, Node local, java.lang.String securityToken, java.lang.String symmetricVersion, java.lang.String configVersion, java.lang.String registrationUrl) throws java.io.IOException
getConfigTransport in interface ITransportManagerjava.io.IOExceptionpublic IOutgoingWithResponseTransport getBandwidthPushTransport(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
getBandwidthPushTransport in interface ITransportManagerjava.io.IOException