org.processmining.stream.core.abstracts

Class AbstractXSHub<T1 extends XSDataPacket<?,?>,T2 extends XSDataPacket<?,?>>

java.lang.Object

java.lang.Thread

org.processmining.stream.core.abstracts.AbstractXSRunnable

org.processmining.stream.core.abstracts.AbstractXSRunnableXSWritable<T1>

org.processmining.stream.core.abstracts.AbstractXSHub<T1,T2>

All Implemented Interfaces:

java.lang.Runnable, XSHub<T1,T2>, XSRunnable, XSWritable<T1>, XSWriter<T2>

Direct Known Subclasses:

AbstractXSStream

public abstract class AbstractXSHub<T1 extends XSDataPacket<?,?>,T2 extends XSDataPacket<?,?>>
extends AbstractXSRunnableXSWritable<T1>
implements XSHub<T1,T2>

Nested Class Summary

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

java.lang.Thread.State, java.lang.Thread.UncaughtExceptionHandler

Field Summary

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor and Description
AbstractXSHub(java.lang.String name, CommunicationType communicationType)

Method Summary

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

Methods inherited from class org.processmining.stream.core.abstracts.AbstractXSRunnableXSWritable

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

Methods inherited from class org.processmining.stream.core.abstracts.AbstractXSRunnable

interrupt, isPaused, isRunning, isStarted, isStopped, pause, pauseXSRunnable, start, startXSRunnable, stopXSRunnable

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, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, stop, stop, suspend, toString, yield

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.processmining.stream.core.interfaces.XSRunnable

getName, interrupt, isPaused, isRunning, isStarted, isStopped, pause, pauseXSRunnable, start, startXSRunnable, stop, stopXSRunnable

Methods inherited from interface org.processmining.stream.core.interfaces.XSWritable

deliver, getCommunicationType, getDeliveryLock, getNumberOfPacketsReceived, getPacketHandlingTimes, getUsedMemory, isTrackingPerformance, setPerformanceTrackerStepSize, setTrackPerformance, triggerPacketHandle

Constructor Detail

AbstractXSHub

public AbstractXSHub(java.lang.String name,
                     CommunicationType communicationType)

Method Detail

getWriterDelegate

public XSWriter<T2> getWriterDelegate()

connect

public void connect(XSWritable<T2> writable)

Description copied from interface: XSWriter

Connect to the XSWritable object

Specified by:

connect in interface XSWriter<T2 extends XSDataPacket<?,?>>

Parameters:

writable - to connect onto

disconnect

public void disconnect(XSWritable<T2> writable)

Description copied from interface: XSWriter

Disconnect from a XSWritable object

Specified by:

disconnect in interface XSWriter<T2 extends XSDataPacket<?,?>>

Parameters:

writable - to disconnect from

write

public void write(T2 dataPacket)

Description copied from interface: XSWriter

Write onto all writable currently connected

Specified by:

write in interface XSWriter<T2 extends XSDataPacket<?,?>>

Parameters:

dataPacket - to write

getNumberOfPacketsSend

public long getNumberOfPacketsSend()

Description copied from interface: XSWriter

Get the total number of packets send so far.

Specified by:

getNumberOfPacketsSend in interface XSWriter<T2 extends XSDataPacket<?,?>>

Returns:

getWritables

public java.util.List<XSWritable<T2>> getWritables()

Description copied from interface: XSWriter

Get all writables to which this writer is currently connected

Specified by:

getWritables in interface XSWriter<T2 extends XSDataPacket<?,?>>

Returns:

the writables

handleNextPacket

protected void handleNextPacket(T1 packet)

Specified by:

handleNextPacket in class AbstractXSRunnableXSWritable<T1 extends XSDataPacket<?,?>>

transform

protected abstract T2 transform(T1 packet)

run

public final void run()

Specified by:

run in interface java.lang.Runnable

Overrides:

run in class AbstractXSRunnable