Package org.jumpmind.symmetric.transport.http

Class HttpTransportManager

java.lang.Object

org.jumpmind.symmetric.transport.AbstractTransportManager

org.jumpmind.symmetric.transport.http.HttpTransportManager

All Implemented Interfaces:

ITransportManager

Direct Known Subclasses:

FileTransportManager

public class HttpTransportManager
extends AbstractTransportManager
implements ITransportManager

Allow remote communication to nodes, in order to push data, pull data, and send messages.

Field Summary

Fields

Modifier and Type	Field	Description
protected ISymmetricEngine	engine
protected Map<String,String>	sessionIdByUri
protected boolean	useHeaderSecurityToken
protected boolean	useSessionAuth

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

extensionService

Constructor Summary

Constructors

Constructor	Description
HttpTransportManager()
HttpTransportManager(ISymmetricEngine engine)

Method Summary

Modifier and Type	Method	Description
protected String	add(String base, String key, String value, String connector)
protected String	addNodeId(String base, String nodeId, String connector)
protected String	addNodeInfo(String base, String nodeId, String securityToken, boolean forceParamSecurityToken)
static String	buildRegistrationUrl(String baseUrl, Node node)
protected String	buildURL(String action, Node remote, Node local, String securityToken, String registrationUrl)	Build a url for an action.
protected void	checkForConnectionUpgrade(HttpConnection conn)
void	clearSession(HttpConnection conn)
protected HttpConnection	createGetConnectionFor(URL url)
protected HttpConnection	createGetConnectionFor(URL url, String nodeId, String securityToken)
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)
int	getCompressionLevel()
int	getCompressionStrategy()
IIncomingTransport	getConfigTransport(Node remote, Node local, String securityToken, String symmetricVersion, String configVersion, String registrationUrl)
protected ISymmetricEngine	getEngine()
IIncomingTransport	getFilePullTransport(Node remote, Node local, String securityToken, Map<String,String> requestProperties, String registrationUrl)
IOutgoingWithResponseTransport	getFilePushTransport(Node remote, Node local, String securityToken, String registrationUrl)
int	getHttpConnectTimeOutInMs()
int	getHttpTimeOutInMs()
protected static InputStream	getInputStreamFrom(HttpConnection connection)
int	getOutputStreamSize()
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)
protected static BufferedReader	getReaderFrom(HttpConnection connection)	If the content is gzip'd, then uncompress.
IOutgoingWithResponseTransport	getRegisterPushTransport(Node remote, Node local)
IIncomingTransport	getRegisterTransport(Node node, String registrationUrl)
IIncomingTransport	getRegisterTransport(Node node, String registrationUrl, Map<String,String> requestProperties)
protected String	getUri(HttpConnection conn)
boolean	isOutputStreamEnabled()
boolean	isUseCompression(Node targetNode)
HttpConnection	openConnection(URL url, String nodeId, String securityToken)
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)
protected int	sendMessage(String action, Node remote, Node local, String data, String securityToken, Map<String,String> requestProperties, String registrationUrl)
protected int	sendMessage(URL url, String nodeId, String securityToken, Map<String,String> requestProperties, String data)
int	sendStatusRequest(Node local, Map<String,String> statuses)
void	updateSession(HttpConnection conn)
void	writeAcknowledgement(OutputStream out, Node remote, List<IncomingBatch> list, Node local, String securityToken)
void	writeMessage(OutputStream out, String data)

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

engine

protected ISymmetricEngine engine

sessionIdByUri

protected Map<String,String> sessionIdByUri

useHeaderSecurityToken

protected boolean useHeaderSecurityToken

useSessionAuth

protected boolean useSessionAuth

Constructor Details

HttpTransportManager

public HttpTransportManager()

HttpTransportManager

public HttpTransportManager(ISymmetricEngine engine)

Method Details

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

sendMessage

protected int sendMessage(String action,
 Node remote,
 Node local,
 String data,
 String securityToken,
 Map<String,String> requestProperties,
 String registrationUrl)
                   throws IOException

Throws:

IOException

sendMessage

protected int sendMessage(URL url,
 String nodeId,
 String securityToken,
 Map<String,String> requestProperties,
 String data)
                   throws IOException

Throws:

IOException

checkForConnectionUpgrade

protected void checkForConnectionUpgrade(HttpConnection conn)

openConnection

public HttpConnection openConnection(URL url,
 String nodeId,
 String securityToken)
                              throws IOException

Throws:

IOException

updateSession

public void updateSession(HttpConnection conn)

clearSession

public void clearSession(HttpConnection conn)

getUri

protected String getUri(HttpConnection conn)

getOutputStreamSize

public int getOutputStreamSize()

isOutputStreamEnabled

public boolean isOutputStreamEnabled()

getHttpTimeOutInMs

public int getHttpTimeOutInMs()

getHttpConnectTimeOutInMs

public int getHttpConnectTimeOutInMs()

isUseCompression

public boolean isUseCompression(Node targetNode)

getCompressionLevel

public int getCompressionLevel()

getCompressionStrategy

public int getCompressionStrategy()

writeMessage

public void writeMessage(OutputStream out,
 String data)
                  throws IOException

Throws:

IOException

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 remote,
 Node local,
 String securityToken,
 Map<String,String> requestProperties,
 String registrationUrl)
                                                throws IOException

Specified by:

getPushTransport in interface ITransportManager

Throws:

IOException

getPushTransport

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

Specified by:

getPushTransport in interface ITransportManager

Throws:

IOException

getFilePushTransport

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

Specified by:

getFilePushTransport 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

getRegisterTransport

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

Specified by:

getRegisterTransport in interface ITransportManager

Throws:

IOException

getRegisterTransport

public IIncomingTransport getRegisterTransport(Node node,
 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

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

buildRegistrationUrl

public static String buildRegistrationUrl(String baseUrl,
 Node node)

createGetConnectionFor

protected HttpConnection createGetConnectionFor(URL url,
 String nodeId,
 String securityToken)
                                         throws IOException

Throws:

IOException

createGetConnectionFor

protected HttpConnection createGetConnectionFor(URL url)
                                         throws IOException

Throws:

IOException

getInputStreamFrom

protected static InputStream getInputStreamFrom(HttpConnection connection)
                                         throws IOException

Throws:

IOException

getReaderFrom

protected static BufferedReader getReaderFrom(HttpConnection connection)
                                       throws IOException

If the content is gzip'd, then uncompress.

Throws:

IOException

buildURL

protected String buildURL(String action,
 Node remote,
 Node local,
 String securityToken,
 String registrationUrl)
                   throws IOException

Build a url for an action.

Throws:

IOException

addNodeInfo

protected String addNodeInfo(String base,
 String nodeId,
 String securityToken,
 boolean forceParamSecurityToken)

addNodeId

protected String addNodeId(String base,
 String nodeId,
 String connector)

add

protected String add(String base,
 String key,
 String value,
 String connector)

getEngine

protected ISymmetricEngine getEngine()