org.jumpmind.symmetric.transport

Class AbstractTransportManager

java.lang.Object

org.jumpmind.symmetric.transport.AbstractTransportManager

Direct Known Subclasses:

HttpTransportManager, InternalTransportManager

public abstract class AbstractTransportManager
extends java.lang.Object

Field Summary

Fields

Modifier and Type	Field and Description
protected IExtensionService	extensionService
protected org.slf4j.Logger	log

Constructor Summary

Constructors

Constructor and Description
AbstractTransportManager()
AbstractTransportManager(IExtensionService extensionService)

Method Summary

Modifier and Type	Method and Description
protected static void	append(java.lang.StringBuilder builder, java.lang.String name, java.lang.Object value)
protected java.lang.String	getAcknowledgementData(boolean requires13Format, java.lang.String nodeId, java.util.List<IncomingBatch> list)
protected static java.util.Map<java.lang.String,java.lang.Object>	getParametersFromQueryUrl(java.lang.String parameterString)
static java.util.List<BatchAck>	readAcknowledgement(java.util.Map<java.lang.String,? extends java.lang.Object> parameters)
java.util.List<BatchAck>	readAcknowledgement(java.lang.String parameterString)
java.util.List<BatchAck>	readAcknowledgement(java.lang.String parameterString1, java.lang.String parameterString2)
java.lang.String	resolveURL(java.lang.String syncUrl, java.lang.String registrationUrl) Build the url for remote node communication.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

log

protected final org.slf4j.Logger log

extensionService

protected IExtensionService extensionService

Constructor Detail

AbstractTransportManager

public AbstractTransportManager()

AbstractTransportManager

public AbstractTransportManager(IExtensionService extensionService)

Method Detail

resolveURL

public java.lang.String resolveURL(java.lang.String syncUrl,
                                   java.lang.String registrationUrl)

Build the url for remote node communication. Use the remote sync_url first, if it is null or blank, then use the registration url instead.

getAcknowledgementData

protected java.lang.String getAcknowledgementData(boolean requires13Format,
                                                  java.lang.String nodeId,
                                                  java.util.List<IncomingBatch> list)
                                           throws java.io.IOException

Throws:

java.io.IOException

append

protected static void append(java.lang.StringBuilder builder,
                             java.lang.String name,
                             java.lang.Object value)

readAcknowledgement

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

Throws:

java.io.IOException

readAcknowledgement

public java.util.List<BatchAck> readAcknowledgement(java.lang.String parameterString)
                                             throws java.io.IOException

Throws:

java.io.IOException

readAcknowledgement

public static java.util.List<BatchAck> readAcknowledgement(java.util.Map<java.lang.String,? extends java.lang.Object> parameters)

getParametersFromQueryUrl

protected static java.util.Map<java.lang.String,java.lang.Object> getParametersFromQueryUrl(java.lang.String parameterString)
                                                                                     throws java.io.IOException

Throws:

java.io.IOException