org.smslib.queues
Class DefaultQueueManager
java.lang.Object
org.smslib.queues.AbstractQueueManager
org.smslib.queues.DefaultQueueManager
public class DefaultQueueManager
- extends AbstractQueueManager
- Since:
- 3.5
- Author:
- Bassam Al-Sarori
Methods inherited from class java.lang.Object |
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
MESSAGE_FILE_EXT
public static final java.lang.String MESSAGE_FILE_EXT
- See Also:
- Constant Field Values
DefaultQueueManager
public DefaultQueueManager()
DefaultQueueManager
public DefaultQueueManager(java.lang.String queueDirectory)
DefaultQueueManager
public DefaultQueueManager(int delay)
DefaultQueueManager
public DefaultQueueManager(int delay,
java.lang.String queueDirectory)
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
(c) 2002-2011, http://smslib.org