Package org.jumpmind.symmetric.transport

Class AbstractTransportManager

java.lang.Object

org.jumpmind.symmetric.transport.AbstractTransportManager

Direct Known Subclasses:

HttpTransportManager, InternalTransportManager

public abstract class AbstractTransportManager
extends Object

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor	Description
AbstractTransportManager()
AbstractTransportManager(IExtensionService extensionService)

Method Summary

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

Methods inherited from class java.lang.Object

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

Field Details

log

protected final org.slf4j.Logger log

extensionService

protected IExtensionService extensionService

Constructor Details

AbstractTransportManager

public AbstractTransportManager()

AbstractTransportManager

public AbstractTransportManager(IExtensionService extensionService)

Method Details

resolveURL

public String resolveURL(String syncUrl,
 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 String getAcknowledgementData(boolean requires13Format,
 String nodeId,
 List<IncomingBatch> list)
                                 throws IOException

Throws:

IOException

append

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

readAcknowledgement

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

Throws:

IOException

readAcknowledgement

public List<BatchAck> readAcknowledgement(String parameterString)
                                   throws IOException

Throws:

IOException

readAcknowledgement

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

writeRequestProperties

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

Throws:

IOException

readRequestProperties

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

Throws:

IOException

getParametersFromQueryUrl

protected Map<String,String> getParametersFromQueryUrl(String parameterString)
                                                throws IOException

Throws:

IOException