Package org.medcare.igtl.network

Class RequestQueueManager

java.lang.Object

java.lang.Thread

org.medcare.igtl.network.RequestQueueManager

All Implemented Interfaces:

Runnable

public class RequestQueueManager
extends Thread

RequestQueueManager create its own OpenIGTClient connected to one OpenIGTServer. Application add Messages request to RequestQueueManager queue. OpenIGTClient will send Messages to its OpenIGTServer respecting the order.

Nested Class Summary

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

Thread.BuilderPREVIEW, Thread.State, Thread.UncaughtExceptionHandler

Field Summary

Fields

Modifier and Type	Field	Description
ConcurrentLinkedQueue<byte[]>	openIGT_Queue

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor	Description
RequestQueueManager(OpenIGTClient openIGTClient)	Default RequestQueueManager constructor.

Method Summary

Modifier and Type	Method	Description
void	addRequest(byte[] request)	add a new request to the request queue
void	destroy()	stop the thread
long	getSleepTime()	** Gets the current sleep time value return@ The sleep time value
String	getVersion()	** Gets the current version return@ The version value
void	run()	Starts the thread and process requests in queue
void	setSleepTime(long sleep)	Sets the time the listener thread will wait between actions

Methods inherited from class java.lang.Thread

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

Methods inherited from class java.lang.Object

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

Field Details

openIGT_Queue

public ConcurrentLinkedQueue<byte[]> openIGT_Queue

Constructor Details

RequestQueueManager

public RequestQueueManager(OpenIGTClient openIGTClient)

Default RequestQueueManager constructor.

Parameters:

openIGTClient - managing this connection

Method Details

run

public void run()

Starts the thread and process requests in queue

Specified by:

run in interface Runnable

Overrides:

run in class Thread

addRequest

public void addRequest(byte[] request)

add a new request to the request queue

Parameters:

request -

destroy

public void destroy()

stop the thread

getSleepTime

public long getSleepTime()

** Gets the current sleep time value return@ The sleep time value

setSleepTime

public void setSleepTime(long sleep)

Sets the time the listener thread will wait between actions

Parameters:

sleep -

getVersion

public String getVersion()

** Gets the current version return@ The version value