public class Messenger extends Object implements MessageListener
Constructor and Description |
---|
Messenger(long timeout,
StatisticsImpl statistics) |
Modifier and Type | Method and Description |
---|---|
void |
connected(MessageSender connection) |
void |
disconnected() |
protected void |
finalize() |
long |
getSessionTimeout() |
protected boolean |
handleDefaultMessage(Message message) |
protected boolean |
handleHandlerMessage(Message message) |
protected void |
handleUnknownMessage(Message message) |
void |
messageReceived(Message message) |
protected Collection<org.eclipse.scada.net.mina.Messenger.MessageTag> |
performDisconnect()
Disconnects the messenger from the current connection (if there is one).
|
protected void |
registerMessageTag(long sequence,
org.eclipse.scada.net.mina.Messenger.MessageTag messageTag) |
org.apache.mina.core.future.WriteFuture |
sendMessage(Message message) |
org.apache.mina.core.future.WriteFuture |
sendMessage(Message message,
MessageStateListener messageListener) |
org.apache.mina.core.future.WriteFuture |
sendMessage(Message message,
MessageStateListener listener,
long timeout)
Send out a message including optional message tracking
|
void |
setHandler(int commandCode,
MessageListener handler) |
void |
unsetHandler(int commandCode) |
public Messenger(long timeout, StatisticsImpl statistics)
public long getSessionTimeout()
protected void finalize() throws Throwable
public void connected(MessageSender connection)
protected Collection<org.eclipse.scada.net.mina.Messenger.MessageTag> performDisconnect()
Be aware that the returned message tags have to be timed out (e.g. using fireTimeouts(Collection)
), otherwise they will wait forever!
public void disconnected()
public void setHandler(int commandCode, MessageListener handler)
public void unsetHandler(int commandCode)
public void messageReceived(Message message)
messageReceived
in interface MessageListener
protected void handleUnknownMessage(Message message)
public org.apache.mina.core.future.WriteFuture sendMessage(Message message)
public org.apache.mina.core.future.WriteFuture sendMessage(Message message, MessageStateListener messageListener)
protected void registerMessageTag(long sequence, org.eclipse.scada.net.mina.Messenger.MessageTag messageTag)
public org.apache.mina.core.future.WriteFuture sendMessage(Message message, MessageStateListener listener, long timeout)
message
- the message to sendlistener
- the optional listenertimeout
- the timeoutprotected boolean handleDefaultMessage(Message message)
protected boolean handleHandlerMessage(Message message)