| org.jboss.ejb.plugins.jms.JMSContainerInvoker
| Inner Class :class MessageListenerImpl implements MessageListener | |
| Inner Class :class ExceptionListenerImpl implements ExceptionListener | |
| Inner Class :interface TCLAction | |
| Method Summary | |
| protected Destination | createDestination(Class type, Context ctx, String jndiName, String jndiSuffix)
Create and or lookup a JMS destination.
Parameters:
type - Either javax.jms.Queue or javax.jms.Topic.
Parameters:
ctx - The naming context to lookup destinations from.
Parameters:
jndiName - The name to use when looking up destinations.
Parameters:
jndiSuffix - The name to use when creating destinations. | | protected void | createService()
Initialize the container invoker. | | protected ServerSessionPool | createSessionPool(Destination destination, Connection connection, int minSession, int maxSession, long keepAlive, boolean isTransacted, int ack, MessageListener listener)
Create a server session pool for the given connection.
Parameters:
destination - the destination
Parameters:
connection - The connection to use.
Parameters:
minSession - The minumum number of sessions
Parameters:
maxSession - The maximum number of sessions.
Parameters:
keepAlive - The time to keep sessions alive
Parameters:
isTransacted - True if the sessions are transacted.
Parameters:
ack - The session acknowledgement mode.
Parameters:
listener - The message listener. | | protected String | getActivationConfigProperty(String property)
| | public boolean | getCreateJBossMQDestination()
| | public boolean | getDeliveryActive()
| | protected String | getDestinationType(Context ctx, String destinationJNDI)
Try to get a destination type by looking up the destination JNDI, or
provide a default if there is not destinationJNDI or if it is not possible
to lookup.
Parameters:
ctx - The naming context to lookup destinations from.
Parameters:
destinationJNDI - The name to use when looking up destinations. | | public Object | getEJBHome()
| | public EJBMetaData | getEJBMetaData()
| | public Collection | getEntityCollection(Collection ids)
| | public Object | getEntityEJBObject(Object id)
| | protected JMSProviderAdapter | getJMSProviderAdapter()
Return the JMSProviderAdapter that should be used. | | public long | getKeepAliveMillis()
| | public int | getMaxMessages()
| | public int | getMaxPoolSize()
| | public MessageDrivenMetaData | getMetaData()
| | public int | getMinPoolSize()
| | public Object | getStatefulSessionEJBObject(Object id)
| | public Object | getStatelessSessionEJBObject()
| | public void | importXml(Element element)
XmlLoadable implementation. | | protected void | innerStartDelivery()
Initialize the container invoker. | | protected void | innerStopDelivery()
Stop done from inside, we should not stop the exceptionListener in inner
stop. | | public Object | invoke(Object id, Method m, Object[] args, Transaction tx, Principal identity, Object credential)
| | public boolean | isIdentical(Container container, Invocation mi)
| | public boolean | isOptimized()
| | protected String | parseJndiSuffix(String jndiname, String defautSuffix)
Parse the JNDI suffix from the given JNDI name. | | protected void | sendNotification(String event, Object userData)
Notify of an event
Parameters:
event - the event
Parameters:
userData - any user data, e.g. | | public void | setContainer(Container container)
Set the container for which this is an invoker to. | | public void | setInvokerBinding(String binding)
| | public void | setInvokerMetaData(InvokerProxyBindingMetaData imd)
| | public void | setKeepAliveMillis(long keepAlive)
| | public void | setMaxMessages(int maxMessages)
| | public void | setMaxPoolSize(int maxPoolSize)
| | public void | setMinPoolSize(int minPoolSize)
| | public void | setOptimized(boolean optimize)
| | public void | startDelivery()
| | protected void | startService()
| | public void | stopDelivery()
| | protected void | stopService()
| | public String | toString()
Return a string representation of the current config state. |
| DEFAULT_DESTINATION_TYPE | | final protected static String DEFAULT_DESTINATION_TYPE(Code) | | Default destination type. Used when no message-driven-destination is given
in ejb-jar, and a lookup of destinationJNDI from jboss.xml is not
successfull. Default value: javax.jms.Topic.
|
| ON_MESSAGE | | protected static Method ON_MESSAGE(Code) | | MessageListener.onMessage reference.
|
| acknowledgeMode | | protected int acknowledgeMode(Code) | | JMS acknowledge mode, used when session is not XA.
|
| connection | | protected Connection connection(Code) | | The JMS connection.
|
| connectionConsumer | | protected ConnectionConsumer connectionConsumer(Code) | | The JMS connection consumer.
|
| createJBossMQDestination | | protected boolean createJBossMQDestination(Code) | | |
| deliveryActive | | protected boolean deliveryActive(Code) | | |
| dlqConfig | | protected Element dlqConfig(Code) | | DLQConfig element from MDBConfig element from jboss.xml.
|
| exListener | | protected ExceptionListenerImpl exListener(Code) | | |
| isContainerManagedTx | | protected boolean isContainerManagedTx(Code) | | |
| isNotSupportedTx | | protected boolean isNotSupportedTx(Code) | | |
| keepAlive | | protected long keepAlive(Code) | | Keep alive server sessions.
|
| maxMessagesNr | | protected int maxMessagesNr(Code) | | Maximum number provider is allowed to stuff into a session.
|
| maxPoolSize | | protected int maxPoolSize(Code) | | Maximun pool size of server sessions.
|
| minPoolSize | | protected int minPoolSize(Code) | | Minimun pool size of server sessions.
|
| optimize | | protected boolean optimize(Code) | | |
| pool | | protected ServerSessionPool pool(Code) | | |
| reconnectInterval | | protected long reconnectInterval(Code) | | Time to wait before retrying to reconnect a lost connection.
|
| tm | | protected TransactionManager tm(Code) | | |
| useDLQ | | protected boolean useDLQ(Code) | | If Dead letter queue should be used or not.
|
| createDestination | | protected Destination createDestination(Class type, Context ctx, String jndiName, String jndiSuffix) throws Exception(Code) | | Create and or lookup a JMS destination.
Parameters:
type - Either javax.jms.Queue or javax.jms.Topic.
Parameters:
ctx - The naming context to lookup destinations from.
Parameters:
jndiName - The name to use when looking up destinations.
Parameters:
jndiSuffix - The name to use when creating destinations. The destination.
throws:
IllegalArgumentException - Type is not Queue or Topic.
throws:
Exception - Description of Exception |
| createService | | protected void createService() throws Exception(Code) | | Initialize the container invoker. Sets up a connection, a server session
pool and a connection consumer for the configured destination.
Any JMSExceptions produced while initializing will be assumed to be caused
due to JMS Provider failure.
throws:
Exception - Failed to initalize. |
| createSessionPool | | protected ServerSessionPool createSessionPool(Destination destination, Connection connection, int minSession, int maxSession, long keepAlive, boolean isTransacted, int ack, MessageListener listener) throws NamingException, JMSException(Code) | | Create a server session pool for the given connection.
Parameters:
destination - the destination
Parameters:
connection - The connection to use.
Parameters:
minSession - The minumum number of sessions
Parameters:
maxSession - The maximum number of sessions.
Parameters:
keepAlive - The time to keep sessions alive
Parameters:
isTransacted - True if the sessions are transacted.
Parameters:
ack - The session acknowledgement mode.
Parameters:
listener - The message listener. A server session pool.
throws:
JMSException -
throws:
NamingException - Description of Exception |
| getActivationConfigProperty | | protected String getActivationConfigProperty(String property)(Code) | | |
| getCreateJBossMQDestination | | public boolean getCreateJBossMQDestination()(Code) | | |
| getDeliveryActive | | public boolean getDeliveryActive()(Code) | | |
| getDestinationType | | protected String getDestinationType(Context ctx, String destinationJNDI)(Code) | | Try to get a destination type by looking up the destination JNDI, or
provide a default if there is not destinationJNDI or if it is not possible
to lookup.
Parameters:
ctx - The naming context to lookup destinations from.
Parameters:
destinationJNDI - The name to use when looking up destinations. The destination type, either derived from destinationJDNI orDEFAULT_DESTINATION_TYPE |
| getEJBMetaData | | public EJBMetaData getEJBMetaData()(Code) | | |
| getKeepAliveMillis | | public long getKeepAliveMillis()(Code) | | |
| getMaxMessages | | public int getMaxMessages()(Code) | | |
| getMaxPoolSize | | public int getMaxPoolSize()(Code) | | |
| getMinPoolSize | | public int getMinPoolSize()(Code) | | |
| getStatelessSessionEJBObject | | public Object getStatelessSessionEJBObject()(Code) | | |
| importXml | | public void importXml(Element element) throws Exception(Code) | | XmlLoadable implementation.
Parameters:
element - Description of Parameter
throws:
DeploymentException - Description of Exception |
| innerStartDelivery | | protected void innerStartDelivery() throws Exception(Code) | | Initialize the container invoker. Sets up a connection, a server session
pool and a connection consumer for the configured destination.
throws:
Exception - Failed to initalize. |
| innerStopDelivery | | protected void innerStopDelivery()(Code) | | Stop done from inside, we should not stop the exceptionListener in inner
stop.
|
| isOptimized | | public boolean isOptimized()(Code) | | |
| parseJndiSuffix | | protected String parseJndiSuffix(String jndiname, String defautSuffix)(Code) | | Parse the JNDI suffix from the given JNDI name.
Parameters:
jndiname - The JNDI name used to lookup the destination.
Parameters:
defautSuffix - Description of Parameter The parsed suffix or the defaultSuffix |
| sendNotification | | protected void sendNotification(String event, Object userData)(Code) | | Notify of an event
Parameters:
event - the event
Parameters:
userData - any user data, e.g. the exception on a failure |
| setContainer | | public void setContainer(Container container)(Code) | | Set the container for which this is an invoker to.
Parameters:
container - The container for which this is an invoker to. |
| setInvokerBinding | | public void setInvokerBinding(String binding)(Code) | | Set the invoker jndi binding
|
| setKeepAliveMillis | | public void setKeepAliveMillis(long keepAlive)(Code) | | |
| setMaxMessages | | public void setMaxMessages(int maxMessages)(Code) | | |
| setMaxPoolSize | | public void setMaxPoolSize(int maxPoolSize)(Code) | | |
| setMinPoolSize | | public void setMinPoolSize(int minPoolSize)(Code) | | |
| setOptimized | | public void setOptimized(boolean optimize)(Code) | | Sets the Optimized attribute of the JMSContainerInvoker object
Parameters:
optimize - The new Optimized value |
| toString | | public String toString()(Code) | | Return a string representation of the current config state.
|
|
|