Package com.seleniumsoftware.SMPPSim
Class OutboundQueue
- java.lang.Object
-
- com.seleniumsoftware.SMPPSim.OutboundQueue
-
- All Implemented Interfaces:
java.lang.Runnable
public class OutboundQueue extends java.lang.Object implements java.lang.Runnable
-
-
Field Summary
Fields Modifier and Type Field Description private LifeCycleManagerlcmprivate static java.util.logging.Loggerlogger(package private) java.util.ArrayList<MessageState>queueprivate Smscsmsc
-
Constructor Summary
Constructors Constructor Description OutboundQueue(int maxsize)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidaddMessageState(MessageState message)java.lang.Object[]getAllMessageStates()MessageStategetMessageState(MessageState m)protected booleanisEmpty()private voidprocessQueue()MessageStatequeryMessageState(java.lang.String message_id, int ton, int npi, java.lang.String addr)voidremoveMessageState(MessageState m)voidrun()voidsetResponseSent(MessageState m)intsize()voidupdateMessageState(MessageState newMs)
-
-
-
Field Detail
-
logger
private static java.util.logging.Logger logger
-
smsc
private Smsc smsc
-
lcm
private LifeCycleManager lcm
-
queue
java.util.ArrayList<MessageState> queue
-
-
Method Detail
-
addMessageState
public void addMessageState(MessageState message) throws OutboundQueueFullException
- Throws:
OutboundQueueFullException
-
setResponseSent
public void setResponseSent(MessageState m) throws MessageStateNotFoundException
- Throws:
MessageStateNotFoundException
-
getMessageState
public MessageState getMessageState(MessageState m) throws MessageStateNotFoundException
- Throws:
MessageStateNotFoundException
-
updateMessageState
public void updateMessageState(MessageState newMs) throws MessageStateNotFoundException
- Throws:
MessageStateNotFoundException
-
queryMessageState
public MessageState queryMessageState(java.lang.String message_id, int ton, int npi, java.lang.String addr) throws MessageStateNotFoundException
- Throws:
MessageStateNotFoundException
-
removeMessageState
public void removeMessageState(MessageState m)
-
getAllMessageStates
public java.lang.Object[] getAllMessageStates()
-
isEmpty
protected boolean isEmpty()
-
run
public void run()
- Specified by:
runin interfacejava.lang.Runnable
-
processQueue
private void processQueue()
-
size
public int size()
-
-