org.jumpmind.symmetric

Class SymmetricPushClient

java.lang.Object

org.jumpmind.symmetric.SymmetricPushClient

public class SymmetricPushClient
extends java.lang.Object

Field Summary

Fields

Modifier and Type	Field and Description
protected org.jumpmind.symmetric.io.data.Batch	batch
protected static org.slf4j.Logger	log
protected java.lang.String	nodeId
protected java.lang.String	securityToken
protected java.lang.String	syncUrl
protected HttpOutgoingTransport	transport
protected org.jumpmind.symmetric.io.data.writer.ProtocolDataWriter	writer

Constructor Summary

Constructors

Constructor and Description
SymmetricPushClient(java.lang.String nodeId, java.lang.String securityToken, java.lang.String syncUrl)

Method Summary

Modifier and Type	Method and Description
protected java.lang.String	buildUrl()
BatchAck	close()
void	delete(org.jumpmind.db.model.Table table, java.lang.String[] pkData)
void	insert(org.jumpmind.db.model.Table table, java.lang.String[] data)
void	open()
void	update(org.jumpmind.db.model.Table table, java.lang.String[] data, java.lang.String[] pkData)

Methods inherited from class java.lang.Object

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

Field Detail

log

protected static final org.slf4j.Logger log

nodeId

protected java.lang.String nodeId

securityToken

protected java.lang.String securityToken

syncUrl

protected java.lang.String syncUrl

transport

protected HttpOutgoingTransport transport

writer

protected org.jumpmind.symmetric.io.data.writer.ProtocolDataWriter writer

batch

protected org.jumpmind.symmetric.io.data.Batch batch

Constructor Detail

SymmetricPushClient

public SymmetricPushClient(java.lang.String nodeId,
                           java.lang.String securityToken,
                           java.lang.String syncUrl)

Method Detail

open

public void open()

close

public BatchAck close()

insert

public void insert(org.jumpmind.db.model.Table table,
                   java.lang.String[] data)

update

public void update(org.jumpmind.db.model.Table table,
                   java.lang.String[] data,
                   java.lang.String[] pkData)

delete

public void delete(org.jumpmind.db.model.Table table,
                   java.lang.String[] pkData)

buildUrl

protected java.lang.String buildUrl()