de.ipcon.db.bthandler

Class BTsHandler

java.lang.Object

de.ipcon.db.bthandler.BTsHandler

public class BTsHandler
extends java.lang.Object

BE AWARE THAT THIS CLASS STORES ITS PROGRESS INFO ONLY ON THE NODE WHERE THE INSTANCE IS USED! The progress info is NOT synchronized by the normal MyTISM sync mechanism.

Constructor Summary

Constructors

Constructor and Description
BTsHandler(DBManLocalI _dbm, java.lang.String _statusKey, BTHandlerI _task, java.lang.String _logPrefix)

Method Summary

Modifier and Type	Method and Description
java.lang.Long[]	getBOTsOfInterest()
java.lang.Long	getLastHandledBTId() BE AWARE THAT THE VALUE RETURNED HERE IS ONLY FOR THE NODE WHERE THIS METHOD IS CALLED!
static java.lang.String	getUnhandledBTsQuery(java.lang.Long lhbId, java.util.Date dateFrom, java.lang.Long[] botIds)
static java.lang.String	getUnhandledBTsQuery(java.lang.Long lhbId, java.util.Date dateFrom, java.lang.Long[] botIds, boolean countOnly)
void	handleUnhandledBTs() Handle all BTs that for some reason were not already handled.
void	markBTAsHandled(java.lang.Long idBT) Stores the idBT in the DB to memorize which BTs have already been handled (storing the last ID is enough as IDs are always ascending).
void	stop()

Methods inherited from class java.lang.Object

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

Constructor Detail

BTsHandler

public BTsHandler(DBManLocalI _dbm,
                  java.lang.String _statusKey,
                  BTHandlerI _task,
                  java.lang.String _logPrefix)

Method Detail

stop

public void stop()

handleUnhandledBTs

public void handleUnhandledBTs()
                        throws java.lang.InterruptedException

Handle all BTs that for some reason were not already handled.

Throws:

java.lang.InterruptedException

getLastHandledBTId

public java.lang.Long getLastHandledBTId()
                                  throws java.lang.NumberFormatException

BE AWARE THAT THE VALUE RETURNED HERE IS ONLY FOR THE NODE WHERE THIS METHOD IS CALLED! It is NOT synchronized by the normal MyTISM sync mechanism and thus always "node local".

Throws:

java.lang.NumberFormatException

getBOTsOfInterest

public java.lang.Long[] getBOTsOfInterest()

getUnhandledBTsQuery

public static java.lang.String getUnhandledBTsQuery(java.lang.Long lhbId,
                                                    java.util.Date dateFrom,
                                                    java.lang.Long[] botIds)

getUnhandledBTsQuery

public static java.lang.String getUnhandledBTsQuery(java.lang.Long lhbId,
                                                    java.util.Date dateFrom,
                                                    java.lang.Long[] botIds,
                                                    boolean countOnly)

markBTAsHandled

public void markBTAsHandled(java.lang.Long idBT)

Stores the idBT in the DB to memorize which BTs have already been handled (storing the last ID is enough as IDs are always ascending). BE AWARE THAT THIS VALUE IS ONLY SET ON THE NODE WHERE THIS METHOD IS CALLED! It is NOT synchronized by the normal MyTISM sync mechanism.