org.processmining.stream.author.json.abstracts

Class AbstractJsonXSAuthor<D extends XSDataPacket<?,?>,V>

java.lang.Object

java.lang.Thread

org.processmining.stream.core.abstracts.AbstractXSRunnable

org.processmining.stream.core.abstracts.AbstractXSRunnableXSWriter<D>

org.processmining.stream.core.abstracts.AbstractXSAuthor<D,V>

org.processmining.stream.author.json.abstracts.AbstractJsonXSAuthor<D,V>

All Implemented Interfaces:

java.lang.Runnable, XSAuthor<D>, XSRunnable, XSStronglyTyped<D>, XSVisualizable, XSWriter<D>

Direct Known Subclasses:

AbstractJsonUrlHttpXSAuthor

public abstract class AbstractJsonXSAuthor<D extends XSDataPacket<?,?>,V>
extends AbstractXSAuthor<D,V>

Nested Class Summary

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

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

Field Summary

Fields

Modifier and Type	Field and Description
protected java.io.Reader	externalStreamReader
protected com.google.gson.JsonStreamParser	jsonStream

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor and Description
AbstractJsonXSAuthor(java.lang.String name, XSVisualization<V> visualization)

Method Summary

Modifier and Type	Method and Description
protected abstract java.io.Reader	establishReaderConnectionToSource()
protected void	reConnect()
void	startXSRunnable()
void	stopXSRunnable()

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

getVisualization, interrupt, pause, pauseXSRunnable, start

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

connect, disconnect, getNumberOfPacketsSend, getWritables, run, write

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

isPaused, isRunning, isStarted, isStopped, workPackage

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, isPaused, isRunning, isStarted, isStopped, stop

Methods inherited from interface java.lang.Runnable

run

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

connect, disconnect, getNumberOfPacketsSend, getWritables, write

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

getTopic

Field Detail

jsonStream

protected com.google.gson.JsonStreamParser jsonStream

externalStreamReader

protected java.io.Reader externalStreamReader

Constructor Detail

AbstractJsonXSAuthor

public AbstractJsonXSAuthor(java.lang.String name,
                            XSVisualization<V> visualization)

Method Detail

startXSRunnable

public void startXSRunnable()

Specified by:

startXSRunnable in interface XSRunnable

Overrides:

startXSRunnable in class AbstractXSAuthor<D extends XSDataPacket<?,?>,V>

stopXSRunnable

public void stopXSRunnable()

Specified by:

stopXSRunnable in interface XSRunnable

Overrides:

stopXSRunnable in class AbstractXSAuthor<D extends XSDataPacket<?,?>,V>

establishReaderConnectionToSource

protected abstract java.io.Reader establishReaderConnectionToSource()

reConnect

protected void reConnect()