org.objectweb.jonas_ejb.container
Class JMdbFactory

java.lang.Object
  org.objectweb.jonas_ejb.container.JFactory
      org.objectweb.jonas_ejb.container.JMdbFactory

All Implemented Interfaces:

BeanFactory, javax.jms.ServerSessionPool

public class JMdbFactory

extends JFactory

implements javax.jms.ServerSessionPool

This class is a factory for a Message Driven Bean There is one such class per MDB class. Contains all information related to the bean and set up all JMS environment for the bean It manages a ServerSession pool to server MDB requests.

Author:

Philippe Coq, Philippe Durieux

Field Summary

Fields inherited from class org.objectweb.jonas_ejb.container.JFactory

beanclass, cont, dd, ejb10Env, ejbname, ejbTimeoutSignature, JNDICtx, myTimerService, naming, passivationDir, stopped, timerTxAttr, tm, txbeanmanaged, wm

Constructor Summary

JMdbFactory(MessageDrivenDesc dd, JContainer cont)
Constructor

Method Summary

void	checkTransaction(RequestCtx rctx) For Message Driven Beans, only 2 cases are possible.
int	getCacheSize()
JHome	getHome() returns the home if exist or null if not
JLocalHome	getLocalHome() returns the local home if exist or null if not
int	getMaxCacheSize()
int	getMinPoolSize()
int	getPoolSize() Get the size of the instance pool for this bean
javax.jms.ServerSession	getServerSession() Returns a server session from the pool.
javax.ejb.TimerService	getTimerService() Obtains the TimerService associated for this Bean
int	getTransactionAttribute()
void	initInstancePool() Init pool of instances
void	notifyTimeout(javax.ejb.Timer timer) Notify a timeout for this bean
void	reduceCache() Reduce number of instances in memory in the free list we reduce to the minPoolSize
void	releaseServerSession(javax.jms.ServerSession ss) put the ServerSession back to the pool
void	stop() stop this EJB.
void	syncDirty(boolean notused) synchronize bean instances if needed

Methods inherited from class org.objectweb.jonas_ejb.container.JFactory

checkJonasVersion, checkSecurity, checkTransactionContainer, getContainer, getDeploymentDescriptor, getEjb10Environment, getEJBName, getEjbTimeoutSignature, getEnv, getInitialContext, getPassivationDir, getTimerTxAttribute, getTransactionManager, getWorkManager, init, isClassAvailable, isStopped, isTxBeanManaged, myClassLoader, postInvoke, postInvokeRemote, preInvoke, preInvokeRemote, resetComponentContext, restartTimers, setComponentContext, stopContainer

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

JMdbFactory

public JMdbFactory(MessageDrivenDesc dd,
                   JContainer cont)

Constructor

Parameters:

dd - Message Driven Descriptor

cont - Container where this bean is defined

Method Detail

initInstancePool

public void initInstancePool()

Init pool of instances

Specified by:

initInstancePool in interface BeanFactory

Specified by:

initInstancePool in class JFactory

getPoolSize

public int getPoolSize()

Description copied from interface: BeanFactory

Get the size of the instance pool for this bean

Specified by:

getPoolSize in interface BeanFactory

Specified by:

getPoolSize in class JFactory

Returns:

the size of the ServerSessionPool

stop

public void stop()

stop this EJB. call ejbRemove on all MDB close the connection consumer Stop the threads and remove the beans

Specified by:

stop in interface BeanFactory

syncDirty

public void syncDirty(boolean notused)

synchronize bean instances if needed

Specified by:

syncDirty in interface BeanFactory

Parameters:

notused - True if store even if passivation timeout not elapsed

getHome

public JHome getHome()

Description copied from interface: BeanFactory

returns the home if exist or null if not

Specified by:

getHome in interface BeanFactory

Returns:

the home if exist

getLocalHome

public JLocalHome getLocalHome()

Description copied from interface: BeanFactory

returns the local home if exist or null if not

Specified by:

getLocalHome in interface BeanFactory

Returns:

the local home if exist

getServerSession

public javax.jms.ServerSession getServerSession()
                                         throws javax.jms.JMSException

Returns a server session from the pool. If pool is empty, creates a new one.

Specified by:

getServerSession in interface javax.jms.ServerSessionPool

Returns:

Returns a server session from the pool.

Throws:

javax.jms.JMSException - - if an application server fails to return a Server Session out of its server session pool.

releaseServerSession

public void releaseServerSession(javax.jms.ServerSession ss)

put the ServerSession back to the pool

Parameters:

ss - The ServerSession

getTimerService

public javax.ejb.TimerService getTimerService()

Obtains the TimerService associated for this Bean

Specified by:

getTimerService in class JFactory

Returns:

a JTimerService instance.

getMinPoolSize

public int getMinPoolSize()

Overrides:

getMinPoolSize in class JFactory

Returns:

min pool size for Jmx

getMaxCacheSize

public int getMaxCacheSize()

Overrides:

getMaxCacheSize in class JFactory

Returns:

max cache size for Jmx

getCacheSize

public int getCacheSize()

Overrides:

getCacheSize in class JFactory

Returns:

current cache size ( = nb of instance created) for Jmx

getTransactionAttribute

public int getTransactionAttribute()

Returns:

the Transaction Attribute

checkTransaction

public void checkTransaction(RequestCtx rctx)

For Message Driven Beans, only 2 cases are possible.

Parameters:

rctx - The Request Context

reduceCache

public void reduceCache()

Reduce number of instances in memory in the free list we reduce to the minPoolSize

Specified by:

reduceCache in interface BeanFactory

notifyTimeout

public void notifyTimeout(javax.ejb.Timer timer)

Notify a timeout for this bean

Parameters:

timer - timer whose expiration caused this notification.