A C E H I O P R S T V

A

addHeaders(Map<String, Object>) - Method in class org.gytheio.messaging.camel.CamelMessageProducer

asyncRequest(RQ) - Method in class org.gytheio.messaging.camel.CamelRequestReplyMessageProducer

C

call() - Method in class org.gytheio.messaging.camel.CamelRequestReplyMessageProducer.ReplyCallable

CamelMessageProducer - Class in org.gytheio.messaging.camel

An Apache Camel implementation of a message producer

CamelMessageProducer() - Constructor for class org.gytheio.messaging.camel.CamelMessageProducer

CamelRequestReplyMessageProducer<RQ extends org.gytheio.messaging.Request<RP>,RP extends org.gytheio.messaging.Reply> - Class in org.gytheio.messaging.camel

An Apache Camel implementation of a request-reply message producer.

CamelRequestReplyMessageProducer() - Constructor for class org.gytheio.messaging.camel.CamelRequestReplyMessageProducer

CamelRequestReplyMessageProducer.ReplyCallable - Class in org.gytheio.messaging.camel

Class which polls the pending requests map to determine if a correlated reply has been received.

CamelRequestReplyMessageProducer.ReplyCallable(String) - Constructor for class org.gytheio.messaging.camel.CamelRequestReplyMessageProducer.ReplyCallable

Constructor which takes a correlating request ID

ComponentUnavailableActionStopCamelContext - Class in org.gytheio.health.camel

ComponentUnavailableAction which stops a given Camel context.

ComponentUnavailableActionStopCamelContext() - Constructor for class org.gytheio.health.camel.ComponentUnavailableActionStopCamelContext

ComponentUnavailableActionStopCamelContext.StopContextRunnable - Class in org.gytheio.health.camel

Runnable which stops the Camel context.

ComponentUnavailableActionStopCamelContext.StopContextRunnable() - Constructor for class org.gytheio.health.camel.ComponentUnavailableActionStopCamelContext.StopContextRunnable

E

endpoint - Variable in class org.gytheio.messaging.camel.CamelMessageProducer

ERROR_SENDING - Static variable in class org.gytheio.messaging.camel.CamelMessageProducer

ExceptionProcessor - Class in org.gytheio.health.camel

Camel Processor and standard bean which provide methods to pass the exception to the specified handler.

ExceptionProcessor() - Constructor for class org.gytheio.health.camel.ExceptionProcessor

execute(Throwable) - Method in class org.gytheio.health.camel.ComponentUnavailableActionStopCamelContext

executorService - Variable in class org.gytheio.messaging.camel.CamelRequestReplyMessageProducer

H

HEADER_JMS_AMQP_MESSAGE_FORMAT - Static variable in class org.gytheio.messaging.camel.CamelMessageProducer

HEADER_JMS_AMQP_MESSAGE_FORMAT_VALUE - Static variable in class org.gytheio.messaging.camel.CamelMessageProducer

HeartbeatMonitorImpl - Class in org.gytheio.health.camel

HeartbeatMonitor implementation which uses Camel to route Heartbeat messages.

HeartbeatMonitorImpl() - Constructor for class org.gytheio.health.camel.HeartbeatMonitorImpl

I

init() - Method in class org.gytheio.messaging.camel.CamelRequestReplyMessageProducer

O

objectMapper - Variable in class org.gytheio.messaging.camel.CamelMessageProducer

onReceive(Object) - Method in class org.gytheio.health.camel.ExceptionProcessor

onReceive(Object) - Method in class org.gytheio.health.camel.HeartbeatMonitorImpl

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

org.gytheio.health.camel - package org.gytheio.health.camel

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

P

pendingRequests - Variable in class org.gytheio.messaging.camel.CamelRequestReplyMessageProducer

pollingIntervalMs - Variable in class org.gytheio.messaging.camel.CamelRequestReplyMessageProducer

process(Exchange) - Method in class org.gytheio.health.camel.ExceptionProcessor

producer - Variable in class org.gytheio.messaging.camel.CamelMessageProducer

R

run() - Method in class org.gytheio.health.camel.ComponentUnavailableActionStopCamelContext.StopContextRunnable

S

send(Object) - Method in class org.gytheio.messaging.camel.CamelMessageProducer

send(Object, Map<String, Object>) - Method in class org.gytheio.messaging.camel.CamelMessageProducer

send(Object, String) - Method in class org.gytheio.messaging.camel.CamelMessageProducer

send(Object, String, Map<String, Object>) - Method in class org.gytheio.messaging.camel.CamelMessageProducer

setCamelContext(CamelContext) - Method in class org.gytheio.health.camel.ComponentUnavailableActionStopCamelContext

Sets the Camel context to be stopped

setEndpoint(String) - Method in class org.gytheio.messaging.camel.CamelMessageProducer

The Camel endpoint for initial delivery of the messages into the Camel context which can then be routed as needed

setExecutorService(ExecutorService) - Method in class org.gytheio.messaging.camel.CamelRequestReplyMessageProducer

The executor service to be used for executing the polling callable

setHandler(ComponentUnavailableExceptionHandler) - Method in class org.gytheio.health.camel.ExceptionProcessor

setHeartbeatDao(HeartbeatDao) - Method in class org.gytheio.health.camel.HeartbeatMonitorImpl

Sets the DAO used to persist heartbeats.

setObjectMapper(ObjectMapper) - Method in class org.gytheio.messaging.camel.CamelMessageProducer

Optional object mapper to be used programatically in send(Object, String) or send(Object, String, Map) methods when an alternate endpoint is specified.

setPollingIntervalMs(long) - Method in class org.gytheio.messaging.camel.CamelRequestReplyMessageProducer

The pending request polling interval in milliseconds

setProducer(ProducerTemplate) - Method in class org.gytheio.messaging.camel.CamelMessageProducer

The Camel producer template

setShutdownGracePeriodSeconds(long) - Method in class org.gytheio.health.camel.ComponentUnavailableActionStopCamelContext

Sets the time to allow Camel to gracefully wrap up shutdown before forcing.

setSpawnNewThread(boolean) - Method in class org.gytheio.health.camel.ComponentUnavailableActionStopCamelContext

Sets whether or not to execute the shutdown in a new thread.

setTimeoutMs(long) - Method in class org.gytheio.messaging.camel.CamelRequestReplyMessageProducer

The pending request timeout in milliseconds

T

timeoutMs - Variable in class org.gytheio.messaging.camel.CamelRequestReplyMessageProducer

V

validateEndpoint(String) - Method in class org.gytheio.messaging.camel.CamelMessageProducer

Checks that the given endpoint is valid

A C E H I O P R S T V