A B C D E G H I L M N O P R S T V W

A

AdaptrisMessageCodec - Class in com.adaptris.vertx

AdaptrisMessageCodec() - Constructor for class com.adaptris.vertx.AdaptrisMessageCodec

addService(InterlokService) - Method in class com.adaptris.vertx.ServiceRecord

B

BlockingExpiryQueue<T> - Class in com.adaptris.vertx.util

This queue works almost identically to an ArrayBlockingQueue, with one difference.

BlockingExpiryQueue(int) - Constructor for class com.adaptris.vertx.util.BlockingExpiryQueue

BlockingExpiryQueue(int, boolean) - Constructor for class com.adaptris.vertx.util.BlockingExpiryQueue

build(VertxProperties) - Method in class com.adaptris.vertx.VertxPropertyBuilder

C

closeService() - Method in class com.adaptris.vertx.VertxService

closeWorkflow() - Method in class com.adaptris.vertx.VertxWorkflow

com.adaptris.vertx - package com.adaptris.vertx

com.adaptris.vertx.util - package com.adaptris.vertx.util

ConsumerEventListener - Interface in com.adaptris.vertx

consumerStarted() - Method in interface com.adaptris.vertx.ConsumerEventListener

consumerStarted() - Method in class com.adaptris.vertx.VertxService

consumerStarted() - Method in class com.adaptris.vertx.VertxWorkflow

continueOnError() - Method in class com.adaptris.vertx.VertxWorkflow

D

decodeFromWire(int, Buffer) - Method in class com.adaptris.vertx.AdaptrisMessageCodec

doService(AdaptrisMessage) - Method in class com.adaptris.vertx.VertxService

E

encodeToWire(Buffer, VertXMessage) - Method in class com.adaptris.vertx.AdaptrisMessageCodec

equals(Object) - Method in class com.adaptris.vertx.InterlokService

equals(Object) - Method in class com.adaptris.vertx.VertXMessage

ExpiryListener<T> - Interface in com.adaptris.vertx.util

G

getAdaptrisMessage() - Method in class com.adaptris.vertx.VertXMessage

getBlockedThreadCheckInterval() - Method in class com.adaptris.vertx.VertxProperties

getClusterId() - Method in interface com.adaptris.vertx.ConsumerEventListener

getClusterId() - Method in class com.adaptris.vertx.VertxService

getClusterId() - Method in class com.adaptris.vertx.VertxWorkflow

getContinueOnError() - Method in class com.adaptris.vertx.VertxWorkflow

getEventLoopPoolSize() - Method in class com.adaptris.vertx.VertxProperties

getException() - Method in class com.adaptris.vertx.InterlokService

getExpiryTimeout() - Method in class com.adaptris.vertx.util.BlockingExpiryQueue

getHaEnabled() - Method in class com.adaptris.vertx.VertxProperties

getHaGroup() - Method in class com.adaptris.vertx.VertxProperties

getId() - Method in class com.adaptris.vertx.InterlokService

getInternalBlockingPoolSize() - Method in class com.adaptris.vertx.VertxProperties

getItemExpiryTimeout() - Method in class com.adaptris.vertx.VertxWorkflow

getMarshaller() - Method in class com.adaptris.vertx.AdaptrisMessageCodec

getMaxEventLoopExecuteTime() - Method in class com.adaptris.vertx.VertxProperties

getMaxThreads() - Method in class com.adaptris.vertx.VertxService

getMaxThreads() - Method in class com.adaptris.vertx.VertxWorkflow

getMaxWorkerExecuteTime() - Method in class com.adaptris.vertx.VertxProperties

getPreferNativeTransport() - Method in class com.adaptris.vertx.VertxProperties

getQueueCapacity() - Method in class com.adaptris.vertx.VertxWorkflow

getQuorumSize() - Method in class com.adaptris.vertx.VertxProperties

getReplyService() - Method in class com.adaptris.vertx.VertxService

getReplyServiceExceptionHandler() - Method in class com.adaptris.vertx.VertxService

getService() - Method in class com.adaptris.vertx.VertxService

getServiceRecord() - Method in class com.adaptris.vertx.VertXMessage

getServices() - Method in class com.adaptris.vertx.ServiceRecord

getStartProcessingTime() - Method in class com.adaptris.vertx.VertXMessage

getState() - Method in class com.adaptris.vertx.InterlokService

getTargetComponentId() - Method in class com.adaptris.vertx.VertxService

getTargetComponentId() - Method in class com.adaptris.vertx.VertxWorkflow

getTargetSendMode() - Method in class com.adaptris.vertx.VertxService

getTargetSendMode() - Method in class com.adaptris.vertx.VertxWorkflow

getUniqueId() - Method in interface com.adaptris.vertx.ConsumerEventListener

getVertXMessageTranslator() - Method in class com.adaptris.vertx.VertxService

getVertXMessageTranslator() - Method in class com.adaptris.vertx.VertxWorkflow

getVertxOptions() - Method in class com.adaptris.vertx.VertxPropertyBuilder

getVertxProperties() - Method in class com.adaptris.vertx.VertxService

getVertxProperties() - Method in class com.adaptris.vertx.VertxWorkflow

getWarningExceptionTime() - Method in class com.adaptris.vertx.VertxProperties

getWorkerPoolSize() - Method in class com.adaptris.vertx.VertxProperties

H

handle(Message<VertXMessage>) - Method in class com.adaptris.vertx.VertxService

handle(Message<VertXMessage>) - Method in class com.adaptris.vertx.VertxWorkflow

handleMessageReply(Message<Object>) - Method in interface com.adaptris.vertx.ConsumerEventListener

handleMessageReply(Message<Object>) - Method in class com.adaptris.vertx.VertxService

handleMessageReply(Message<Object>) - Method in class com.adaptris.vertx.VertxWorkflow

hashCode() - Method in class com.adaptris.vertx.InterlokService

hashCode() - Method in class com.adaptris.vertx.VertXMessage

I

initialiseWorkflow() - Method in class com.adaptris.vertx.VertxWorkflow

initService() - Method in class com.adaptris.vertx.VertxService

InterlokService - Class in com.adaptris.vertx

InterlokService() - Constructor for class com.adaptris.vertx.InterlokService

InterlokService(String) - Constructor for class com.adaptris.vertx.InterlokService

InterlokService(String, ServiceState) - Constructor for class com.adaptris.vertx.InterlokService

itemExpired(T) - Method in interface com.adaptris.vertx.util.ExpiryListener

itemExpired(VertXMessage) - Method in class com.adaptris.vertx.VertxWorkflow

L

log - Variable in class com.adaptris.vertx.AdaptrisMessageCodec

log - Variable in class com.adaptris.vertx.util.BlockingExpiryQueue

log - Variable in class com.adaptris.vertx.VertXMessageTranslator

M

maxThreads() - Method in class com.adaptris.vertx.VertxService

maxThreads() - Method in class com.adaptris.vertx.VertxWorkflow

MessageTranslator - Interface in com.adaptris.vertx

N

name() - Method in class com.adaptris.vertx.AdaptrisMessageCodec

notifyListenerOfExpiry(T) - Method in class com.adaptris.vertx.util.BlockingExpiryQueue

O

onAdaptrisMessage(AdaptrisMessage, Consumer<AdaptrisMessage>) - Method in class com.adaptris.vertx.VertxWorkflow

onVertxMessage(Message<VertXMessage>) - Method in class com.adaptris.vertx.VertxWorkflow

P

prepare() - Method in class com.adaptris.vertx.VertxService

prepareWorkflow() - Method in class com.adaptris.vertx.VertxWorkflow

put(T) - Method in class com.adaptris.vertx.util.BlockingExpiryQueue

R

registerExpiryListener(ExpiryListener<T>) - Method in class com.adaptris.vertx.util.BlockingExpiryQueue

resubmitMessage(AdaptrisMessage) - Method in class com.adaptris.vertx.VertxWorkflow

S

SendMode - Class in com.adaptris.vertx

The mode in which to send messages.

SendMode() - Constructor for class com.adaptris.vertx.SendMode

SendMode.Mode - Enum in com.adaptris.vertx

ServiceRecord - Class in com.adaptris.vertx

ServiceRecord() - Constructor for class com.adaptris.vertx.ServiceRecord

ServiceRecordException - Exception in com.adaptris.vertx

ServiceRecordException() - Constructor for exception com.adaptris.vertx.ServiceRecordException

Creates a new instance.

ServiceRecordException(Throwable) - Constructor for exception com.adaptris.vertx.ServiceRecordException

Creates a new instance with a reference to a previous Exception.

ServiceRecordException(String) - Constructor for exception com.adaptris.vertx.ServiceRecordException

Creates a new instance with a description of the Exception.

ServiceRecordException(String, Throwable) - Constructor for exception com.adaptris.vertx.ServiceRecordException

Creates a new instance with a reference to a previous Exception and a description of the Exception.

ServiceState - Enum in com.adaptris.vertx

setAdaptrisMessage(SerializableAdaptrisMessage) - Method in class com.adaptris.vertx.VertXMessage

setBlockedThreadCheckInterval(Long) - Method in class com.adaptris.vertx.VertxProperties

Sets the value of blocked thread check period, in blockedThreadCheckIntervalUnit.

setClusterId(String) - Method in class com.adaptris.vertx.VertxService

Sets the ID that will be registered with vertx.

setClusterId(String) - Method in class com.adaptris.vertx.VertxWorkflow

Sets the ID that will be registered with vertx.

setContinueOnError(Boolean) - Method in class com.adaptris.vertx.VertxWorkflow

setEventLoopPoolSize(Integer) - Method in class com.adaptris.vertx.VertxProperties

Set the number of event loop threads to be used by the Vert.x instance.

setException(Exception) - Method in class com.adaptris.vertx.InterlokService

setExpiryTimeout(TimeInterval) - Method in class com.adaptris.vertx.util.BlockingExpiryQueue

setHaEnabled(Boolean) - Method in class com.adaptris.vertx.VertxProperties

Set whether HA will be enabled on the Vert.x instance.

setHaGroup(String) - Method in class com.adaptris.vertx.VertxProperties

Set the HA group to be used when HA is enabled.

setId(String) - Method in class com.adaptris.vertx.InterlokService

setInternalBlockingPoolSize(Integer) - Method in class com.adaptris.vertx.VertxProperties

Set the value of internal blocking pool size

setItemExpiryTimeout(TimeInterval) - Method in class com.adaptris.vertx.VertxWorkflow

setMarshaller(AdaptrisMarshaller) - Method in class com.adaptris.vertx.AdaptrisMessageCodec

setMaxEventLoopExecuteTime(Long) - Method in class com.adaptris.vertx.VertxProperties

Sets the value of max event loop execute time, in maxEventLoopExecuteTimeUnit.

setMaxThreads(Integer) - Method in class com.adaptris.vertx.VertxService

setMaxThreads(Integer) - Method in class com.adaptris.vertx.VertxWorkflow

setMaxWorkerExecuteTime(Long) - Method in class com.adaptris.vertx.VertxProperties

Sets the value of max worker execute time, in maxWorkerExecuteTimeUnit.

setPreferNativeTransport(Boolean) - Method in class com.adaptris.vertx.VertxProperties

Set wether to prefer the native transport to the JDK transport.

setQueueCapacity(Integer) - Method in class com.adaptris.vertx.VertxWorkflow

setQuorumSize(Integer) - Method in class com.adaptris.vertx.VertxProperties

Set the quorum size to be used when HA is enabled.

setReplyService(Service) - Method in class com.adaptris.vertx.VertxService

setReplyServiceExceptionHandler(ProcessingExceptionHandler) - Method in class com.adaptris.vertx.VertxService

setService(Service) - Method in class com.adaptris.vertx.VertxService

setServiceRecord(ServiceRecord) - Method in class com.adaptris.vertx.VertXMessage

setServices(List<InterlokService>) - Method in class com.adaptris.vertx.ServiceRecord

setStartProcessingTime(long) - Method in class com.adaptris.vertx.VertXMessage

setState(ServiceState) - Method in class com.adaptris.vertx.InterlokService

setTargetComponentId(DataInputParameter<String>) - Method in class com.adaptris.vertx.VertxService

setTargetComponentId(DataInputParameter<String>) - Method in class com.adaptris.vertx.VertxWorkflow

setTargetSendMode(SendMode.Mode) - Method in class com.adaptris.vertx.VertxService

setTargetSendMode(SendMode.Mode) - Method in class com.adaptris.vertx.VertxWorkflow

setVertXMessageTranslator(VertXMessageTranslator) - Method in class com.adaptris.vertx.VertxService

setVertXMessageTranslator(VertXMessageTranslator) - Method in class com.adaptris.vertx.VertxWorkflow

setVertxOptions(VertxOptions) - Method in class com.adaptris.vertx.VertxPropertyBuilder

setVertxProperties(VertxProperties) - Method in class com.adaptris.vertx.VertxService

setVertxProperties(VertxProperties) - Method in class com.adaptris.vertx.VertxWorkflow

setWarningExceptionTime(Long) - Method in class com.adaptris.vertx.VertxProperties

Set the threshold value above this, the blocked warning contains a stack trace.

setWorkerPoolSize(Integer) - Method in class com.adaptris.vertx.VertxProperties

Set the maximum number of worker threads to be used by the Vert.x instance.

start() - Method in class com.adaptris.vertx.VertxService

startWorkflow() - Method in class com.adaptris.vertx.VertxWorkflow

stop() - Method in class com.adaptris.vertx.VertxService

stopWorkflow() - Method in class com.adaptris.vertx.VertxWorkflow

systemCodecID() - Method in class com.adaptris.vertx.AdaptrisMessageCodec

T

targetComponentId(VertXMessage) - Method in class com.adaptris.vertx.VertxWorkflow

toString() - Method in class com.adaptris.vertx.InterlokService

toString() - Method in class com.adaptris.vertx.ServiceRecord

toString() - Method in class com.adaptris.vertx.VertXMessage

transform(VertXMessage) - Method in class com.adaptris.vertx.AdaptrisMessageCodec

translate(AdaptrisMessage) - Method in interface com.adaptris.vertx.MessageTranslator

translate(VertXMessage) - Method in interface com.adaptris.vertx.MessageTranslator

translate(AdaptrisMessage) - Method in class com.adaptris.vertx.VertXMessageTranslator

translate(VertXMessage) - Method in class com.adaptris.vertx.VertXMessageTranslator

V

valueOf(String) - Static method in enum com.adaptris.vertx.SendMode.Mode

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

valueOf(String) - Static method in enum com.adaptris.vertx.ServiceState

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

values() - Static method in enum com.adaptris.vertx.SendMode.Mode

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

values() - Static method in enum com.adaptris.vertx.ServiceState

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

VertXMessage - Class in com.adaptris.vertx

VertXMessage() - Constructor for class com.adaptris.vertx.VertXMessage

VertXMessage(SerializableAdaptrisMessage) - Constructor for class com.adaptris.vertx.VertXMessage

VertXMessageTranslator - Class in com.adaptris.vertx

VertXMessageTranslator() - Constructor for class com.adaptris.vertx.VertXMessageTranslator

VertxProperties - Class in com.adaptris.vertx

This class exposes many of the internal Vertx engine properties.

VertxProperties() - Constructor for class com.adaptris.vertx.VertxProperties

VertxPropertyBuilder - Class in com.adaptris.vertx

VertxPropertyBuilder() - Constructor for class com.adaptris.vertx.VertxPropertyBuilder

VertxService - Class in com.adaptris.vertx

A clustered service that allows you to farm out the service processing to a random instance of this service in your cluster.
Clusters are managed and discovered by Hazelcast.

VertxService() - Constructor for class com.adaptris.vertx.VertxService

VertxWorkflow - Class in com.adaptris.vertx

A clustered workflow that allows you to farm out the service-list processing to a random instance of this workflow in your cluster.

VertxWorkflow() - Constructor for class com.adaptris.vertx.VertxWorkflow

W

wrappedServices() - Method in class com.adaptris.vertx.VertxService

A B C D E G H I L M N O P R S T V W