oracle.lite.sync.queue

Class ConsolidatorQueueProcessor

java.lang.Object

oracle.lite.sync.queue.ConsolidatorQueueProcessor

public abstract class ConsolidatorQueueProcessor
extends java.lang.Object

Java interface for queues

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	ALL_PUBLICATIONS
static java.lang.String	ALL_SUBSCRIPTIONS
static java.lang.String	ALL_TEMPLATE_ITEMS
static java.lang.String	ALL_TEMPLATES
static java.lang.String	ALL_VPKS
static java.lang.String	EQ_CONTROL
static java.lang.String	EQ_DML_PREFIX
static java.lang.String	IN_DML_PREFIX
static java.lang.String	INQ_CONTROL
oracle.lite.sync.tracing.Logger	m_log
static java.lang.String	PUB_ITEMS_Q

Constructor Summary

Constructors

Constructor and Description
ConsolidatorQueueProcessor()

Method Summary

Methods

Modifier and Type	Method and Description
abstract void	downloadComplete(java.sql.Connection conn, java.sql.Connection rmtConn, java.lang.String clientid) Called after client has successfully disconnected from the mobile server
abstract void	downloadInit(java.sql.Connection conn, java.sql.Connection rmtConn, java.lang.String clientid, long lastTran, long currTran, java.lang.String highPrty) Called with pubListQ populated with pub items to be downloaded
abstract java.util.LinkedList	getPubListQ() Called by sync session after downloadInit() to get a list of publication items flags for complete refresh and optionally, for record count in each out queue.
abstract void	setPubListQ(java.util.LinkedList ll) Called before downloadInit() is called, to identify which publication items need to be synchronized.
abstract void	uploadComplete(java.sql.Connection conn, java.sql.Connection rmtConn, java.lang.String clientid, long tranid) Called after all records are uploaded

Methods inherited from class java.lang.Object

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

Field Detail

ALL_PUBLICATIONS

public static final java.lang.String ALL_PUBLICATIONS

See Also:

Constant Field Values

ALL_SUBSCRIPTIONS

public static final java.lang.String ALL_SUBSCRIPTIONS

See Also:

Constant Field Values

ALL_TEMPLATE_ITEMS

public static final java.lang.String ALL_TEMPLATE_ITEMS

See Also:

Constant Field Values

ALL_TEMPLATES

public static final java.lang.String ALL_TEMPLATES

See Also:

Constant Field Values

ALL_VPKS

public static final java.lang.String ALL_VPKS

See Also:

Constant Field Values

EQ_CONTROL

public static final java.lang.String EQ_CONTROL

See Also:

Constant Field Values

EQ_DML_PREFIX

public static final java.lang.String EQ_DML_PREFIX

See Also:

Constant Field Values

IN_DML_PREFIX

public static final java.lang.String IN_DML_PREFIX

See Also:

Constant Field Values

INQ_CONTROL

public static final java.lang.String INQ_CONTROL

See Also:

Constant Field Values

m_log

public oracle.lite.sync.tracing.Logger m_log

PUB_ITEMS_Q

public static final java.lang.String PUB_ITEMS_Q

See Also:

Constant Field Values

Constructor Detail

ConsolidatorQueueProcessor

public ConsolidatorQueueProcessor()

Method Detail

downloadComplete

public abstract void downloadComplete(java.sql.Connection conn,
                    java.sql.Connection rmtConn,
                    java.lang.String clientid)
                               throws java.lang.Throwable

Called after client has successfully disconnected from the mobile server

Parameters:

conn - mobile server connection

rmtConn - if publication resides on a separate db instance from the mobile server this will be not null

clientid - String

Throws:

java.lang.Throwable

downloadInit

public abstract void downloadInit(java.sql.Connection conn,
                java.sql.Connection rmtConn,
                java.lang.String clientid,
                long lastTran,
                long currTran,
                java.lang.String highPrty)
                           throws java.lang.Throwable

Called with pubListQ populated with pub items to be downloaded

Parameters:

conn - mobile server connection

rmtConn - if publication resides on a separate db instance from the mobile server this will be not null

clientid - String

lastTran - last acknowledge server transaction received by the client

currTran - current sync session download transaction id

highPrty - indicates whether or not client is performing a high priority sync

Throws:

java.lang.Throwable

getPubListQ

public abstract java.util.LinkedList getPubListQ()

Called by sync session after downloadInit() to get a list of publication items flags for complete refresh and optionally, for record count in each out queue.

Returns:

LinkedList of publication items to download

See Also:

setPubListQ(LinkedList)

setPubListQ

public abstract void setPubListQ(java.util.LinkedList ll)

Called before downloadInit() is called, to identify which publication items need to be synchronized. The queue interface implementation can use this list to prepare the client's out queue(s) for the publication items in the list.

Parameters:

ll - contains a LinkedList of QueueListRecord objects corresponding to each publication item

See Also:

QueueListRecord.QueueListRecord(String, String, int), QueueListRecord.QueueListRecord(String, String)

uploadComplete

public abstract void uploadComplete(java.sql.Connection conn,
                  java.sql.Connection rmtConn,
                  java.lang.String clientid,
                  long tranid)
                             throws java.lang.Throwable

Called after all records are uploaded

Parameters:

conn - mobile server connection

rmtConn - if publication resides on a separate db instance from the mobile server this will be not null

clientid - String

tranid - upload transaction id. This transaction id is used to identify records in the mobile server in queue

Throws:

java.lang.Throwable