public abstract class AbstractXSHub<T1 extends XSDataPacket<?,?>,T2 extends XSDataPacket<?,?>> extends AbstractXSRunnableXSWritable<T1> implements XSHub<T1,T2>
Constructor and Description |
---|
AbstractXSHub(java.lang.String name,
CommunicationType communicationType) |
Modifier and Type | Method and Description |
---|---|
void |
connect(XSWritable<T2> writable)
Connect to the XSWritable object
|
void |
disconnect(XSWritable<T2> writable)
Disconnect from a XSWritable object
|
long |
getNumberOfPacketsSend()
Get the total number of packets send so far.
|
java.util.List<XSWritable<T2>> |
getWritables()
Get all writables to which this writer is currently connected
|
XSWriter<T2> |
getWriterDelegate() |
protected void |
handleNextPacket(T1 packet) |
void |
run() |
protected abstract T2 |
transform(T1 packet) |
void |
write(T2 dataPacket)
Write onto all writable currently connected
|
deliver, getCommunicationType, getDeliveryLock, getHandlingTimes, getLatestWritingThread, getMemoryUsage, getNextHandlingTimeIndex, getNextMemoryUsageIndex, getNextPacket, getNumberOfPacketsReceived, getPacketHandlingTimes, getPerformanceTrackerStepSize, getUsedMemory, isTrackingPerformance, isTrackPerformance, measureUsedMemory, setHandlingTimes, setLatestWritingThread, setMemoryUsage, setNextHandlingTimeIndex, setNextMemoryUsageIndex, setPerformanceTrackerStepSize, setTrackPerformance, storeNewPacket, triggerPacketHandle, workPackage
interrupt, isPaused, isRunning, isStarted, isStopped, pause, pauseXSRunnable, start, startXSRunnable, stopXSRunnable
activeCount, checkAccess, clone, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, stop, stop, suspend, toString, yield
equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
getName, interrupt, isPaused, isRunning, isStarted, isStopped, pause, pauseXSRunnable, start, startXSRunnable, stop, stopXSRunnable
deliver, getCommunicationType, getDeliveryLock, getNumberOfPacketsReceived, getPacketHandlingTimes, getUsedMemory, isTrackingPerformance, setPerformanceTrackerStepSize, setTrackPerformance, triggerPacketHandle
public AbstractXSHub(java.lang.String name, CommunicationType communicationType)
public void connect(XSWritable<T2> writable)
XSWriter
connect
in interface XSWriter<T2 extends XSDataPacket<?,?>>
writable
- to connect ontopublic void disconnect(XSWritable<T2> writable)
XSWriter
disconnect
in interface XSWriter<T2 extends XSDataPacket<?,?>>
writable
- to disconnect frompublic void write(T2 dataPacket)
XSWriter
write
in interface XSWriter<T2 extends XSDataPacket<?,?>>
dataPacket
- to writepublic long getNumberOfPacketsSend()
XSWriter
getNumberOfPacketsSend
in interface XSWriter<T2 extends XSDataPacket<?,?>>
public java.util.List<XSWritable<T2>> getWritables()
XSWriter
getWritables
in interface XSWriter<T2 extends XSDataPacket<?,?>>
protected void handleNextPacket(T1 packet)
handleNextPacket
in class AbstractXSRunnableXSWritable<T1 extends XSDataPacket<?,?>>
public final void run()
run
in interface java.lang.Runnable
run
in class AbstractXSRunnable