C D E F G I J P Q R S T _

C

com.github.ddth.queue - package com.github.ddth.queue

com.github.ddth.queue.impl - package com.github.ddth.queue.impl

com.github.ddth.queue.utils - package com.github.ddth.queue.utils

D

destroy() - Method in class com.github.ddth.queue.impl.JdbcQueue

E

ephemeralSize() - Method in class com.github.ddth.queue.impl.JdbcQueue

Gets ephemeral-queue's number of items.

ephemeralSize() - Method in interface com.github.ddth.queue.IQueue

Gets ephemeral-queue's number of items.

F

finish(IQueueMessage) - Method in class com.github.ddth.queue.impl.JdbcQueue

Called when finish processing the message to cleanup ephemeral storage.

finish(IQueueMessage) - Method in interface com.github.ddth.queue.IQueue

Called when finish processing the message to cleanup ephemeral storage.

G

getTableName() - Method in class com.github.ddth.queue.impl.JdbcQueue

getTableNameEphemeral() - Method in class com.github.ddth.queue.impl.JdbcQueue

I

init() - Method in class com.github.ddth.queue.impl.JdbcQueue

IQueue - Interface in com.github.ddth.queue

APIs to interact with queue.

IQueueMessage - Interface in com.github.ddth.queue

Represents a queue message.

J

JdbcQueue - Class in com.github.ddth.queue.impl

Abstract JDBC implementation of IQueue.

JdbcQueue() - Constructor for class com.github.ddth.queue.impl.JdbcQueue

P

putToEphemeralStorage(JdbcTemplate, IQueueMessage) - Method in class com.github.ddth.queue.impl.JdbcQueue

Puts message to tail of ephemeral storage.

putToQueueStorage(JdbcTemplate, IQueueMessage) - Method in class com.github.ddth.queue.impl.JdbcQueue

Puts message to tail of queue storage.

Q

qId() - Method in interface com.github.ddth.queue.IQueueMessage

Message's unique id in queue.

qId(Object) - Method in interface com.github.ddth.queue.IQueueMessage

Sets message's unique queue id.

qIncNumRequeues() - Method in interface com.github.ddth.queue.IQueueMessage

Increases message's number of re-queue times by 1.

qNumRequeues() - Method in interface com.github.ddth.queue.IQueueMessage

How many times message has been re-queued?

qNumRequeues(int) - Method in interface com.github.ddth.queue.IQueueMessage

Sets message's number of re-queue times.

qOriginalTimestamp() - Method in interface com.github.ddth.queue.IQueueMessage

Message's first-queued timestamp.

qOriginalTimestamp(Date) - Method in interface com.github.ddth.queue.IQueueMessage

Sets message's first-queued timestamp.

qTimestamp() - Method in interface com.github.ddth.queue.IQueueMessage

Message's last-queued timestamp.

qTimestamp(Date) - Method in interface com.github.ddth.queue.IQueueMessage

Sets message's last-queued timestamp.

queue(IQueueMessage) - Method in class com.github.ddth.queue.impl.JdbcQueue

Queues a message.

queue(IQueueMessage) - Method in interface com.github.ddth.queue.IQueue

Queues a message.

QueueException - Exception in com.github.ddth.queue.utils

Thrown to indicate that there has been an error with queue oeration.

QueueException() - Constructor for exception com.github.ddth.queue.utils.QueueException

QueueException(String) - Constructor for exception com.github.ddth.queue.utils.QueueException

QueueException(Throwable) - Constructor for exception com.github.ddth.queue.utils.QueueException

QueueException(String, Throwable) - Constructor for exception com.github.ddth.queue.utils.QueueException

QueueException(String, Throwable, boolean, boolean) - Constructor for exception com.github.ddth.queue.utils.QueueException

queueSize() - Method in class com.github.ddth.queue.impl.JdbcQueue

Gets queue's number of items.

queueSize() - Method in interface com.github.ddth.queue.IQueue

Gets queue's number of items.

R

readFromEphemeralStorage(JdbcTemplate) - Method in class com.github.ddth.queue.impl.JdbcQueue

Reads a message from ephemeral storage.

readFromQueueStorage(JdbcTemplate) - Method in class com.github.ddth.queue.impl.JdbcQueue

Reads a message from head of queue storage.

removeFromEphemeralStorage(JdbcTemplate, IQueueMessage) - Method in class com.github.ddth.queue.impl.JdbcQueue

Removes message from ephemeral storage.

removeFromQueueStorage(JdbcTemplate, IQueueMessage) - Method in class com.github.ddth.queue.impl.JdbcQueue

Removes message from queue storage.

requeue(IQueueMessage) - Method in class com.github.ddth.queue.impl.JdbcQueue

Re-queues a message.

requeue(IQueueMessage) - Method in interface com.github.ddth.queue.IQueue

Re-queues a message.

requeueSilent(IQueueMessage) - Method in class com.github.ddth.queue.impl.JdbcQueue

Silently re-queues a message.

requeueSilent(IQueueMessage) - Method in interface com.github.ddth.queue.IQueue

Silently re-queues a message.

S

setTableName(String) - Method in class com.github.ddth.queue.impl.JdbcQueue

setTableNameEphemeral(String) - Method in class com.github.ddth.queue.impl.JdbcQueue

T

take() - Method in class com.github.ddth.queue.impl.JdbcQueue

Takes a message out of queue.

take() - Method in interface com.github.ddth.queue.IQueue

Takes a message out of queue.

_

_finishWithRetries(JdbcTemplate, IQueueMessage, int, int) - Method in class com.github.ddth.queue.impl.JdbcQueue

Performs "finish" action, retry if deadlock.

_queueWithRetries(JdbcTemplate, IQueueMessage, int, int) - Method in class com.github.ddth.queue.impl.JdbcQueue

Queues a message, retry if deadlock.

_requeueSilentWithRetries(JdbcTemplate, IQueueMessage, int, int) - Method in class com.github.ddth.queue.impl.JdbcQueue

Re-queues a message silently, retry if deadlock.

_requeueWithRetries(JdbcTemplate, IQueueMessage, int, int) - Method in class com.github.ddth.queue.impl.JdbcQueue

Re-queues a message, retry if deadlock.

_takeWithRetries(JdbcTemplate, int, int) - Method in class com.github.ddth.queue.impl.JdbcQueue

Takes a message from queue, retry if deadlock.

C D E F G I J P Q R S T _