org.jumpmind.symmetric.transport.internal
Class InternalTransportManager

java.lang.Object
  org.jumpmind.symmetric.transport.AbstractTransportManager
      org.jumpmind.symmetric.transport.internal.InternalTransportManager

All Implemented Interfaces:

ITransportManager

public class InternalTransportManager
extends AbstractTransportManager
implements ITransportManager

Coordinates interaction between two symmetric engines in the same JVM.

Constructor Summary

InternalTransportManager(INodeService nodeService, IParameterService config)

Method Summary

IIncomingTransport	getPullTransport(Node remote, Node local)
IOutgoingWithResponseTransport	getPushTransport(Node remote, Node local)
IIncomingTransport	getRegisterTransport(Node client)
boolean	sendAcknowledgement(Node remote, java.util.List<IncomingBatchHistory> list, Node local)
void	writeAcknowledgement(java.io.OutputStream out, java.util.List<IncomingBatchHistory> list)

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

append, getAcknowledgementData, getParametersFromQueryUrl, readAcknowledgement, readAcknowledgement, readAcknowledgement

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

Constructor Detail

InternalTransportManager

public InternalTransportManager(INodeService nodeService,
                                IParameterService config)

Method Detail

getPullTransport

public IIncomingTransport getPullTransport(Node remote,
                                           Node local)
                                    throws java.io.IOException

Specified by:

getPullTransport in interface ITransportManager

Throws:

java.io.IOException

getPushTransport

public IOutgoingWithResponseTransport getPushTransport(Node remote,
                                                       Node local)
                                                throws java.io.IOException

Specified by:

getPushTransport in interface ITransportManager

Throws:

java.io.IOException

getRegisterTransport

public IIncomingTransport getRegisterTransport(Node client)
                                        throws java.io.IOException

Specified by:

getRegisterTransport in interface ITransportManager

Throws:

java.io.IOException

sendAcknowledgement

public boolean sendAcknowledgement(Node remote,
                                   java.util.List<IncomingBatchHistory> list,
                                   Node local)
                            throws java.io.IOException

Specified by:

sendAcknowledgement in interface ITransportManager

Throws:

java.io.IOException

writeAcknowledgement

public void writeAcknowledgement(java.io.OutputStream out,
                                 java.util.List<IncomingBatchHistory> list)
                          throws java.io.IOException

Specified by:

writeAcknowledgement in interface ITransportManager

Throws:

java.io.IOException