|
| |
|
| java.lang.Object
 org.objectweb.jonas_ejb.container.JFactory
org.objectweb.jonas_ejb.container.JMdbEndpointFactory
| JMdbEndpointFactory | | public class JMdbEndpointFactory extends JFactory implements MessageEndpointFactory(Code) | | This class is a factory for a Message Driven Bean Endpoints There is one such
class per MDB class. Contains all information related to the bean
author:
Eric Hardesty |
| JMdbEndpointFactory | | public JMdbEndpointFactory(MessageDrivenDesc dd, JContainer cont, ActivationSpec as)(Code) | | Constructor
Parameters:
dd - Message Driven Descriptor
Parameters:
cont - Container where this bean is defined
Parameters:
as - ActivationSpec to link the Container to |
| JMdbEndpointFactory | | public JMdbEndpointFactory(MessageDrivenDesc dd, String destination, JContainer cont, ActivationSpec as)(Code) | | Constructor
Parameters:
dd - Message Driven Descriptor
Parameters:
destination - String of desired destination
Parameters:
cont - Container where this bean is defined
Parameters:
as - ActivationSpec to link the Container to |
| checkTransaction | | public void checkTransaction(RequestCtx rctx)(Code) | | For Message Driven Beans, only 2 cases are possible:
TX_REQUIRED or TX_NOT_SUPPORTED
Parameters:
rctx - The Request Context |
| createEndpoint | | public MessageEndpoint createEndpoint(XAResource xaResource) throws UnavailableException(Code) | | Create the message endpoint
Parameters:
xaResource - XAResource object to attach MessageEndpoint to deliver messages to
throws:
UnavailableException - exception to throw |
| getCacheSize | | public int getCacheSize()(Code) | | current cache size ( = nb of instance created) for Jmx |
| getMaxCacheSize | | public int getMaxCacheSize()(Code) | | max cache size for Jmx |
| getMessageEndpoint | | public JMessageEndpoint getMessageEndpoint() throws Exception(Code) | | Return an MessageEndpoint from the pool. If pool is empty, creates a new
one.
an MessageEndpoint from the pool.
exception:
Exception - - if an application server fails to return anMessageEndpoint out of its pool. |
| getMinPoolSize | | public int getMinPoolSize()(Code) | | min pool size for Jmx |
| getPoolSize | | public int getPoolSize()(Code) | | the size of the EndpointPool |
| getTimerService | | public TimerService getTimerService()(Code) | | Obtains the TimerService associated for this Bean
a JTimerService instance. |
| getTransactionAttribute | | public int getTransactionAttribute()(Code) | | the Transaction Attribute |
| initInstancePool | | public void initInstancePool()(Code) | | Init pool of instances
|
| isDeliveryTransacted | | public boolean isDeliveryTransacted(Method method) throws NoSuchMethodException(Code) | | Determine if the method is transacted
Parameters:
method - Method to check boolean whether the specified method is transacted
throws:
NoSuchMethodException - exception to throw |
| notifyTimeout | | public void notifyTimeout(Timer timer)(Code) | | Notify a timeout for this bean
Parameters:
timer - timer whose expiration caused this notification. |
| reduceCache | | public void reduceCache()(Code) | | Reduce number of instances in memory in the free list we reduce to the
minPoolSize
|
| releaseEndpoint | | public void releaseEndpoint(JMessageEndpoint ep)(Code) | | put the JMessageEndpoint back to the pool
Parameters:
ep - the MessageEndpoint |
| stop | | public void stop()(Code) | | stop this EJB. call deactivate on the Endpoint Stop the threads and
remove the beans
|
| storeInstances | | public void storeInstances(Transaction tx)(Code) | | |
| syncDirty | | public void syncDirty(boolean notused)(Code) | | synchronize bean instances if needed
|
|
|
|