SMSLib 3.5.3

org.smslib.queues
Class DefaultQueueManager

java.lang.Object
  extended by org.smslib.queues.AbstractQueueManager
      extended by org.smslib.queues.DefaultQueueManager

public class DefaultQueueManager
extends AbstractQueueManager

Since:
3.5
Author:
Bassam Al-Sarori

Field Summary
static java.lang.String MESSAGE_FILE_EXT
           
 
Constructor Summary
DefaultQueueManager()
           
DefaultQueueManager(int delay)
           
DefaultQueueManager(int delay, java.lang.String queueDirectory)
           
DefaultQueueManager(java.lang.String queueDirectory)
           
 
Method Summary
 int delayedQueueSize(java.lang.String gatewayId)
           
 java.util.Collection<OutboundMessage> getDelayedMessages()
           
 java.util.Collection<OutboundMessage> getPendingMessages(java.lang.String gatewayId)
           
 int pendingQueueSize(java.lang.String gatewayId)
           
 OutboundMessage pollDelayedMessage()
           
 OutboundMessage pollPendingMessage(java.lang.String gatewayId)
           
 boolean queueMessage(OutboundMessage message)
          Queues the message.
 boolean removeAllDelayedMessages()
           
 boolean removeAllPendingMessages()
           
 boolean removeAllPendingMessages(java.lang.String gatewayId)
           
 boolean removeDelayedMessage(OutboundMessage message)
           
 boolean removeDelayedMessage(java.lang.String messageUUID)
           
 boolean removePendingMessage(OutboundMessage message)
           
 boolean removePendingMessage(java.lang.String messageUUID)
           
 
Methods inherited from class org.smslib.queues.AbstractQueueManager
getQueueDelay, pause, resume, setQueueDelay, start, stop
 
Methods inherited from class java.lang.Object
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

MESSAGE_FILE_EXT

public static final java.lang.String MESSAGE_FILE_EXT
See Also:
Constant Field Values
Constructor Detail

DefaultQueueManager

public DefaultQueueManager()

DefaultQueueManager

public DefaultQueueManager(java.lang.String queueDirectory)

DefaultQueueManager

public DefaultQueueManager(int delay)

DefaultQueueManager

public DefaultQueueManager(int delay,
                           java.lang.String queueDirectory)
Method Detail

queueMessage

public boolean queueMessage(OutboundMessage message)
Description copied from class: AbstractQueueManager
Queues the message. If message.getDeliveryDelay > 0 then it is queued for later delivery else it is added to the gateway's pending queue specified by message.getGatewayId.

Specified by:
queueMessage in class AbstractQueueManager
Returns:
if the message was queued, false otherwise.

removePendingMessage

public boolean removePendingMessage(OutboundMessage message)
Specified by:
removePendingMessage in class AbstractQueueManager

removePendingMessage

public boolean removePendingMessage(java.lang.String messageUUID)
Specified by:
removePendingMessage in class AbstractQueueManager

pollDelayedMessage

public OutboundMessage pollDelayedMessage()
Specified by:
pollDelayedMessage in class AbstractQueueManager

pollPendingMessage

public OutboundMessage pollPendingMessage(java.lang.String gatewayId)
Specified by:
pollPendingMessage in class AbstractQueueManager

delayedQueueSize

public int delayedQueueSize(java.lang.String gatewayId)
Specified by:
delayedQueueSize in class AbstractQueueManager

getDelayedMessages

public java.util.Collection<OutboundMessage> getDelayedMessages()
Specified by:
getDelayedMessages in class AbstractQueueManager

getPendingMessages

public java.util.Collection<OutboundMessage> getPendingMessages(java.lang.String gatewayId)
Specified by:
getPendingMessages in class AbstractQueueManager

pendingQueueSize

public int pendingQueueSize(java.lang.String gatewayId)
Specified by:
pendingQueueSize in class AbstractQueueManager

removeDelayedMessage

public boolean removeDelayedMessage(OutboundMessage message)
Specified by:
removeDelayedMessage in class AbstractQueueManager

removeDelayedMessage

public boolean removeDelayedMessage(java.lang.String messageUUID)
Specified by:
removeDelayedMessage in class AbstractQueueManager

removeAllDelayedMessages

public boolean removeAllDelayedMessages()
Specified by:
removeAllDelayedMessages in class AbstractQueueManager

removeAllPendingMessages

public boolean removeAllPendingMessages(java.lang.String gatewayId)
Specified by:
removeAllPendingMessages in class AbstractQueueManager

removeAllPendingMessages

public boolean removeAllPendingMessages()
Specified by:
removeAllPendingMessages in class AbstractQueueManager

SMSLib 3.5.3

(c) 2002-2011, http://smslib.org