org.jumpmind.symmetric.transport

Interface ITransportManager

All Known Implementing Classes:

FileTransportManager, HttpTransportManager, InternalTransportManager

public interface ITransportManager

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 remote, Node local, 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 remote, Node local, java.lang.String securityToken, java.lang.String registrationUrl)
IIncomingTransport	getRegisterTransport(Node node, java.lang.String registrationUrl)
IIncomingTransport	getRegisterTransport(Node node, java.lang.String registrationUrl, java.util.Map<java.lang.String,java.lang.String> requestProperties)
java.util.List<BatchAck>	readAcknowledgement(java.lang.String parameterString1, java.lang.String parameterString2)
java.lang.String	resolveURL(java.lang.String url, java.lang.String registrationUrl) This is the proper way to determine the URL for a node.
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)

Method Detail

sendAcknowledgement

int sendAcknowledgement(Node remote,
                        java.util.List<IncomingBatch> list,
                        Node local,
                        java.lang.String securityToken,
                        java.lang.String registrationUrl)
                 throws java.io.IOException

Throws:

java.io.IOException

writeAcknowledgement

void writeAcknowledgement(java.io.OutputStream out,
                          Node remote,
                          java.util.List<IncomingBatch> list,
                          Node local,
                          java.lang.String securityToken)
                   throws java.io.IOException

Throws:

java.io.IOException

readAcknowledgement

java.util.List<BatchAck> readAcknowledgement(java.lang.String parameterString1,
                                             java.lang.String parameterString2)
                                      throws java.io.IOException

Throws:

java.io.IOException

getFilePullTransport

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

Throws:

java.io.IOException

getFilePushTransport

IOutgoingWithResponseTransport getFilePushTransport(Node remote,
                                                    Node local,
                                                    java.lang.String securityToken,
                                                    java.lang.String registrationUrl)
                                             throws java.io.IOException

Throws:

java.io.IOException

getPullTransport

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

Throws:

java.io.IOException

getPingTransport

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

Throws:

java.io.IOException

getPushTransport

IOutgoingWithResponseTransport getPushTransport(Node remote,
                                                Node local,
                                                java.lang.String securityToken,
                                                java.lang.String registrationUrl)
                                         throws java.io.IOException

Throws:

java.io.IOException

getPushTransport

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

Throws:

java.io.IOException

getRegisterTransport

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

Throws:

java.io.IOException

getRegisterTransport

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

Throws:

java.io.IOException

getConfigTransport

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

Throws:

java.io.IOException

getBandwidthPushTransport

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

Throws:

java.io.IOException

resolveURL

java.lang.String resolveURL(java.lang.String url,
                            java.lang.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 java.io.IOException

Throws:

java.io.IOException

sendStatusRequest

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

Throws:

java.io.IOException