Index

A C D E F G H I L M P Q R S T U V W
All Classes and Interfaces|All Packages

A

ACTIVATING - Enum constant in enum class com.codeheadsystems.queue.State

Activate queue state.

availableThreadCount() - Method in class com.codeheadsystems.queue.impl.MessageConsumerExecutor

Number of free threads in the executor service.

C

clear(Message) - Method in class com.codeheadsystems.queue.impl.QueueImpl

clear(Message) - Method in class com.codeheadsystems.queue.manager.MessageManager

Clear.

clear(Message) - Method in interface com.codeheadsystems.queue.Queue

Clear.

clearAll() - Method in class com.codeheadsystems.queue.impl.QueueImpl

clearAll() - Method in class com.codeheadsystems.queue.manager.MessageManager

Clear all.

clearAll() - Method in interface com.codeheadsystems.queue.Queue

Clear all.

com.codeheadsystems.queue - package com.codeheadsystems.queue

com.codeheadsystems.queue.dao - package com.codeheadsystems.queue.dao

com.codeheadsystems.queue.factory - package com.codeheadsystems.queue.factory

com.codeheadsystems.queue.impl - package com.codeheadsystems.queue.impl

com.codeheadsystems.queue.manager - package com.codeheadsystems.queue.manager

com.codeheadsystems.queue.module - package com.codeheadsystems.queue.module

com.codeheadsystems.queue.util - package com.codeheadsystems.queue.util

count() - Method in interface com.codeheadsystems.queue.dao.StateCount

Count long.

counts() - Method in interface com.codeheadsystems.queue.dao.MessageDao

Returns back the count of all messages in the queue.

counts() - Method in class com.codeheadsystems.queue.manager.MessageManager

Returns counts of all states.

createMessage(String, String) - Method in class com.codeheadsystems.queue.factory.MessageFactory

Create message message.

D

delete(Message) - Method in interface com.codeheadsystems.queue.dao.MessageDao

Delete.

deleteAll() - Method in interface com.codeheadsystems.queue.dao.MessageDao

Delete all.

deregister(String) - Method in class com.codeheadsystems.queue.impl.QueueRegister

Deregister.

deregisterAll() - Method in class com.codeheadsystems.queue.impl.QueueRegister

Deregister all.

E

enqueue(Message) - Method in class com.codeheadsystems.queue.impl.MessageConsumerExecutor

Enqueue.

enqueue(String, String) - Method in class com.codeheadsystems.queue.impl.QueueImpl

enqueue(String, String) - Method in interface com.codeheadsystems.queue.Queue

Enqueue message.

exceptionOnEnqueueFail() - Method in interface com.codeheadsystems.queue.QueueConfiguration

Exception on enqueue fail boolean.

F

forState(State) - Method in interface com.codeheadsystems.queue.dao.MessageDao

For state list.

forState(State, int) - Method in interface com.codeheadsystems.queue.dao.MessageDao

For state list, but limit to the number requested.

G

getConsumer(String) - Method in class com.codeheadsystems.queue.impl.QueueRegister

Gets consumer.

getMessageStateCounts() - Method in class com.codeheadsystems.queue.impl.QueueImpl

getMessageStateCounts() - Method in interface com.codeheadsystems.queue.Queue

Provides the list of messages enqueued within the system for each state.

getPendingMessages(int) - Method in class com.codeheadsystems.queue.manager.MessageManager

Gets pending messages, up to the limit.

getRegisteredMessageTypes() - Method in class com.codeheadsystems.queue.impl.QueueRegister

Gets registered message types.

getState(Message) - Method in class com.codeheadsystems.queue.impl.QueueImpl

getState(Message) - Method in class com.codeheadsystems.queue.manager.MessageManager

Gets state.

getState(Message) - Method in interface com.codeheadsystems.queue.Queue

Gets state.

H

hash() - Method in interface com.codeheadsystems.queue.Message

Hash string for deduping, used as the primary key.

I

instance(Jdbi) - Static method in interface com.codeheadsystems.queue.dao.MessageDao

Instance message dao.

L

LiquibaseHelper - Class in com.codeheadsystems.queue.util

The type Liquibase helper.

LiquibaseHelper() - Constructor for class com.codeheadsystems.queue.util.LiquibaseHelper

Instantiates a new Liquibase helper.

M

Message - Interface in com.codeheadsystems.queue

The interface Message.

MessageConsumer - Interface in com.codeheadsystems.queue

The interface Message consumer.

MessageConsumerExecutor - Class in com.codeheadsystems.queue.impl

The type Message consumer executor.

MessageConsumerExecutor(QueueConfigurationFactory, MessageManager, QueueRegister, Metrics) - Constructor for class com.codeheadsystems.queue.impl.MessageConsumerExecutor

Instantiates a new Message consumer executor.

messageDao(Jdbi) - Method in class com.codeheadsystems.queue.module.QueueModule

Message dao message dao.

MessageDao - Interface in com.codeheadsystems.queue.dao

The interface Message dao.

MessageFactory - Class in com.codeheadsystems.queue.factory

The type Message factory.

MessageFactory(Clock) - Constructor for class com.codeheadsystems.queue.factory.MessageFactory

Instantiates a new Message factory.

MessageManager - Class in com.codeheadsystems.queue.manager

The Message manager.

MessageManager(MessageDao, MessageFactory, Metrics) - Constructor for class com.codeheadsystems.queue.manager.MessageManager

Instantiates a new Message manager.

messageType() - Method in interface com.codeheadsystems.queue.Message

Message type string.

P

payload() - Method in interface com.codeheadsystems.queue.Message

Payload string.

PENDING - Enum constant in enum class com.codeheadsystems.queue.State

Pending queue state.

PROCESSING - Enum constant in enum class com.codeheadsystems.queue.State

PROCESSING queue state.

processPendingQueue() - Method in class com.codeheadsystems.queue.impl.QueueProcessor

Process pending queue.

Q

queue(QueueImpl) - Method in class com.codeheadsystems.queue.module.QueueModule

Queue queue.

Queue - Interface in com.codeheadsystems.queue

The interface Queue.

queueConfiguration() - Method in class com.codeheadsystems.queue.factory.QueueConfigurationFactory

Queue configuration queue configuration.

QueueConfiguration - Interface in com.codeheadsystems.queue

The interface Queue configuration.

QueueConfigurationFactory - Class in com.codeheadsystems.queue.factory

Not really a factory.

QueueConfigurationFactory(Optional<QueueConfiguration>) - Constructor for class com.codeheadsystems.queue.factory.QueueConfigurationFactory

Instantiates a new Queue configuration factory.

queueExecutorIdleSeconds() - Method in interface com.codeheadsystems.queue.QueueConfiguration

Queue executor idle seconds int.

queueExecutorMaxThreads() - Method in interface com.codeheadsystems.queue.QueueConfiguration

Queue executor max threads int.

queueExecutorMinThreads() - Method in interface com.codeheadsystems.queue.QueueConfiguration

Queue executor min threads int.

QueueImpl - Class in com.codeheadsystems.queue.impl

The type Queue.

QueueImpl(MessageManager, QueueConfigurationFactory, Metrics) - Constructor for class com.codeheadsystems.queue.impl.QueueImpl

Instantiates a new Queue.

QueueModule - Class in com.codeheadsystems.queue.module

The type Queue module.

QueueModule() - Constructor for class com.codeheadsystems.queue.module.QueueModule

Instantiates a new Queue module.

QueueProcessor - Class in com.codeheadsystems.queue.impl

The Queue Processor.

QueueProcessor(MessageManager, QueueConfigurationFactory, MessageConsumerExecutor, Metrics) - Constructor for class com.codeheadsystems.queue.impl.QueueProcessor

Instantiates a new Queue processor.

queueProcessorInitialDelay() - Method in interface com.codeheadsystems.queue.QueueConfiguration

Queue processor initial delay int for processing the durable queue for entries.

queueProcessorInterval() - Method in interface com.codeheadsystems.queue.QueueConfiguration

Queue processor interval int for processing the durable queue for entries.

QueueRegister - Class in com.codeheadsystems.queue.impl

The type Queue register.

QueueRegister(Map<String, MessageConsumer>) - Constructor for class com.codeheadsystems.queue.impl.QueueRegister

Instantiates a new Queue register.

R

readByHash(long) - Method in interface com.codeheadsystems.queue.dao.MessageDao

Read by hash optional.

register(String, MessageConsumer) - Method in class com.codeheadsystems.queue.impl.QueueRegister

Register.

runLiquibase(Connection, String) - Method in class com.codeheadsystems.queue.util.LiquibaseHelper

Run liquibase.

runLiquibase(DataSource, String) - Method in class com.codeheadsystems.queue.util.LiquibaseHelper

Run liquibase.

S

saveMessage(String, String) - Method in class com.codeheadsystems.queue.manager.MessageManager

Save message optional.

setActivating(Message) - Method in class com.codeheadsystems.queue.manager.MessageManager

Sets activating.

setAllToPending() - Method in class com.codeheadsystems.queue.manager.MessageManager

Sets all to pending.

setProcessing(Message) - Method in class com.codeheadsystems.queue.manager.MessageManager

Sets processing.

start() - Method in class com.codeheadsystems.queue.impl.MessageConsumerExecutor

start() - Method in class com.codeheadsystems.queue.impl.QueueProcessor

state() - Method in interface com.codeheadsystems.queue.dao.StateCount

State state.

State - Enum Class in com.codeheadsystems.queue

The enum Queue state.

StateCount - Interface in com.codeheadsystems.queue.dao

The interface State count.

stateOf(Message) - Method in interface com.codeheadsystems.queue.dao.MessageDao

State of optional.

stop() - Method in class com.codeheadsystems.queue.impl.MessageConsumerExecutor

stop() - Method in class com.codeheadsystems.queue.impl.QueueProcessor

store(Message, State) - Method in interface com.codeheadsystems.queue.dao.MessageDao

Store.

T

timestamp() - Method in interface com.codeheadsystems.queue.Message

Created instant.

U

updateAllToState(State) - Method in interface com.codeheadsystems.queue.dao.MessageDao

Update state.

updateState(Message, State) - Method in interface com.codeheadsystems.queue.dao.MessageDao

Update state.

V

valueOf(String) - Static method in enum class com.codeheadsystems.queue.State

Returns the enum constant of this class with the specified name.

values() - Static method in enum class com.codeheadsystems.queue.State

Returns an array containing the constants of this enum class, in the order they are declared.

W

waitBetweenPollsSeconds() - Method in interface com.codeheadsystems.queue.QueueConfiguration

Wait between polls seconds int.

A C D E F G H I L M P Q R S T U V W
All Classes and Interfaces|All Packages