Package 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	Description
protected ISymmetricEngine	symmetricEngine

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

extensionService

Constructor Summary

Constructors

Constructor	Description
InternalTransportManager(ISymmetricEngine engine)

Method Summary

Modifier and Type	Method	Description
IOutgoingWithResponseTransport	getBandwidthPushTransport(Node remote, Node local, String securityToken, Map<String,String> requestProperties, String registrationUrl)
IIncomingTransport	getComparePullTransport(Node remote, Node local, String securityToken, String registrationUrl, Map<String,String> requestParameters)
IOutgoingWithResponseTransport	getComparePushTransport(Node remote, Node local, String securityToken, String registrationUrl, Map<String,String> requestParameters)
IIncomingTransport	getConfigTransport(Node remote, Node local, String securityToken, String symmetricVersion, String configVersion, String registrationUrl)
IIncomingTransport	getFilePullTransport(Node remote, Node local, String securityToken, Map<String,String> requestProperties, String registrationUrl)
IOutgoingWithResponseTransport	getFilePushTransport(Node targetNode, Node sourceNode, String securityToken, String registrationUrl)
IIncomingTransport	getPingTransport(Node remote, Node local, String registrationUrl)
IIncomingTransport	getPullTransport(Node remote, Node local, String securityToken, Map<String,String> requestProperties, String registrationUrl)
IOutgoingWithResponseTransport	getPushTransport(Node targetNode, Node sourceNode, String securityToken, String registrationUrl)
IOutgoingWithResponseTransport	getPushTransport(Node remote, Node local, String securityToken, Map<String,String> requestProperties, String registrationUrl)
IOutgoingWithResponseTransport	getRegisterPushTransport(Node remote, Node local)
IIncomingTransport	getRegisterTransport(Node client, String registrationUrl)
IIncomingTransport	getRegisterTransport(Node client, String registrationUrl, Map<String,String> requestProperties)
int	sendAcknowledgement(Node remote, List<IncomingBatch> list, Node local, String securityToken, String registrationUrl)
int	sendAcknowledgement(Node remote, List<IncomingBatch> list, Node local, String securityToken, Map<String,String> requestProperties, String registrationUrl)
int	sendCopyRequest(Node local)
int	sendStatusRequest(Node local, Map<String,String> statuses)
void	writeAcknowledgement(OutputStream out, Node remote, List<IncomingBatch> list, Node local, String securityToken)

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

readAcknowledgement, readRequestProperties, resolveURL, writeRequestProperties

Field Details

symmetricEngine

protected ISymmetricEngine symmetricEngine

Constructor Details

InternalTransportManager

public InternalTransportManager(ISymmetricEngine engine)

Method Details

getFilePullTransport

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

Specified by:

getFilePullTransport in interface ITransportManager

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

Throws:

IOException

getPingTransport

public IIncomingTransport getPingTransport(Node remote,
 Node local,
 String registrationUrl)
                                    throws IOException

Specified by:

getPingTransport in interface ITransportManager

Throws:

IOException

getPushTransport

public IOutgoingWithResponseTransport getPushTransport(Node targetNode,
 Node sourceNode,
 String securityToken,
 String registrationUrl)
                                                throws IOException

Specified by:

getPushTransport in interface ITransportManager

Throws:

IOException

getPushTransport

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

Specified by:

getPushTransport in interface ITransportManager

Throws:

IOException

getFilePushTransport

public IOutgoingWithResponseTransport getFilePushTransport(Node targetNode,
 Node sourceNode,
 String securityToken,
 String registrationUrl)
                                                    throws IOException

Specified by:

getFilePushTransport in interface ITransportManager

Throws:

IOException

getRegisterTransport

public IIncomingTransport getRegisterTransport(Node client,
 String registrationUrl)
                                        throws IOException

Specified by:

getRegisterTransport in interface ITransportManager

Throws:

IOException

getRegisterTransport

public IIncomingTransport getRegisterTransport(Node client,
 String registrationUrl,
 Map<String,String> requestProperties)
                                        throws IOException

Specified by:

getRegisterTransport in interface ITransportManager

Throws:

IOException

getRegisterPushTransport

public IOutgoingWithResponseTransport getRegisterPushTransport(Node remote,
 Node local)
                                                        throws IOException

Specified by:

getRegisterPushTransport in interface ITransportManager

Throws:

IOException

sendCopyRequest

public int sendCopyRequest(Node local)
                    throws IOException

Specified by:

sendCopyRequest in interface ITransportManager

Throws:

IOException

sendStatusRequest

public int sendStatusRequest(Node local,
 Map<String,String> statuses)
                      throws IOException

Specified by:

sendStatusRequest in interface ITransportManager

Throws:

IOException

sendAcknowledgement

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

Specified by:

sendAcknowledgement in interface ITransportManager

Throws:

IOException

sendAcknowledgement

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

Specified by:

sendAcknowledgement in interface ITransportManager

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

Throws:

IOException

getConfigTransport

public IIncomingTransport getConfigTransport(Node remote,
 Node local,
 String securityToken,
 String symmetricVersion,
 String configVersion,
 String registrationUrl)
                                      throws IOException

Specified by:

getConfigTransport in interface ITransportManager

Throws:

IOException

getBandwidthPushTransport

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

Specified by:

getBandwidthPushTransport in interface ITransportManager

Throws:

IOException

getComparePullTransport

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

Specified by:

getComparePullTransport in interface ITransportManager

Throws:

IOException

getComparePushTransport

public IOutgoingWithResponseTransport getComparePushTransport(Node remote,
 Node local,
 String securityToken,
 String registrationUrl,
 Map<String,String> requestParameters)
                                                       throws IOException

Specified by:

getComparePushTransport in interface ITransportManager

Throws:

IOException