org.processmining.eventstream.core.implementations

Class XSEventStreamImpl

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

org.processmining.stream.core.abstracts.AbstractXSStream<XSEvent>

org.processmining.eventstream.core.implementations.XSEventStreamImpl

All Implemented Interfaces:

java.lang.Runnable, XSEventStream, org.processmining.stream.core.interfaces.XSHub<XSEvent,XSEvent>, org.processmining.stream.core.interfaces.XSRunnable, org.processmining.stream.core.interfaces.XSStream<XSEvent>, org.processmining.stream.core.interfaces.XSStronglyTyped<XSEvent>, org.processmining.stream.core.interfaces.XSVisualizable, org.processmining.stream.core.interfaces.XSWritable<XSEvent>, org.processmining.stream.core.interfaces.XSWriter<XSEvent>

public class XSEventStreamImpl
extends org.processmining.stream.core.abstracts.AbstractXSStream<XSEvent>
implements XSEventStream

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
XSEventStreamImpl(org.processmining.stream.core.enums.CommunicationType communicationType)
XSEventStreamImpl(XSEventSignature signature, org.processmining.stream.core.enums.CommunicationType communciationType)

Method Summary

Modifier and Type	Method and Description
java.lang.Class<XSEvent>	getTopic()
org.processmining.stream.core.interfaces.XSVisualization<?>	getVisualization()

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

connect, getSignature, transform

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

disconnect, getNumberOfPacketsSend, getWritables, getWriterDelegate, handleNextPacket, run, write

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.XSStream

getSignature

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 java.lang.Runnable

run

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

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

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

connect, disconnect, getNumberOfPacketsSend, getWritables, write

Constructor Detail

XSEventStreamImpl

public XSEventStreamImpl(org.processmining.stream.core.enums.CommunicationType communicationType)

XSEventStreamImpl

public XSEventStreamImpl(XSEventSignature signature,
                         org.processmining.stream.core.enums.CommunicationType communciationType)

Method Detail

getTopic

public java.lang.Class<XSEvent> getTopic()

Specified by:

getTopic in interface org.processmining.stream.core.interfaces.XSStronglyTyped<XSEvent>

getVisualization

public org.processmining.stream.core.interfaces.XSVisualization<?> getVisualization()

Specified by:

getVisualization in interface org.processmining.stream.core.interfaces.XSVisualizable