Package org.jumpmind.symmetric.transport

Class MockTransportManager

java.lang.Object

org.jumpmind.symmetric.transport.MockTransportManager

All Implemented Interfaces:

ITransportManager

public class MockTransportManager
extends Object
implements ITransportManager

Field Summary

Fields

Modifier and Type	Field	Description
protected IIncomingTransport	incomingTransport
protected IOutgoingWithResponseTransport	outgoingTransport

Constructor Summary

Constructors

Constructor	Description
MockTransportManager()

Method Summary

Modifier and Type	Method	Description
void	addExtensionSyncUrlHandler(String name, ISyncUrlExtension handler)
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)
IIncomingTransport	getConfigTransport(Node remote, Node local, String securityToken, String symmetricVersion, String configVersion, String registrationUrl)
IIncomingTransport	getFilePullTransport(Node remote, Node local, String securityToken, Map<String,String> requestProperties, String registrationUrl)
IOutgoingWithResponseTransport	getFilePushTransport(Node remote, Node local, String securityToken, String registrationUrl)
IIncomingTransport	getIncomingTransport()
IOutgoingWithResponseTransport	getOutgoingTransport()
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)
IOutgoingWithResponseTransport	getRegisterPushTransport(Node remote, Node local)
IIncomingTransport	getRegisterTransport(Node node, String registrationUrl)
IIncomingTransport	getRegisterTransport(Node node, String registrationUrl, Map<String,String> requestProperties)
List<BatchAck>	readAcknowledgement(String parameterString)
List<BatchAck>	readAcknowledgement(String parameterString1, String parameterString2)
List<BatchAck>	readAcknowledgement(Map<String,Object> parameters)
Map<String,String>	readRequestProperties(InputStream is)
String	resolveURL(String url, String registrationUrl)	This is the proper way to determine the URL for a node.
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)
int	sendStatusRequest(Node local, Map<String,String> statuses)
void	setIncomingTransport(IIncomingTransport is)
void	setOutgoingTransport(IOutgoingWithResponseTransport outgoingTransport)
void	writeAcknowledgement(OutputStream out, Node remote, List<IncomingBatch> list, Node local, String securityToken)
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

incomingTransport

protected IIncomingTransport incomingTransport

outgoingTransport

protected IOutgoingWithResponseTransport outgoingTransport

Constructor Details

MockTransportManager

public MockTransportManager()

Method Details

resolveURL

public String resolveURL(String url,
 String registrationUrl)

Description copied from interface: ITransportManager

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.

Specified by:

resolveURL in interface ITransportManager

Parameters:

url - This is the url configured in sync_url of the node table

addExtensionSyncUrlHandler

public void addExtensionSyncUrlHandler(String name,
 ISyncUrlExtension handler)

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

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

getPushTransport

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

Specified by:

getPushTransport 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

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

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

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

getIncomingTransport

public IIncomingTransport getIncomingTransport()

setIncomingTransport

public void setIncomingTransport(IIncomingTransport is)

getOutgoingTransport

public IOutgoingWithResponseTransport getOutgoingTransport()

setOutgoingTransport

public void setOutgoingTransport(IOutgoingWithResponseTransport outgoingTransport)

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

readAcknowledgement

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

Throws:

IOException

readAcknowledgement

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

readAcknowledgement

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

Specified by:

readAcknowledgement 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

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

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

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

writeRequestProperties

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

Specified by:

writeRequestProperties in interface ITransportManager

Throws:

IOException

readRequestProperties

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

Specified by:

readRequestProperties 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