public class LLRPIoHandlerAdapterImpl extends LLRPIoHandlerAdapter
| Constructor and Description |
|---|
LLRPIoHandlerAdapterImpl() |
LLRPIoHandlerAdapterImpl(LLRPConnection connection) |
| Modifier and Type | Method and Description |
|---|---|
void |
exceptionCaught(org.apache.mina.core.session.IoSession session,
java.lang.Throwable cause) |
LLRPConnection |
getConnection()
gets connection on which handler is operating
|
java.util.concurrent.BlockingQueue<ConnectionAttemptEvent> |
getConnectionAttemptEventQueue()
returns queue with all incoming ConnectionAttemptEvent parameters which were embedded in
READER_NOTIFICATION messages.
|
java.util.concurrent.BlockingQueue<LLRPMessage> |
getSynMessageQueue()
returns queue of all incoming messages where the messages type is equal to the one specified
in the IoSession parameter LLRPConnection.SYNC_MESSAGE_ANSWER.
|
boolean |
isKeepAliveAck()
returns true if incoming KEEP_ALIVE messages are being acknowledged.
|
boolean |
isKeepAliveForward()
returns true if incoming KEEP_ALIVE messages are being forwarded to the LLRPEndpoint.
|
void |
messageReceived(org.apache.mina.core.session.IoSession session,
java.lang.Object message)
is called whenever an LLRP Message is received.
|
void |
messageSent(org.apache.mina.core.session.IoSession session,
java.lang.Object message) |
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) |
void |
setConnection(LLRPConnection connection)
sets connection on which handler is operating
|
void |
setKeepAliveAck(boolean keepAliveAck)
set whether incoming KEEP_ALIVE messages should be acknowledged.
|
void |
setKeepAliveForward(boolean keepAliveForward)
set whether incoming KEEP_ALIVE messages are being forwarded to the LLRPEndpoint.
|
public LLRPIoHandlerAdapterImpl(LLRPConnection connection)
public LLRPIoHandlerAdapterImpl()
public void sessionOpened(org.apache.mina.core.session.IoSession session)
throws java.lang.Exception
sessionOpened in interface org.apache.mina.core.service.IoHandlersessionOpened in class org.apache.mina.core.service.IoHandlerAdapterjava.lang.Exceptionpublic void messageReceived(org.apache.mina.core.session.IoSession session,
java.lang.Object message)
throws java.lang.Exception
messageReceived in interface org.apache.mina.core.service.IoHandlermessageReceived in class org.apache.mina.core.service.IoHandlerAdapterjava.lang.Exceptionpublic void messageSent(org.apache.mina.core.session.IoSession session,
java.lang.Object message)
throws java.lang.Exception
messageSent in interface org.apache.mina.core.service.IoHandlermessageSent in class org.apache.mina.core.service.IoHandlerAdapterjava.lang.Exceptionpublic void exceptionCaught(org.apache.mina.core.session.IoSession session,
java.lang.Throwable cause)
throws java.lang.Exception
exceptionCaught in interface org.apache.mina.core.service.IoHandlerexceptionCaught in class org.apache.mina.core.service.IoHandlerAdapterjava.lang.Exceptionpublic void sessionIdle(org.apache.mina.core.session.IoSession session,
org.apache.mina.core.session.IdleStatus status)
throws java.lang.Exception
sessionIdle in interface org.apache.mina.core.service.IoHandlersessionIdle in class org.apache.mina.core.service.IoHandlerAdapterjava.lang.Exceptionpublic java.util.concurrent.BlockingQueue<LLRPMessage> getSynMessageQueue()
getSynMessageQueue in class LLRPIoHandlerAdapterpublic java.util.concurrent.BlockingQueue<ConnectionAttemptEvent> getConnectionAttemptEventQueue()
getConnectionAttemptEventQueue in class LLRPIoHandlerAdapterpublic boolean isKeepAliveAck()
isKeepAliveAck in class LLRPIoHandlerAdapterpublic void setKeepAliveAck(boolean keepAliveAck)
setKeepAliveAck in class LLRPIoHandlerAdapterkeepAliveAck - true if KEEP_ALIVE messages are to be acknowledgedpublic boolean isKeepAliveForward()
isKeepAliveForward in class LLRPIoHandlerAdapterpublic void setKeepAliveForward(boolean keepAliveForward)
setKeepAliveForward in class LLRPIoHandlerAdapterkeepAliveForward - true if KEEP_ALIVE messages are to be forwardedpublic LLRPConnection getConnection()
getConnection in class LLRPIoHandlerAdapterpublic void setConnection(LLRPConnection connection)
setConnection in class LLRPIoHandlerAdapterCopyright © 2007 ETH Zurich.