Package org.medcare.igtl.network

Class OpenIGTClient

java.lang.Object

java.lang.Thread

org.medcare.igtl.network.OpenIGTClient

All Implemented Interfaces:

Runnable

Direct Known Subclasses:

GenericIGTLinkClient

public abstract class OpenIGTClient
extends Thread

The class can be used by first connecting to a server sending requests comming from the requestQueue, listening for response and adding response to the responsqueue

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
ErrorManager	errorManager

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor	Description
OpenIGTClient(String host, int port, ErrorManager errorManager)	Default OpenIGTClient constructor.

Method Summary

Modifier and Type	Method	Description
abstract ResponseHandler	getResponseHandler(Header header, byte[] bodyBuf)	** To get response Handler
Status	getStatus()	** To set server status **
void	interrupt()	Interrupt this thread
boolean	isConnected()
void	run()	Reader thread.
final boolean	sendBytes(byte[] bytes)	Sends bytes
void	sendMessage(OpenIGTMessage message)
void	sendMessage(Header header, byte[] body)
void	setSocketFactory(SocketFactory socketFactory)
void	setStatus(Status status)	** To set server status

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, 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

errorManager

public ErrorManager errorManager

Constructor Details

OpenIGTClient

public OpenIGTClient(String host,
 int port,
 ErrorManager errorManager)
              throws UnknownHostException,
IOException

Default OpenIGTClient constructor.

Parameters:

host - to be connected

port - of the host

errorManager - main class running this client

Throws:

IOException

UnknownHostException

Method Details

run

public void run()

Reader thread. Reads messages from the socket and add them to the ResponseQueueManager

Specified by:

run in interface Runnable

Overrides:

run in class Thread

setSocketFactory

public void setSocketFactory(SocketFactory socketFactory)

sendMessage

public void sendMessage(OpenIGTMessage message)
                 throws Exception

Throws:

Exception

sendMessage

public void sendMessage(Header header,
 byte[] body)
                 throws Exception

Throws:

Exception

sendBytes

public final boolean sendBytes(byte[] bytes)
                        throws IOException

Sends bytes

Parameters:

bytes - - byte[] array.

Throws:

IOException - - Exception in I/O.

interrupt

public void interrupt()

Interrupt this thread

Overrides:

interrupt in class Thread

getStatus

public Status getStatus()

** To set server status **

Returns:

the status status

setStatus

public void setStatus(Status status)

** To set server status

Parameters:

status - **

getResponseHandler

public abstract ResponseHandler getResponseHandler(Header header,
 byte[] bodyBuf)

** To get response Handler

Parameters:

header - header of the message received

bodyBuf - byte array of the body of the message received **

Returns:

the response Handler

isConnected

public boolean isConnected()