com.acap.rudp.core
Class BaseUDPSessionManager

java.lang.Object
  com.acap.rudp.core.StatefulRunnable
      com.acap.rudp.core.BaseUDPSessionManager

All Implemented Interfaces:

java.lang.Runnable

Direct Known Subclasses:

J2meClient, MinaSessionManager

public abstract class BaseUDPSessionManager
extends StatefulRunnable

Constructor Summary

BaseUDPSessionManager(java.lang.String senderId)

Method Summary

void	doRun()
long	getLastMessageReceivedDateTimeMillis()
int	getPendingAcknowledgmentCount()
int	getReceivedCount()
java.lang.String	getSenderId()
int	getSentCount()
boolean	hasMessagesPendingAck()
void	incrementReceivedCount()
void	receivePacket(byte[] data)
void	send(Message message)
void	updateLastMessageReceivedDateTime()

Methods inherited from class com.acap.rudp.core.StatefulRunnable

isStarted, run, start, stop

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

BaseUDPSessionManager

public BaseUDPSessionManager(java.lang.String senderId)
                      throws java.lang.Exception

Throws:

java.lang.Exception

Method Detail

hasMessagesPendingAck

public boolean hasMessagesPendingAck()

getSenderId

public java.lang.String getSenderId()

doRun

public void doRun()

updateLastMessageReceivedDateTime

public void updateLastMessageReceivedDateTime()

getLastMessageReceivedDateTimeMillis

public long getLastMessageReceivedDateTimeMillis()

incrementReceivedCount

public void incrementReceivedCount()

getSentCount

public int getSentCount()

getReceivedCount

public int getReceivedCount()

receivePacket

public void receivePacket(byte[] data)
                   throws java.lang.Exception

Throws:

java.lang.Exception

send

public void send(Message message)
          throws java.lang.Exception

Throws:

java.lang.Exception

getPendingAcknowledgmentCount

public int getPendingAcknowledgmentCount()