public abstract class StreamBaseDevice extends GenericBaseDevice implements BaseDevice
Modifier and Type | Field and Description |
---|---|
static int |
CONNECT_TIMEOUT |
protected org.apache.mina.core.session.IoSession |
session |
connectionListeners
Constructor and Description |
---|
StreamBaseDevice(SocketAddress address) |
Modifier and Type | Method and Description |
---|---|
void |
connect() |
void |
dispose() |
boolean |
isConnected() |
void |
sessionClosed(org.apache.mina.core.session.IoSession session) |
void |
sessionCreated(org.apache.mina.core.session.IoSession session) |
void |
sessionIdle(org.apache.mina.core.session.IoSession session,
org.apache.mina.core.session.IdleStatus status) |
void |
sessionOpened(org.apache.mina.core.session.IoSession session) |
protected void |
setTimeout(long timeout) |
protected abstract void |
setupConnector(org.apache.mina.transport.socket.SocketConnector connector) |
protected void |
writeMessage(Object message)
Write a message to the outbound connection or fail if there is not open
connection at the moment
|
protected void |
writeMessageIgnore(Object message)
Write a message to the outbound connection or ignore it if there is no
open connection at the moment
|
addConnectionListener, fireConnected, fireConnectionFailed, fireDisconnected, removeConnectionListener
exceptionCaught, messageReceived, messageSent
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
addConnectionListener, removeConnectionListener
public static final int CONNECT_TIMEOUT
protected org.apache.mina.core.session.IoSession session
public StreamBaseDevice(SocketAddress address)
protected abstract void setupConnector(org.apache.mina.transport.socket.SocketConnector connector)
public boolean isConnected()
isConnected
in interface BaseDevice
public void connect()
connect
in interface BaseDevice
public void dispose()
dispose
in interface BaseDevice
public void sessionCreated(org.apache.mina.core.session.IoSession session) throws Exception
sessionCreated
in interface org.apache.mina.core.service.IoHandler
sessionCreated
in class org.apache.mina.core.service.IoHandlerAdapter
Exception
protected void setTimeout(long timeout)
public void sessionOpened(org.apache.mina.core.session.IoSession session) throws Exception
sessionOpened
in interface org.apache.mina.core.service.IoHandler
sessionOpened
in class org.apache.mina.core.service.IoHandlerAdapter
Exception
public void sessionIdle(org.apache.mina.core.session.IoSession session, org.apache.mina.core.session.IdleStatus status) throws Exception
sessionIdle
in interface org.apache.mina.core.service.IoHandler
sessionIdle
in class org.apache.mina.core.service.IoHandlerAdapter
Exception
public void sessionClosed(org.apache.mina.core.session.IoSession session) throws Exception
sessionClosed
in interface org.apache.mina.core.service.IoHandler
sessionClosed
in class org.apache.mina.core.service.IoHandlerAdapter
Exception
protected void writeMessage(Object message) throws NotConnectedException
message
- the message to wrtiteNotConnectedException
- thrown if there is no connection at the momentprotected void writeMessageIgnore(Object message)
message
- the message to writeCopyright © 2016 Eclipse NeoSCADA Project. All rights reserved.