Package com.seleniumsoftware.SMPPSim

Class InboundQueue

java.lang.Object

com.seleniumsoftware.SMPPSim.InboundQueue

All Implemented Interfaces:

java.lang.Runnable

public class InboundQueue
extends java.lang.Object
implements java.lang.Runnable

Field Summary

Fields

Modifier and Type	Field	Description
private static DelayedInboundQueue	diqueue
(package private) java.util.ArrayList<Pdu>	inbound_queue
private static InboundQueue	iqueue
private static java.util.logging.Logger	logger
(package private) java.util.ArrayList<Pdu>	pending_queue
(package private) java.util.ArrayList<Pdu>	response_queue
private Smsc	smsc

Constructor Summary

Constructors

Modifier	Constructor	Description
private	InboundQueue(int maxsize)

Method Summary

Modifier and Type	Method	Description
void	addMessage(Pdu message)
private void	addPendingQueue(Pdu mo)
void	deliverPendingMoMessages()	Called when a receiver or transceiver session is established.
void	deliveryResult(int seqno, int command_status)
private java.lang.Object[]	getAllMessages()
static InboundQueue	getInstance()
private boolean	isEmpty()
void	notifyReceiverBound()
int	pending_size()
protected boolean	processDataSM(DataSM pdu, StandardConnectionHandler receiver)
protected boolean	processDeliverSM(DeliverSM pdu, StandardConnectionHandler receiver, java.util.ArrayList<Pdu> from_queue)
private void	processQueue()
void	removeMessage(Pdu m)
void	removeMessage(Pdu m, java.util.ArrayList<Pdu> queue)
void	run()
int	size()

Methods inherited from class java.lang.Object

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

Field Detail

logger

private static java.util.logging.Logger logger

smsc

private Smsc smsc

iqueue

private static InboundQueue iqueue

diqueue

private static DelayedInboundQueue diqueue

inbound_queue

java.util.ArrayList<Pdu> inbound_queue

response_queue

java.util.ArrayList<Pdu> response_queue

pending_queue

java.util.ArrayList<Pdu> pending_queue

Constructor Detail

InboundQueue

private InboundQueue(int maxsize)

Method Detail

getInstance

public static InboundQueue getInstance()

addMessage

public void addMessage(Pdu message)
                throws InboundQueueFullException

Throws:

InboundQueueFullException

deliveryResult

public void deliveryResult(int seqno,
                           int command_status)

removeMessage

public void removeMessage(Pdu m)

removeMessage

public void removeMessage(Pdu m,
                          java.util.ArrayList<Pdu> queue)

getAllMessages

private java.lang.Object[] getAllMessages()

isEmpty

private boolean isEmpty()

size

public int size()

pending_size

public int pending_size()

notifyReceiverBound

public void notifyReceiverBound()

run

public void run()

Specified by:

run in interface java.lang.Runnable

addPendingQueue

private void addPendingQueue(Pdu mo)

processQueue

private void processQueue()

processDeliverSM

protected boolean processDeliverSM(DeliverSM pdu,
                                   StandardConnectionHandler receiver,
                                   java.util.ArrayList<Pdu> from_queue)

processDataSM

protected boolean processDataSM(DataSM pdu,
                                StandardConnectionHandler receiver)

deliverPendingMoMessages

public void deliverPendingMoMessages()

Called when a receiver or transceiver session is established. Results in any MO messages for which a session was not available originally and which were set to one side in the pending queue, being delivered if the new session is suitable.