private class Service.DataExchange extends java.lang.Object implements IDataExchange, java.lang.Runnable
Modifier and Type | Field and Description |
---|---|
private java.util.concurrent.BlockingQueue<DataEvent> |
events
List of Data events.
|
private java.util.List<IDataExchangeListener> |
listeners
List of Data Exchange Listeners.
|
(package private) java.util.concurrent.Future |
task
Task control.
|
Modifier | Constructor and Description |
---|---|
private |
DataExchange() |
Modifier and Type | Method and Description |
---|---|
void |
addDataExchangeListener(IDataExchangeListener listener)
Adds a Data Exchange listener.
|
void |
cancel()
Cancels this data exchange.
|
void |
post(java.lang.String name,
java.lang.Number value)
Posts new data to the data exchange.
|
void |
removeDataExchangeListener(IDataExchangeListener listener)
Removes a Data Exchange listener.
|
void |
run()
Fires data added events when there are events on the event queue.
|
void |
start()
Starts the data exchange.
|
private final java.util.List<IDataExchangeListener> listeners
private final java.util.concurrent.BlockingQueue<DataEvent> events
java.util.concurrent.Future task
public void start()
start
in interface IDataExchange
public void cancel()
cancel
in interface IDataExchange
public void post(java.lang.String name, java.lang.Number value)
post
in interface IDataExchange
name
- name of the data source.value
- data being posted.public void addDataExchangeListener(IDataExchangeListener listener)
addDataExchangeListener
in interface IDataExchange
listener
- to add.public void removeDataExchangeListener(IDataExchangeListener listener)
removeDataExchangeListener
in interface IDataExchange
listener
- to remove.public void run()
run
in interface java.lang.Runnable