org.jumpmind.symmetric.transport.internal

Class InternalTransportManager

java.lang.Object

org.jumpmind.symmetric.transport.AbstractTransportManager

org.jumpmind.symmetric.transport.internal.InternalTransportManager

All Implemented Interfaces:

ITransportManager

public class InternalTransportManager
extends AbstractTransportManager
implements ITransportManager

Coordinates interaction between two symmetric engines in the same JVM.

Field Summary

Fields

Modifier and Type	Field and Description
protected ISymmetricEngine	symmetricEngine

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

extensionService

Constructor Summary

Constructors

Constructor and Description
InternalTransportManager(ISymmetricEngine engine)

Method Summary

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)

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

readAcknowledgement, resolveURL

Field Detail

symmetricEngine

protected ISymmetricEngine symmetricEngine

Constructor Detail

InternalTransportManager

public InternalTransportManager(ISymmetricEngine engine)

Method Detail

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

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

Throws:

java.io.IOException

getPingTransport

public IIncomingTransport getPingTransport(Node remote,
                                           Node local,
                                           java.lang.String registrationUrl)
                                    throws java.io.IOException

Specified by:

getPingTransport in interface ITransportManager

Throws:

java.io.IOException

getPushTransport

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

Specified by:

getPushTransport in interface ITransportManager

Throws:

java.io.IOException

getPushTransport

public 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

Specified by:

getPushTransport in interface ITransportManager

Throws:

java.io.IOException

getFilePushTransport

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

Specified by:

getFilePushTransport in interface ITransportManager

Throws:

java.io.IOException

getRegisterTransport

public IIncomingTransport getRegisterTransport(Node client,
                                               java.lang.String registrationUrl)
                                        throws java.io.IOException

Specified by:

getRegisterTransport in interface ITransportManager

Throws:

java.io.IOException

getRegisterTransport

public IIncomingTransport getRegisterTransport(Node client,
                                               java.lang.String registrationUrl,
                                               java.util.Map<java.lang.String,java.lang.String> requestProperties)
                                        throws java.io.IOException

Specified by:

getRegisterTransport in interface ITransportManager

Throws:

java.io.IOException

sendCopyRequest

public int sendCopyRequest(Node local)
                    throws java.io.IOException

Specified by:

sendCopyRequest in interface ITransportManager

Throws:

java.io.IOException

sendStatusRequest

public int sendStatusRequest(Node local,
                             java.util.Map<java.lang.String,java.lang.String> statuses)
                      throws java.io.IOException

Specified by:

sendStatusRequest in interface ITransportManager

Throws:

java.io.IOException

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

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

Throws:

java.io.IOException

getConfigTransport

public 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

Specified by:

getConfigTransport in interface ITransportManager

Throws:

java.io.IOException

getBandwidthPushTransport

public 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

Specified by:

getBandwidthPushTransport in interface ITransportManager

Throws:

java.io.IOException