Package org.jumpmind.symmetric.transport

Interface ITransportManager

All Known Implementing Classes:

FileTransportManager, HttpTransportManager, InternalTransportManager, MockTransportManager

public interface ITransportManager

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 remote, Node local, 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 remote, Node local, 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 node, String registrationUrl)
IIncomingTransport	getRegisterTransport(Node node, String registrationUrl, Map<String,String> requestProperties)
List<BatchAck>	readAcknowledgement(String parameterString1, String parameterString2)
Map<String,String>	readRequestProperties(InputStream is)
String	resolveURL(String url, String registrationUrl)	This is the proper way to determine the URL for a node.
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)
void	writeRequestProperties(Map<String,String> requestProperties, OutputStream os)

Method Details

sendAcknowledgement

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

Throws:

IOException

sendAcknowledgement

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

Throws:

IOException

writeAcknowledgement

void writeAcknowledgement(OutputStream out,
 Node remote,
 List<IncomingBatch> list,
 Node local,
 String securityToken)
                   throws IOException

Throws:

IOException

readAcknowledgement

List<BatchAck> readAcknowledgement(String parameterString1,
 String parameterString2)
                            throws IOException

Throws:

IOException

getFilePullTransport

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

Throws:

IOException

getFilePushTransport

IOutgoingWithResponseTransport getFilePushTransport(Node remote,
 Node local,
 String securityToken,
 String registrationUrl)
                                             throws IOException

Throws:

IOException

getPullTransport

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

Throws:

IOException

getPingTransport

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

Throws:

IOException

getPushTransport

IOutgoingWithResponseTransport getPushTransport(Node remote,
 Node local,
 String securityToken,
 String registrationUrl)
                                         throws IOException

Throws:

IOException

getPushTransport

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

Throws:

IOException

getRegisterTransport

IIncomingTransport getRegisterTransport(Node node,
 String registrationUrl)
                                 throws IOException

Throws:

IOException

getRegisterTransport

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

Throws:

IOException

getRegisterPushTransport

IOutgoingWithResponseTransport getRegisterPushTransport(Node remote,
 Node local)
                                                 throws IOException

Throws:

IOException

getConfigTransport

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

Throws:

IOException

getBandwidthPushTransport

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

Throws:

IOException

getComparePullTransport

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

Throws:

IOException

getComparePushTransport

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

Throws:

IOException

resolveURL

String resolveURL(String url,
 String registrationUrl)

This is the proper way to determine the URL for a node. It delegates to configured extension points when necessary to take in to account custom load balancing and url selection schemes.

Parameters:

url - This is the url configured in sync_url of the node table

sendCopyRequest

int sendCopyRequest(Node local)
             throws IOException

Throws:

IOException

sendStatusRequest

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

Throws:

IOException

writeRequestProperties

void writeRequestProperties(Map<String,String> requestProperties,
 OutputStream os)
                     throws IOException

Throws:

IOException

readRequestProperties

Map<String,String> readRequestProperties(InputStream is)
                                  throws IOException

Throws:

IOException