org.openmrs.hl7

Class Hl7InArchivesMigrateThread

java.lang.Object

java.lang.Thread

org.openmrs.hl7.Hl7InArchivesMigrateThread

All Implemented Interfaces:

Runnable

public class Hl7InArchivesMigrateThread
extends Thread

Separate thread to move the hl7 in archives from the database tables to the filesystem. It is highly recommended to start this thread via DWRHL7Service as opposed to calling the thread's start() method to ensure the thread is started after making all the necessary checks.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	Hl7InArchivesMigrateThread.Status The different states this thread can be in at a given point during migration

Nested classes/interfaces inherited from class java.lang.Thread

Thread.State, Thread.UncaughtExceptionHandler

Field Summary

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor and Description
Hl7InArchivesMigrateThread() Constructor to initialize variables

Method Summary

Modifier and Type	Method and Description
static Integer	getDaysKept()
static Integer	getNumberOfFailedTransfers() Gets the number of failed transfers during migration, this could be that the system couldn't write them to the file system or couldn't be deleted from the database.
static Integer	getNumberTransferred()
static Hl7InArchivesMigrateThread.Status	getTransferStatus()
UserContext	getUserContext()
static boolean	isActive()
void	run()
static void	setActive(boolean active)
static void	setDaysKept(Integer daysKept)
static void	setProgressStatusMap(Map<String,Integer> progressStatusMap)
static void	setTransferStatus(Hl7InArchivesMigrateThread.Status transferStatus)
static void	stopMigration() convenience method to set transfer status and active flag to stop migration

Methods inherited from class java.lang.Thread

activeCount, checkAccess, clone, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, toString, yield

Methods inherited from class java.lang.Object

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

Constructor Detail

Hl7InArchivesMigrateThread

public Hl7InArchivesMigrateThread()

Constructor to initialize variables

Method Detail

setProgressStatusMap

public static void setProgressStatusMap(Map<String,Integer> progressStatusMap)

getDaysKept

public static Integer getDaysKept()

Returns:

the daysKept

setDaysKept

public static void setDaysKept(Integer daysKept)

Parameters:

daysKept - the daysKept to set

isActive

public static boolean isActive()

Returns:

the active

setActive

public static void setActive(boolean active)

Parameters:

active - the active to set

setTransferStatus

public static void setTransferStatus(Hl7InArchivesMigrateThread.Status transferStatus)

run

public void run()

Specified by:

run in interface Runnable

Overrides:

run in class Thread

See Also:

Runnable.run()

stopMigration

public static void stopMigration()

convenience method to set transfer status and active flag to stop migration

getTransferStatus

public static Hl7InArchivesMigrateThread.Status getTransferStatus()

Returns:

the transferStatus

getNumberTransferred

public static Integer getNumberTransferred()

Returns:

the numberTransferred at a given time during migration

getNumberOfFailedTransfers

public static Integer getNumberOfFailedTransfers()

Gets the number of failed transfers during migration, this could be that the system couldn't write them to the file system or couldn't be deleted from the database.

Returns:

the numberOfFailedTransfers

getUserContext

public UserContext getUserContext()

Returns:

the userContext