A C D E G I J L M N O P Q R S T W

A

AbstractAsyncComponent<W extends org.gytheio.content.ContentWorker,RQ extends Request<RP>,RP extends Reply> - Class in org.gytheio.content

Base component which pulls a message off the queue before performing the work, useful when progress reporting is needed as some messaging endpoints will lock the session until the message consumption is complete and progress replies can not be sent.

AbstractAsyncComponent() - Constructor for class org.gytheio.content.AbstractAsyncComponent

AbstractAsyncComponent.LocalQueueProcessor - Class in org.gytheio.content

Takes from the local concurrent queue and hands them off to be processed

AbstractAsyncComponent.LocalQueueProcessor(BlockingQueue<RQ>) - Constructor for class org.gytheio.content.AbstractAsyncComponent.LocalQueueProcessor

AbstractComponent<W extends org.gytheio.content.ContentWorker> - Class in org.gytheio.content

Base implementation of a component with content worker and messageProducer fields.

AbstractComponent() - Constructor for class org.gytheio.content.AbstractComponent

AbstractContentReply - Class in org.gytheio.content

Base implementation of a content reply

AbstractContentReply() - Constructor for class org.gytheio.content.AbstractContentReply

AbstractContentReply(Request<?>) - Constructor for class org.gytheio.content.AbstractContentReply

AbstractContentRequest - Class in org.gytheio.content

Represents a request for some operation on content sources.

AbstractContentRequest() - Constructor for class org.gytheio.content.AbstractContentRequest

AbstractReply - Class in org.gytheio.messaging

Base implementation of a reply.

AbstractReply() - Constructor for class org.gytheio.messaging.AbstractReply

AbstractReply(Request<?>) - Constructor for class org.gytheio.messaging.AbstractReply

AbstractRequest - Class in org.gytheio.messaging

Represents a generic messaging request

AbstractRequest() - Constructor for class org.gytheio.messaging.AbstractRequest

asyncRequest(RQ) - Method in interface org.gytheio.messaging.RequestReplyMessageProducer

Sends the given request message to the configured queue and waits for its reply, returning a Future object that will contain that reply once available.

C

Component - Interface in org.gytheio.content

Defines a component which is a consumer of request for content action messages, delegates that work to a worker, and sends a reply with the results.

ContentReply - Interface in org.gytheio.content

createInstance() - Static method in class org.gytheio.messaging.jackson.ObjectMapperFactory

D

deserializeKey(String, DeserializationContext) - Method in class org.gytheio.messaging.jackson.JsonClassKeyDeserializer

deserializeKeyToClass(String) - Static method in class org.gytheio.messaging.jackson.JsonClassKeyDeserializer

E

executorService - Variable in class org.gytheio.content.AbstractAsyncComponent

G

getConsumingMessageBodyClass() - Method in interface org.gytheio.messaging.MessageConsumer

The class of POJO messages expected

getName() - Method in class org.gytheio.content.AbstractComponent

getName() - Method in interface org.gytheio.content.Component

Gets the name of the component, useful for health checks.

getReplyClass() - Method in interface org.gytheio.messaging.Request

Gets the class of expected Reply messages

getReplyTo() - Method in class org.gytheio.messaging.AbstractRequest

Gets the optional overriding reply to queue replies should be sent to

getReplyTo() - Method in interface org.gytheio.messaging.Request

Gets the optional overriding reply to queue name

getRequestId() - Method in class org.gytheio.messaging.AbstractReply

Gets the UUID for the original hash request

getRequestId() - Method in class org.gytheio.messaging.AbstractRequest

Gets the generated UUID for the transformation request

getRequestId() - Method in interface org.gytheio.messaging.Reply

The correlating request ID for the reply.

getRequestId() - Method in interface org.gytheio.messaging.Request

Gets the correlating request ID.

getResults() - Method in class org.gytheio.content.AbstractContentReply

getResults() - Method in interface org.gytheio.content.ContentReply

Gets the results of the content operation.

getSourceContentReferences() - Method in class org.gytheio.content.AbstractContentRequest

Gets the source content reference objects

getWorkerVersionDetailsString() - Method in class org.gytheio.content.AbstractComponent

getWorkerVersionDetailsString() - Method in interface org.gytheio.content.Component

Gets a string returning detailed version information such as JVM or command line application's version output

getWorkerVersionString() - Method in class org.gytheio.content.AbstractComponent

getWorkerVersionString() - Method in interface org.gytheio.content.Component

Gets a string returning name and version information

I

init() - Method in class org.gytheio.content.AbstractAsyncComponent

init() - Method in class org.gytheio.content.AbstractComponent

isWorkerAvailable() - Method in class org.gytheio.content.AbstractComponent

isWorkerAvailable() - Method in interface org.gytheio.content.Component

Determines whether or not the worker is available.

J

JsonClassKeyDeserializer - Class in org.gytheio.messaging.jackson

JsonClassKeyDeserializer() - Constructor for class org.gytheio.messaging.jackson.JsonClassKeyDeserializer

L

LoggingDeadLetterQueue - Class in org.gytheio.messaging

Endpoint which simply logs dead letter messages

LoggingDeadLetterQueue() - Constructor for class org.gytheio.messaging.LoggingDeadLetterQueue

M

MessageConsumer - Interface in org.gytheio.messaging

Defines methods for handling messages.

messageProducer - Variable in class org.gytheio.content.AbstractComponent

MessageProducer - Interface in org.gytheio.messaging

Defines methods for sending message objects to a queue.

MessagingException - Exception in org.gytheio.messaging

Exception thrown when a message is unable to be processed.

MessagingException(String) - Constructor for exception org.gytheio.messaging.MessagingException

MessagingException(String, Throwable) - Constructor for exception org.gytheio.messaging.MessagingException

N

name - Variable in class org.gytheio.content.AbstractComponent

O

ObjectMapperFactory - Class in org.gytheio.messaging.jackson

ObjectMapperFactory() - Constructor for class org.gytheio.messaging.jackson.ObjectMapperFactory

onReceive(Object) - Method in class org.gytheio.content.AbstractComponent

onReceive(Object) - Method in class org.gytheio.messaging.LoggingDeadLetterQueue

onReceive(Object) - Method in interface org.gytheio.messaging.MessageConsumer

Performs any processing required upon receiving the given POJO message

onReceiveImpl(Object) - Method in class org.gytheio.content.AbstractAsyncComponent

onReceiveImpl(Object) - Method in class org.gytheio.content.AbstractComponent

org.gytheio.content - package org.gytheio.content

org.gytheio.messaging - package org.gytheio.messaging

org.gytheio.messaging.jackson - package org.gytheio.messaging.jackson

P

processRequest(RQ) - Method in class org.gytheio.content.AbstractAsyncComponent

Performs the actual work for the request.

Q

QpidJsonBodyCleanerObjectMapper - Class in org.gytheio.messaging.jackson

Extension of ObjectMapper which cleans erroneous characters apparently added by the Qpid library before the start of a JSON object.

QpidJsonBodyCleanerObjectMapper() - Constructor for class org.gytheio.messaging.jackson.QpidJsonBodyCleanerObjectMapper

R

readValue(InputStream, Class<T>) - Method in class org.gytheio.messaging.jackson.QpidJsonBodyCleanerObjectMapper

Reply - Interface in org.gytheio.messaging

Defines a reply message for a specific Request message

Request<RP extends Reply> - Interface in org.gytheio.messaging

Defines a request message where a Reply is expected

RequestReplyMessageProducer<RQ extends Request<RP>,RP extends Reply> - Interface in org.gytheio.messaging

Defines an asynchronous request-reply message producer

run() - Method in class org.gytheio.content.AbstractAsyncComponent.LocalQueueProcessor

S

send(Object) - Method in interface org.gytheio.messaging.MessageProducer

Send the given POJO message to the default queue for the producer

send(Object, Map<String, Object>) - Method in interface org.gytheio.messaging.MessageProducer

Send the given POJO message to the default queue for the producer with the given headers.

send(Object, String) - Method in interface org.gytheio.messaging.MessageProducer

Send the given POJO message to the given queue

send(Object, String, Map<String, Object>) - Method in interface org.gytheio.messaging.MessageProducer

Send the given POJO message to the given queue with the given headers.

setExecutorService(ExecutorService) - Method in class org.gytheio.content.AbstractAsyncComponent

Sets the executor service components may optionally need for running separate threads.

setMessageProducer(MessageProducer) - Method in class org.gytheio.content.AbstractComponent

Sets the message producer used to send replies

setName(String) - Method in class org.gytheio.content.AbstractComponent

Sets the component name

setReplyTo(String) - Method in class org.gytheio.messaging.AbstractRequest

Sets the optional overriding reply to queue replies should be sent to

setReplyTo(String) - Method in interface org.gytheio.messaging.Request

Sets the optional overriding reply to queue name

setRequestId(String) - Method in class org.gytheio.messaging.AbstractReply

Sets the UUID for the original hash request

setResults(List<ContentWorkResult>) - Method in class org.gytheio.content.AbstractContentReply

setSourceContentReferences(List<ContentReference>) - Method in class org.gytheio.content.AbstractContentRequest

Sets the source content reference objects

setWorker(W) - Method in class org.gytheio.content.AbstractComponent

Sets the transformer worker which does the actual work of the transformation

T

toString() - Method in class org.gytheio.content.AbstractComponent

W

worker - Variable in class org.gytheio.content.AbstractComponent

A C D E G I J L M N O P Q R S T W