public abstract class AbstractObserverTransport extends Object implements StreamTransport
Modifier and Type | Field and Description |
---|---|
protected ListenerObservers |
listenerObservers |
protected Log |
log |
Modifier | Constructor and Description |
---|---|
protected |
AbstractObserverTransport() |
Modifier and Type | Method and Description |
---|---|
void |
connect(StreamListener listener)
Connect to stream.
|
void |
disconnect(StreamListener listener)
Disconnect to stream.
|
void |
dispose()
Dispose the transport.
|
void |
removeMessageStreamListener(StreamListener listener)
Remove message stream listener.
|
void |
setMessageStreamListener(StreamListener listener)
Sets message stream listener.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
isConnect
protected final Log log
protected ListenerObservers listenerObservers
public void setMessageStreamListener(StreamListener listener)
StreamTransport
setMessageStreamListener
in interface StreamTransport
listener
- the listenerpublic void removeMessageStreamListener(StreamListener listener)
StreamTransport
removeMessageStreamListener
in interface StreamTransport
listener
- the listenerpublic void connect(StreamListener listener) throws IOException
StreamTransport
connect
in interface StreamTransport
listener
- the listenerIOException
- if error occurredpublic void disconnect(StreamListener listener) throws IOException
StreamTransport
disconnect
in interface StreamTransport
listener
- the listenerIOException
- if error occurredpublic void dispose() throws IOException
StreamTransport
This methods disconnect from stream and cleans all subscribed listeners.
dispose
in interface StreamTransport
IOException
- if error occurredCopyright © 2000-2017 EPAM Systems. All Rights Reserved.