org.graphstream.stream.gephi

Class JSONReceiver

java.lang.Object

java.lang.Thread

org.graphstream.stream.gephi.JSONReceiver

All Implemented Interfaces:

Runnable

public class JSONReceiver
extends Thread

connect GraphStream to Gephi Gephi works as source, sends events to GraphStream

Author:

wumalbert

Nested Class Summary

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

Thread.State, Thread.UncaughtExceptionHandler

Field Summary

Fields

Modifier and Type	Field and Description
protected org.graphstream.stream.thread.ThreadProxyPipe	currentStream The current pipe commands are being written to.
protected String	sourceId the gephi source ID
protected org.graphstream.stream.sync.SourceTime	sourceTime

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor and Description
JSONReceiver(String host, int port, String workspace)
JSONReceiver(String host, int port, String workspace, boolean debug)

Method Summary

Modifier and Type	Method and Description
org.graphstream.stream.thread.ThreadProxyPipe	getStream()
protected void	init() connect to Gephi
void	run() process the stream received from Gephi
void	setDebug(boolean debug) set debug mode

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

Methods inherited from class java.lang.Object

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

Field Detail

sourceId

protected String sourceId

the gephi source ID

sourceTime

protected org.graphstream.stream.sync.SourceTime sourceTime

currentStream

protected org.graphstream.stream.thread.ThreadProxyPipe currentStream

The current pipe commands are being written to.

Constructor Detail

JSONReceiver

public JSONReceiver(String host,
                    int port,
                    String workspace)

Parameters:

host - , the host of the Gephi server

port - , the port of the Gephi server

workspace - , the workspace name of the Gephi server

JSONReceiver

public JSONReceiver(String host,
                    int port,
                    String workspace,
                    boolean debug)

Parameters:

host - , the host of the Gephi server

port - , the port of the Gephi server

workspace - , the workspace name of the Gephi server

debug - , the program mode

Method Detail

setDebug

public void setDebug(boolean debug)

set debug mode

Parameters:

debug -

getStream

public org.graphstream.stream.thread.ThreadProxyPipe getStream()

init

protected void init()

connect to Gephi

run

public void run()

process the stream received from Gephi

Specified by:

run in interface Runnable

Overrides:

run in class Thread