com.digi.wva.device

Class EventChannel

java.lang.Object

java.lang.Thread

com.digi.wva.device.EventChannel

All Implemented Interfaces:

Runnable

public class EventChannel
extends Thread

Handles the TCP event channel connection between an Android application and the WVA device.

You should not need to create an instance of this class manually. Use the WVA class to manage all interactions with the WVA.

Nested Class Summary

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

Thread.State, Thread.UncaughtExceptionHandler

Field Summary

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor and Description
EventChannel(WVA owner, Socket socket)
EventChannel(WVA owner, String hostname, int port)
EventChannel(WVA owner, String hostname, int port, EventChannelStateListener listener)

Method Summary

Methods

Modifier and Type	Method and Description
BlockingQueue<JSONObject>	getIncoming() Allow the EventDispatcher access to the object queue
IOException	ioException()
boolean	isStopped()
protected Socket	makeSocket() Create a new Socket pointed at this EventChannel's hostname and port.
void	run() Read JSONObjects from a TCP stream into the incoming queue until either the thread is interrupted or stopThread() is called.
void	setStateListener(EventChannelStateListener listener) Sets the state listener used to report back changes in the connection state.
void	stopThread(IOException e)

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

Constructor Detail

EventChannel

public EventChannel(WVA owner,
            Socket socket)

EventChannel

public EventChannel(WVA owner,
            String hostname,
            int port)

EventChannel

public EventChannel(WVA owner,
            String hostname,
            int port,
            EventChannelStateListener listener)

Method Detail

getIncoming

public BlockingQueue<JSONObject> getIncoming()

Allow the EventDispatcher access to the object queue

Returns:

the received object queue

setStateListener

public void setStateListener(EventChannelStateListener listener)

Sets the state listener used to report back changes in the connection state.

Parameters:

listener - the listener to set

stopThread

public void stopThread(IOException e)

isStopped

public boolean isStopped()

ioException

public IOException ioException()

Returns:

The most recent exception encountered by this thread

run

public void run()

Read JSONObjects from a TCP stream into the incoming queue until either the thread is interrupted or stopThread() is called. No validation is performed on the objects, but they will be discarded if they are longer than MAX_LENGTH characters.

Specified by:

run in interface Runnable

Overrides:

run in class Thread

makeSocket

protected Socket makeSocket()
                     throws IOException

Create a new Socket pointed at this EventChannel's hostname and port.

This method is protected, rather than private, due to a bug between JaCoCo and the Android build tools which causes the instrumented bytecode to be invalid when this method is private: http://stackoverflow.com/questions/17603192/dalvik-transformation-using-wrong-invoke-opcode

Returns:

Throws:

IOException