Uses of Class
com.github.workerframework.api.QueueException

Packages that use QueueException

Package	Description
com.github.workerframework.api
com.github.workerframework.core
com.github.workerframework.queues.rabbit

Uses of QueueException in com.github.workerframework.api

Methods in com.github.workerframework.api that throw QueueException

Modifier and Type	Method	Description
ManagedWorkerQueue	WorkerQueueProvider.getWorkerQueue(ConfigurationSource configurationSource, int maxTasks)	Create a new WorkerQueue instance.
void	WorkerQueue.publish(TaskInformation taskInformation, byte[] taskMessage, String targetQueue, Map<String,Object> headers)	Acknowledge the original received message but send out a new message to a target queue.
void	WorkerQueue.publish(TaskInformation taskInformation, byte[] taskMessage, String targetQueue, Map<String,Object> headers, boolean isLastMessage)	Acknowledge the original received message but send out a new message to a target queue.
void	ManagedWorkerQueue.start(TaskCallback callback)	Open queues to start accepting tasks and results.

Uses of QueueException in com.github.workerframework.core

Methods in com.github.workerframework.core that throw QueueException

Modifier and Type	Method	Description
void	WorkerApplication.run(WorkerConfiguration workerConfiguration, io.dropwizard.core.setup.Environment environment)	Start the asynchronous worker micro-service.

Uses of QueueException in com.github.workerframework.queues.rabbit

Methods in com.github.workerframework.queues.rabbit that throw QueueException

Modifier and Type	Method	Description
ManagedWorkerQueue	RabbitWorkerQueueProvider.getWorkerQueue(ConfigurationSource configurationSource, int maxTasks)
void	RabbitWorkerQueue.publish(TaskInformation taskInformation, byte[] taskMessage, String targetQueue, Map<String,Object> headers)
void	RabbitWorkerQueue.publish(TaskInformation taskInformation, byte[] taskMessage, String targetQueue, Map<String,Object> headers, boolean isLastMessage)
void	RabbitWorkerQueue.start(TaskCallback callback)	Open queues to start accepting tasks and results.