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

A

AcknowledgeEndpoint - class org.codehaus.activemq.jca.AcknowledgeEndpoint.
An endpoint which uses a JMS Message.acknowledge() to acknowledge that a message is delivered.
AcknowledgeEndpoint(MessageListener) - Constructor for class org.codehaus.activemq.jca.AcknowledgeEndpoint
 
addConnector() - Method in class org.codehaus.activemq.jca.JCAContainer
 
afterDelivery() - Method in class org.codehaus.activemq.jca.AcknowledgeEndpoint
 
afterDelivery() - Method in class org.codehaus.activemq.jca.LocalTransactionEndpoint
 
afterDelivery() - Method in class org.codehaus.activemq.jca.XAEndpoint
 
afterPropertiesSet() - Method in class org.codehaus.activemq.jca.DefaultEndpointFactory
 
afterPropertiesSet() - Method in class org.codehaus.activemq.jca.JCAConnector
 
afterPropertiesSet() - Method in class org.codehaus.activemq.jca.JCAContainer
 
afterPropertiesSet() - Method in class org.codehaus.activemq.jca.TargetSourceMessageListener
 
afterPropertiesSet() - Method in class org.codehaus.activemq.work.SpringWorkManager
 

B

BridgeBean - class org.codehaus.activemq.bean.BridgeBean.
A simple Bridge POJO which will copy messages from one destination to another optionally performing some kind of transformation.
BridgeBean(Session, MessageProducer, Destination) - Constructor for class org.codehaus.activemq.bean.BridgeBean
 
beforeDelivery(Method) - Method in class org.codehaus.activemq.jca.AcknowledgeEndpoint
 
beforeDelivery(Method) - Method in class org.codehaus.activemq.jca.LocalTransactionEndpoint
 
beforeDelivery(Method) - Method in class org.codehaus.activemq.jca.XAEndpoint
 
begin(Xid, long) - Method in interface org.codehaus.activemq.work.XAWork
 

C

call(Destination, Message, long) - Method in class org.codehaus.activemq.bean.JmsHelper
Performs an RPC to the given destination - blocking until a reply is received up to the given timeout
call(Destination, Message) - Method in class org.codehaus.activemq.bean.JmsHelper
Performs an RPC to the given destination - blocking until a reply is received up to some maximum timeout
close() - Method in class org.codehaus.activemq.bean.Requestor
Closes the Requestor and its session.
close() - Method in class org.codehaus.activemq.pool.PooledConnection
 
configureMessage(Message, Message) - Method in class org.codehaus.activemq.bean.TransformerBean
Append any custom header properties
createAlreadyClosedException() - Method in class org.codehaus.activemq.pool.PooledConnection
 
createConnectionConsumer(Destination, String, ServerSessionPool, int) - Method in class org.codehaus.activemq.pool.PooledConnection
 
createConnectionConsumer(Topic, String, ServerSessionPool, int) - Method in class org.codehaus.activemq.pool.PooledConnection
 
createConnectionConsumer(Queue, String, ServerSessionPool, int) - Method in class org.codehaus.activemq.pool.PooledConnection
 
createDurableConnectionConsumer(Topic, String, String, ServerSessionPool, int) - Method in class org.codehaus.activemq.pool.PooledConnection
 
createEndpoint(XAResource) - Method in class org.codehaus.activemq.jca.DefaultEndpointFactory
 
createEntityResolver() - Method in class org.codehaus.activemq.jca.impl.JCABeanDefinitionReader
 
createMessage(String) - Method in class org.codehaus.activemq.bean.TransformerBean
 
createObjectMessage(Serializable) - Method in class org.codehaus.activemq.bean.JmsHelper
 
createOutputMessage(Message) - Method in class org.codehaus.activemq.bean.BridgeBean
A strategy method to create a new message given an input message
createQueueSession(boolean, int) - Method in class org.codehaus.activemq.pool.PooledConnection
 
createReader() - Method in class org.codehaus.activemq.jca.JCABeanFactory
A hook to allow custom ActiveMQBeanFactory implementations to provide their own custom parser of the XML to perform macro processing or perform XSLT etc
createSession(boolean, int) - Method in class org.codehaus.activemq.pool.PooledConnection
 
createSource(Message) - Method in class org.codehaus.activemq.bean.TransformerBean
 
createSource(String) - Method in class org.codehaus.activemq.bean.TransformerBean
 
createTemporaryDestination(Session) - Method in class org.codehaus.activemq.bean.Requestor
 
createTextMessage(String) - Method in class org.codehaus.activemq.bean.JmsHelper
 
createTimer() - Method in class org.codehaus.activemq.jca.JCAContainer
 
createTopicSession(boolean, int) - Method in class org.codehaus.activemq.pool.PooledConnection
 
createTransformer(Source) - Static method in class org.codehaus.activemq.jca.impl.JCABeanDefinitionReader
 
createXslSource() - Method in class org.codehaus.activemq.jca.impl.JCABeanDefinitionReader
Creates the XSL resource for the transformation

D

DefaultEndpointFactory - class org.codehaus.activemq.jca.DefaultEndpointFactory.
A factory of MessageEndpoint instances, either using XA transactions, Local (JMS) transactions or regular JMS message acknowledgements.
DefaultEndpointFactory() - Constructor for class org.codehaus.activemq.jca.DefaultEndpointFactory
 
DefaultEndpointFactory(MessageListener) - Constructor for class org.codehaus.activemq.jca.DefaultEndpointFactory
 
DefaultEndpointFactory(MessageListener, TransactionManager) - Constructor for class org.codehaus.activemq.jca.DefaultEndpointFactory
 
destroy() - Method in class org.codehaus.activemq.jca.JCAConnector
 
destroy() - Method in class org.codehaus.activemq.jca.JCAContainer
 
destroy() - Method in class org.codehaus.activemq.work.SpringWorkManager
 
doExecute(WorkerContext, Executor) - Method in class org.codehaus.activemq.work.pool.ScheduleWorkExecutor
 
doExecute(WorkerContext, Executor) - Method in class org.codehaus.activemq.work.pool.StartWorkExecutor
 
doExecute(WorkerContext, Executor) - Method in class org.codehaus.activemq.work.pool.SyncWorkExecutor
 
doExecute(WorkerContext, Executor) - Method in interface org.codehaus.activemq.work.pool.WorkExecutor
This method must be implemented by sub-classes in order to provide the relevant synchronization policy.
doRollback(Exception) - Method in class org.codehaus.activemq.jca.XAEndpoint
 
doWork(Work) - Method in class org.codehaus.activemq.work.SpringWorkManager
 
doWork(Work, long, ExecutionContext, WorkListener) - Method in class org.codehaus.activemq.work.SpringWorkManager
 

E

EchoBean - class org.codehaus.activemq.bean.EchoBean.
A simple bean which just logs inbound messsages.
EchoBean() - Constructor for class org.codehaus.activemq.bean.EchoBean
 
end(Xid) - Method in interface org.codehaus.activemq.work.XAWork
 
enrich(Message, Message) - Method in class org.codehaus.activemq.bean.BridgeBean
A strategy method to allow a message to be enriched, such as to append some properties from the input message
execute(Runnable) - Method in class org.codehaus.activemq.work.pool.NullWorkExecutorPool
 
execute(Runnable) - Method in class org.codehaus.activemq.work.pool.TimedOutPooledExecutor
Executes the provided task, which MUST be an instance of WorkWrapper.
execute(Runnable) - Method in class org.codehaus.activemq.work.pool.WorkExecutorPoolImpl
Execute the specified Work.

G

getAcceptedTime() - Method in class org.codehaus.activemq.work.WorkerContext
System.currentTimeMillis() when the Work has been accepted.
getActivationSpec() - Method in class org.codehaus.activemq.jca.JCAConnector
 
getBootstrapContext() - Method in class org.codehaus.activemq.jca.JCAConnector
 
getClientID() - Method in class org.codehaus.activemq.pool.PooledConnection
 
getDefaultTimeout() - Method in class org.codehaus.activemq.bean.JmsHelper
 
getEndpointFactory() - Method in class org.codehaus.activemq.jca.JCAConnector
 
getExceptionListener() - Method in class org.codehaus.activemq.pool.PooledConnection
 
getLog() - Method in class org.codehaus.activemq.bean.EchoBean
 
getMaximumPoolSize() - Method in class org.codehaus.activemq.work.pool.NullWorkExecutorPool
 
getMaximumPoolSize() - Method in interface org.codehaus.activemq.work.pool.WorkExecutorPool
Gets the maximum number of threads to simultaneously execute.
getMaximumPoolSize() - Method in class org.codehaus.activemq.work.pool.WorkExecutorPoolImpl
Gets the maximum size of this pool.
getMaximumTimeout() - Method in class org.codehaus.activemq.bean.Requestor
 
getMessageListener() - Method in class org.codehaus.activemq.jca.DefaultEndpointFactory
 
getMessageListener() - Method in class org.codehaus.activemq.jca.JCAConnector
 
getMetaData() - Method in class org.codehaus.activemq.pool.PooledConnection
 
getPoolSize() - Method in class org.codehaus.activemq.work.pool.NullWorkExecutorPool
 
getPoolSize() - Method in interface org.codehaus.activemq.work.pool.WorkExecutorPool
Gets the current number of active threads in the pool.
getPoolSize() - Method in class org.codehaus.activemq.work.pool.WorkExecutorPoolImpl
Gets the size of this pool.
getProducer() - Method in class org.codehaus.activemq.bean.JmsHelper
 
getProducer() - Method in class org.codehaus.activemq.bean.TransformerBean
 
getQueueConnection() - Method in class org.codehaus.activemq.pool.PooledConnection
 
getReader() - Method in class org.codehaus.activemq.jca.JCABeanFactory
Lazily creates a reader on demand
getResourceAdapter() - Method in class org.codehaus.activemq.jca.JCAConnector
 
getResourceAdapter() - Method in class org.codehaus.activemq.jca.JCAContainer
 
getScheduledMaximumPoolSize() - Method in class org.codehaus.activemq.work.SpringWorkManager
 
getScheduledThreadCount() - Method in class org.codehaus.activemq.work.SpringWorkManager
 
getSession() - Method in class org.codehaus.activemq.bean.JmsHelper
 
getSession() - Method in class org.codehaus.activemq.bean.TransformerBean
 
getStartMaximumPoolSize() - Method in class org.codehaus.activemq.work.SpringWorkManager
 
getStartThreadCount() - Method in class org.codehaus.activemq.work.SpringWorkManager
 
getStartTimeout() - Method in class org.codehaus.activemq.work.WorkerContext
Gets the time duration (in milliseconds) within which the execution of the Work instance must start.
getSyncMaximumPoolSize() - Method in class org.codehaus.activemq.work.SpringWorkManager
 
getSyncThreadCount() - Method in class org.codehaus.activemq.work.SpringWorkManager
 
getTargetSource() - Method in class org.codehaus.activemq.jca.TargetSourceMessageListener
 
getThreadPriority() - Method in class org.codehaus.activemq.work.WorkerContext
Gets the priority level of the thread, which will be dispatched to process this work.
getTopicConnection() - Method in class org.codehaus.activemq.pool.PooledConnection
 
getTransactionManager() - Method in class org.codehaus.activemq.jca.DefaultEndpointFactory
 
getTransactionManager() - Method in class org.codehaus.activemq.jca.JCAConnector
 
getTransformer() - Method in class org.codehaus.activemq.bean.TransformerBean
 
getWorkException() - Method in class org.codehaus.activemq.work.WorkerContext
Gets the WorkException, if any, thrown during the execution.
getWorkManager() - Method in class org.codehaus.activemq.jca.JCAContainer
 
getXATerminator() - Method in class org.codehaus.activemq.jca.JCAContainer
 
getXATerminator() - Method in class org.codehaus.activemq.work.SpringWorkManager
 
getXslResource() - Method in class org.codehaus.activemq.jca.impl.JCABeanDefinitionReader
 

H

handleException(Exception) - Method in class org.codehaus.activemq.jca.TargetSourceMessageListener
 

I

isDeliveryTransacted(Method) - Method in class org.codehaus.activemq.jca.DefaultEndpointFactory
 
isTimedOut() - Method in class org.codehaus.activemq.work.WorkerContext
Used by a Work executor in order to know if this work, which should be accepted but not started has timed out.

J

JCABeanDefinitionReader - class org.codehaus.activemq.jca.impl.JCABeanDefinitionReader.
 
JCABeanDefinitionReader(BeanDefinitionRegistry) - Constructor for class org.codehaus.activemq.jca.impl.JCABeanDefinitionReader
 
JCABeanFactory - class org.codehaus.activemq.jca.JCABeanFactory.
A Spring BeanFactory for creating an JCA container
JCABeanFactory(Resource) - Constructor for class org.codehaus.activemq.jca.JCABeanFactory
Create a new JCABeanFactory with the given resource, which must be parsable using DOM.
JCABeanFactory(InputStream) - Constructor for class org.codehaus.activemq.jca.JCABeanFactory
Create a new JCABeanFactory with the given InputStream, which must be parsable using DOM.
JCABeanFactory(Resource, BeanFactory) - Constructor for class org.codehaus.activemq.jca.JCABeanFactory
Create a new JCABeanFactory with the given input stream, which must be parsable using DOM.
JCAConnector - class org.codehaus.activemq.jca.JCAConnector.
A Lightweight Message Driven Object Container which is a lightweight alternative to MDBs.
JCAConnector() - Constructor for class org.codehaus.activemq.jca.JCAConnector
 
JCAConnector(BootstrapContext, ResourceAdapter) - Constructor for class org.codehaus.activemq.jca.JCAConnector
 
JCAContainer - class org.codehaus.activemq.jca.JCAContainer.
Represents a Spring based JCA container for a single JCA ResourceAdapter which provides Message Driven POJO support to Spring, providing all the features of MDBs but using a lightweight container.
JCAContainer() - Constructor for class org.codehaus.activemq.jca.JCAContainer
 
JCADtdResolver - class org.codehaus.activemq.jca.impl.JCADtdResolver.
EntityResolver implementation for the MDO DTD, to load the DTD from the MDO classpath JAR file.
JCADtdResolver() - Constructor for class org.codehaus.activemq.jca.impl.JCADtdResolver
 
JmsHelper - class org.codehaus.activemq.bean.JmsHelper.
A helper base class POJO which can be used by any POJO deployed in the JMS container.
JmsHelper() - Constructor for class org.codehaus.activemq.bean.JmsHelper
 
JmsHelper(Session, MessageProducer) - Constructor for class org.codehaus.activemq.bean.JmsHelper
 

L

LocalTransactionEndpoint - class org.codehaus.activemq.jca.LocalTransactionEndpoint.
Performs a local transaction while processing the message
LocalTransactionEndpoint(MessageListener, LocalTransaction) - Constructor for class org.codehaus.activemq.jca.LocalTransactionEndpoint
 
logger - Variable in class org.codehaus.activemq.jca.impl.JCADtdResolver
 

N

NullWorkExecutorPool - class org.codehaus.activemq.work.pool.NullWorkExecutorPool.
 
NullWorkExecutorPool(int) - Constructor for class org.codehaus.activemq.work.pool.NullWorkExecutorPool
 

O

onJMSException(JMSException) - Method in class org.codehaus.activemq.bean.BridgeBean
Handle a JMS exception being thrown
onMessage(Message) - Method in class org.codehaus.activemq.bean.BridgeBean
 
onMessage(Message) - Method in class org.codehaus.activemq.bean.EchoBean
 
onMessage(Message) - Method in class org.codehaus.activemq.jca.AcknowledgeEndpoint
 
onMessage(Message) - Method in class org.codehaus.activemq.jca.LocalTransactionEndpoint
 
onMessage(Message) - Method in class org.codehaus.activemq.jca.TargetSourceMessageListener
 
onMessage(Message) - Method in class org.codehaus.activemq.jca.XAEndpoint
 
org.codehaus.activemq.bean - package org.codehaus.activemq.bean
A collection of lightweight reusable POJOs for bridging and transforming JMS messages
org.codehaus.activemq.jca - package org.codehaus.activemq.jca
A lightweight and easily embeddable Spring based JCA container, useful for efficient JMS message consumption from inside a JVM.
org.codehaus.activemq.jca.impl - package org.codehaus.activemq.jca.impl
Implementation classes for the Spring based JCA container
org.codehaus.activemq.pool - package org.codehaus.activemq.pool
A JMS provider which delegates to an underlying JMS implementation
org.codehaus.activemq.work - package org.codehaus.activemq.work
An implementation of the JCA WorkManager ported from the Geronimo code to reduce dependencies on Geronimo & GBeans to just have a single dependency on Spring.
org.codehaus.activemq.work.pool - package org.codehaus.activemq.work.pool
Implementation classes for the Spring based JCA WorkManager implementation

P

PooledConnection - class org.codehaus.activemq.pool.PooledConnection.
Represents a proxy Connection which is-a TopicConnection and QueueConnection which is pooled and on PooledConnection.close() will return itself to the pool.
PooledConnection(TopicConnection, ObjectPool) - Constructor for class org.codehaus.activemq.pool.PooledConnection
 
processMessage(Message) - Method in class org.codehaus.activemq.bean.TransformerBean
 
provideEndLatch() - Method in class org.codehaus.activemq.work.WorkerContext
Provides a latch, which can be used to wait the end of a work execution.
provideStartLatch() - Method in class org.codehaus.activemq.work.WorkerContext
Provides a latch, which can be used to wait the start of a work execution.

R

Requestor - class org.codehaus.activemq.bean.Requestor.
A helper class for performing remote method invocations over JMS.
Requestor(Session, Destination) - Constructor for class org.codehaus.activemq.bean.Requestor
Constructor for the Requestor class.
registerBeanDefinitions(Document, Resource) - Method in class org.codehaus.activemq.jca.impl.JCABeanDefinitionReader
 
release() - Method in class org.codehaus.activemq.jca.AcknowledgeEndpoint
 
release() - Method in class org.codehaus.activemq.jca.LocalTransactionEndpoint
 
release() - Method in class org.codehaus.activemq.jca.XAEndpoint
 
release() - Method in class org.codehaus.activemq.work.WorkerContext
 
request(Message) - Method in class org.codehaus.activemq.bean.Requestor
Sends a request and waits for a reply.
request(Message, long) - Method in class org.codehaus.activemq.bean.Requestor
Sends a request and waits for a reply up to a maximum timeout.
resolveEntity(String, String) - Method in class org.codehaus.activemq.jca.impl.JCADtdResolver
 
run() - Method in class org.codehaus.activemq.work.WorkerContext
 

S

ScheduleWorkExecutor - class org.codehaus.activemq.work.pool.ScheduleWorkExecutor.
 
ScheduleWorkExecutor() - Constructor for class org.codehaus.activemq.work.pool.ScheduleWorkExecutor
 
SpringWorkManager - class org.codehaus.activemq.work.SpringWorkManager.
WorkManager implementation which uses under the cover three WorkExecutorPool - one for each synchronization policy - in order to dispatch the submitted Work instances.
SpringWorkManager() - Constructor for class org.codehaus.activemq.work.SpringWorkManager
Create a WorkManager.
SpringWorkManager(int, XAWork) - Constructor for class org.codehaus.activemq.work.SpringWorkManager
 
SpringWorkManager(int, int, int, XAWork) - Constructor for class org.codehaus.activemq.work.SpringWorkManager
 
StartWorkExecutor - class org.codehaus.activemq.work.pool.StartWorkExecutor.
 
StartWorkExecutor() - Constructor for class org.codehaus.activemq.work.pool.StartWorkExecutor
 
SyncWorkExecutor - class org.codehaus.activemq.work.pool.SyncWorkExecutor.
 
SyncWorkExecutor() - Constructor for class org.codehaus.activemq.work.pool.SyncWorkExecutor
 
scheduleWork(Work) - Method in class org.codehaus.activemq.work.SpringWorkManager
 
scheduleWork(Work, long, ExecutionContext, WorkListener) - Method in class org.codehaus.activemq.work.SpringWorkManager
 
send(Destination, Message) - Method in class org.codehaus.activemq.bean.JmsHelper
 
send(Message) - Method in class org.codehaus.activemq.bean.JmsHelper
 
send(String, Message, boolean) - Method in class org.codehaus.activemq.bean.JmsHelper
 
send(Message) - Method in class org.codehaus.activemq.bean.TransformerBean
 
setActivationSpec(ActivationSpec) - Method in class org.codehaus.activemq.jca.JCAConnector
 
setBeanFactory(BeanFactory) - Method in class org.codehaus.activemq.jca.JCAContainer
 
setBootstrapContext(BootstrapContext) - Method in class org.codehaus.activemq.jca.JCAConnector
 
setClientID(String) - Method in class org.codehaus.activemq.pool.PooledConnection
 
setDefaultTimeout(long) - Method in class org.codehaus.activemq.bean.JmsHelper
 
setEndpointFactory(MessageEndpointFactory) - Method in class org.codehaus.activemq.jca.JCAConnector
 
setExceptionListener(ExceptionListener) - Method in class org.codehaus.activemq.pool.PooledConnection
 
setLog(Log) - Method in class org.codehaus.activemq.bean.EchoBean
 
setMaximumPoolSize(int) - Method in class org.codehaus.activemq.work.pool.NullWorkExecutorPool
 
setMaximumPoolSize(int) - Method in interface org.codehaus.activemq.work.pool.WorkExecutorPool
Sets the maximum number of threads to simultaneously execute.
setMaximumPoolSize(int) - Method in class org.codehaus.activemq.work.pool.WorkExecutorPoolImpl
Sets the maximum size of this pool.
setMaximumTimeout(long) - Method in class org.codehaus.activemq.bean.Requestor
Sets the maximum default timeout used for remote requests.
setMessageListener(MessageListener) - Method in class org.codehaus.activemq.jca.DefaultEndpointFactory
 
setMessageListener(MessageListener) - Method in class org.codehaus.activemq.jca.JCAConnector
 
setProducer(MessageProducer) - Method in class org.codehaus.activemq.bean.JmsHelper
 
setProducer(MessageProducer) - Method in class org.codehaus.activemq.bean.TransformerBean
 
setResourceAdapter(ResourceAdapter) - Method in class org.codehaus.activemq.jca.JCAConnector
 
setResourceAdapter(ResourceAdapter) - Method in class org.codehaus.activemq.jca.JCAContainer
 
setScheduledMaximumPoolSize(int) - Method in class org.codehaus.activemq.work.SpringWorkManager
 
setSession(Session) - Method in class org.codehaus.activemq.bean.JmsHelper
 
setSession(Session) - Method in class org.codehaus.activemq.bean.TransformerBean
 
setStartMaximumPoolSize(int) - Method in class org.codehaus.activemq.work.SpringWorkManager
 
setSyncMaximumPoolSize(int) - Method in class org.codehaus.activemq.work.SpringWorkManager
 
setTargetSource(TargetSource) - Method in class org.codehaus.activemq.jca.TargetSourceMessageListener
 
setThreadPriority(int) - Method in class org.codehaus.activemq.work.WorkerContext
Defines the thread priority level of the thread, which will be dispatched to process this work.
setTransactionManager(TransactionManager) - Method in class org.codehaus.activemq.jca.DefaultEndpointFactory
 
setTransactionManager(TransactionManager) - Method in class org.codehaus.activemq.jca.JCAConnector
 
setTransformer(Transformer) - Method in class org.codehaus.activemq.bean.TransformerBean
 
setWorkManager(WorkManager) - Method in class org.codehaus.activemq.jca.JCAContainer
 
setXaTerminator(XATerminator) - Method in class org.codehaus.activemq.jca.JCAContainer
 
start() - Method in class org.codehaus.activemq.pool.PooledConnection
 
start() - Method in class org.codehaus.activemq.work.pool.NullWorkExecutorPool
 
start() - Method in interface org.codehaus.activemq.work.pool.WorkExecutorPool
 
start() - Method in class org.codehaus.activemq.work.pool.WorkExecutorPoolImpl
 
startWork(Work) - Method in class org.codehaus.activemq.work.SpringWorkManager
 
startWork(Work, long, ExecutionContext, WorkListener) - Method in class org.codehaus.activemq.work.SpringWorkManager
 
stop() - Method in class org.codehaus.activemq.pool.PooledConnection
 
stop() - Method in class org.codehaus.activemq.work.pool.NullWorkExecutorPool
 
stop() - Method in interface org.codehaus.activemq.work.pool.WorkExecutorPool
 
stop() - Method in class org.codehaus.activemq.work.pool.WorkExecutorPoolImpl
Stops this pool.

T

TargetSourceMessageListener - class org.codehaus.activemq.jca.TargetSourceMessageListener.
Represents a pool of MessageListener instances using Spring's TargetSource for the underlying pool.
TargetSourceMessageListener() - Constructor for class org.codehaus.activemq.jca.TargetSourceMessageListener
 
TimedOutPooledExecutor - class org.codehaus.activemq.work.pool.TimedOutPooledExecutor.
PooledExecutor enforcing a timed out "blocked execution policy".
TimedOutPooledExecutor() - Constructor for class org.codehaus.activemq.work.pool.TimedOutPooledExecutor
Creates a pooled executor.
TimedOutPooledExecutor(Channel) - Constructor for class org.codehaus.activemq.work.pool.TimedOutPooledExecutor
Creates a pooled executor, which uses the provided Channel as its queueing mechanism.
TransformerBean - class org.codehaus.activemq.bean.TransformerBean.
Performs a transformation on an XML message and then sends the result to the given destination using any TrAX based Transformer instance
TransformerBean() - Constructor for class org.codehaus.activemq.bean.TransformerBean
 
toString() - Method in class org.codehaus.activemq.work.WorkerContext
 
transformDocument(Document) - Method in class org.codehaus.activemq.jca.impl.JCABeanDefinitionReader
A hook to transform the source document into a default Spring XML configuration

W

WorkExecutor - interface org.codehaus.activemq.work.pool.WorkExecutor.
 
WorkExecutorPool - interface org.codehaus.activemq.work.pool.WorkExecutorPool.
Defines the operations that a pool in charge of the execution of Work instances must expose.
WorkExecutorPoolImpl - class org.codehaus.activemq.work.pool.WorkExecutorPoolImpl.
Based class for WorkExecutorPool.
WorkExecutorPoolImpl(int) - Constructor for class org.codehaus.activemq.work.pool.WorkExecutorPoolImpl
Creates a pool with the specified minimum and maximum sizes.
WorkExecutorPoolImpl(Channel, int) - Constructor for class org.codehaus.activemq.work.pool.WorkExecutorPoolImpl
Creates a pool with the specified minimum and maximum sizes and using the specified Channel to enqueue the submitted Work instances.
WorkerContext - class org.codehaus.activemq.work.WorkerContext.
Work wrapper providing an execution context to a Work instance.
WorkerContext(Work) - Constructor for class org.codehaus.activemq.work.WorkerContext
Create a WorkWrapper.
WorkerContext(Work, long, ExecutionContext, XAWork, WorkListener) - Constructor for class org.codehaus.activemq.work.WorkerContext
Create a WorkWrapper with the specified execution context.
workAccepted(Object) - Method in class org.codehaus.activemq.work.WorkerContext
Call-back method used by a Work executor in order to notify this instance that the wrapped Work instance has been accepted.

X

XAEndpoint - class org.codehaus.activemq.jca.XAEndpoint.
An XA based Endpoint which uses an XA transaction per message delivery.
XAEndpoint(MessageListener, XAResource, TransactionManager) - Constructor for class org.codehaus.activemq.jca.XAEndpoint
 
XAWork - interface org.codehaus.activemq.work.XAWork.
 

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

Copyright © 2004-2005 Protique, Ltd.. All Rights Reserved.