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 and Description
protected ISymmetricEngine	engine
protected boolean	isHttp2Enabled
protected static org.slf4j.Logger	log
protected java.util.Map<java.lang.String,java.lang.String>	sessionIdByUri
protected boolean	useHeaderSecurityToken
protected boolean	useSessionAuth

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

extensionService

Constructor Summary

Constructors

Constructor and Description
HttpTransportManager()
HttpTransportManager(ISymmetricEngine engine)

Method Summary

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

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

append, getAcknowledgementData, getParametersFromQueryUrl, readAcknowledgement, readAcknowledgement, readAcknowledgement, resolveURL

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, resolveURL

Field Detail

log

protected static final org.slf4j.Logger log

engine

protected ISymmetricEngine engine

sessionIdByUri

protected java.util.Map<java.lang.String,java.lang.String> sessionIdByUri

useHeaderSecurityToken

protected boolean useHeaderSecurityToken

useSessionAuth

protected boolean useSessionAuth

isHttp2Enabled

protected boolean isHttp2Enabled

Constructor Detail

HttpTransportManager

public HttpTransportManager()

HttpTransportManager

public HttpTransportManager(ISymmetricEngine engine)

Method Detail

sendCopyRequest

public int sendCopyRequest(Node local)
                    throws java.io.IOException

Specified by:

sendCopyRequest in interface ITransportManager

Throws:

java.io.IOException

sendStatusRequest

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

Specified by:

sendStatusRequest in interface ITransportManager

Throws:

java.io.IOException

sendAcknowledgement

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

Specified by:

sendAcknowledgement in interface ITransportManager

Throws:

java.io.IOException

writeAcknowledgement

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

Specified by:

writeAcknowledgement in interface ITransportManager

Throws:

java.io.IOException

sendMessage

protected int sendMessage(java.lang.String action,
                          Node remote,
                          Node local,
                          java.lang.String data,
                          java.lang.String securityToken,
                          java.lang.String registrationUrl)
                   throws java.io.IOException

Throws:

java.io.IOException

sendMessage

protected int sendMessage(java.net.URL url,
                          java.lang.String nodeId,
                          java.lang.String securityToken,
                          java.lang.String data)
                   throws java.io.IOException

Throws:

java.io.IOException

checkForConnectionUpgrade

protected void checkForConnectionUpgrade(HttpConnection conn)

openConnection

public HttpConnection openConnection(java.net.URL url,
                                     java.lang.String nodeId,
                                     java.lang.String securityToken)
                              throws java.io.IOException

Throws:

java.io.IOException

updateSession

public void updateSession(HttpConnection conn)

clearSession

public void clearSession(HttpConnection conn)

getUri

protected java.lang.String getUri(HttpConnection conn)

getOutputStreamSize

public int getOutputStreamSize()

isOutputStreamEnabled

public boolean isOutputStreamEnabled()

getHttpTimeOutInMs

public int getHttpTimeOutInMs()

isUseCompression

public boolean isUseCompression(Node targetNode)

getCompressionLevel

public int getCompressionLevel()

getCompressionStrategy

public int getCompressionStrategy()

writeMessage

public void writeMessage(java.io.OutputStream out,
                         java.lang.String data)
                  throws java.io.IOException

Throws:

java.io.IOException

getFilePullTransport

public 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

Specified by:

getFilePullTransport in interface ITransportManager

Throws:

java.io.IOException

getPullTransport

public 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

Specified by:

getPullTransport in interface ITransportManager

Throws:

java.io.IOException

getPingTransport

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

Specified by:

getPingTransport in interface ITransportManager

Throws:

java.io.IOException

getPushTransport

public 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

Specified by:

getPushTransport in interface ITransportManager

Throws:

java.io.IOException

getPushTransport

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

Specified by:

getPushTransport in interface ITransportManager

Throws:

java.io.IOException

getFilePushTransport

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

Specified by:

getFilePushTransport in interface ITransportManager

Throws:

java.io.IOException

getConfigTransport

public 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

Specified by:

getConfigTransport in interface ITransportManager

Throws:

java.io.IOException

getRegisterTransport

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

Specified by:

getRegisterTransport in interface ITransportManager

Throws:

java.io.IOException

getRegisterTransport

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

Specified by:

getRegisterTransport in interface ITransportManager

Throws:

java.io.IOException

getBandwidthPushTransport

public 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

Specified by:

getBandwidthPushTransport in interface ITransportManager

Throws:

java.io.IOException

buildRegistrationUrl

public static java.lang.String buildRegistrationUrl(java.lang.String baseUrl,
                                                    Node node)
                                             throws java.io.IOException

Throws:

java.io.IOException

buildRegistrationRequestProperties

public static java.util.Map<java.lang.String,java.lang.String> buildRegistrationRequestProperties(Node node,
                                                                                                  java.util.Map<java.lang.String,java.lang.String> prop)

createGetConnectionFor

protected HttpConnection createGetConnectionFor(java.net.URL url,
                                                java.lang.String nodeId,
                                                java.lang.String securityToken)
                                         throws java.io.IOException

Throws:

java.io.IOException

createGetConnectionFor

protected HttpConnection createGetConnectionFor(java.net.URL url)
                                         throws java.io.IOException

Throws:

java.io.IOException

getInputStreamFrom

protected static java.io.InputStream getInputStreamFrom(HttpConnection connection)
                                                 throws java.io.IOException

Throws:

java.io.IOException

getReaderFrom

protected static java.io.BufferedReader getReaderFrom(HttpConnection connection)
                                               throws java.io.IOException

If the content is gzip'd, then uncompress.

Throws:

java.io.IOException

buildURL

protected java.lang.String buildURL(java.lang.String action,
                                    Node remote,
                                    Node local,
                                    java.lang.String securityToken,
                                    java.lang.String registrationUrl)
                             throws java.io.IOException

Build a url for an action.

Throws:

java.io.IOException

addNodeInfo

protected java.lang.String addNodeInfo(java.lang.String base,
                                       java.lang.String nodeId,
                                       java.lang.String securityToken,
                                       boolean forceParamSecurityToken)

addNodeId

protected java.lang.String addNodeId(java.lang.String base,
                                     java.lang.String nodeId,
                                     java.lang.String connector)

add

protected java.lang.String add(java.lang.String base,
                               java.lang.String key,
                               java.lang.String value,
                               java.lang.String connector)

getEngine

protected ISymmetricEngine getEngine()