User: chirino
Date: 01/09/24 20:34:46
Modified: src/main/org/jboss/ejb/plugins/jms JMSContainerInvoker.java
Log:
Updated the MDB stuff so it supports local tx for both BMT and for CMT-NotSupported
Revision Changes Path
1.30 +13 -6
jboss/src/main/org/jboss/ejb/plugins/jms/JMSContainerInvoker.java
Index: JMSContainerInvoker.java
===================================================================
RCS file:
/cvsroot/jboss/jboss/src/main/org/jboss/ejb/plugins/jms/JMSContainerInvoker.java,v
retrieving revision 1.29
retrieving revision 1.30
diff -u -r1.29 -r1.30
--- JMSContainerInvoker.java 2001/09/20 05:08:43 1.29
+++ JMSContainerInvoker.java 2001/09/25 03:34:46 1.30
@@ -61,7 +61,7 @@
* </a>
* @author <a href="mailto:[EMAIL PROTECTED]";>Marc Fleury</a>
* @author <a href="mailto:[EMAIL PROTECTED]";>Jason Dillon</a>
- * @version $Revision: 1.29 $
+ * @version $Revision: 1.30 $
*/
public class JMSContainerInvoker
implements ContainerInvoker, XmlLoadable
@@ -117,6 +117,10 @@
/**
* Description of the Field
*/
+ protected boolean isNotSupportedTx;
+ /**
+ * Description of the Field
+ */
protected Container container;
/**
* Description of the Field
@@ -398,7 +402,11 @@
// Is container managed?
isContainerManagedTx = config.isContainerManagedTx();
acknowledgeMode = config.getAcknowledgeMode();
-
+ isNotSupportedTx =
+ config.getMethodTransactionType("onMessage",
+ new Class[]{Message.class},
+ false) == MetaData.TX_NOT_SUPPORTED;
+
// Get configuration data from jboss.xml
String destinationJNDI = config.getDestinationJndiName();
String user = config.getUser();
@@ -453,9 +461,8 @@
// set up the server session pool
pool = createSessionPool(tConnection,
maxPoolSize,
- true,
- // tx
- acknowledgeMode,
+ true, // tx
+ acknowledgeMode ,
new MessageListenerImpl(this));
// To be no-durable or durable
@@ -750,7 +757,7 @@
// the create the pool
pool = factory.getServerSessionPool
- (connection, maxSession, isTransacted, ack, isContainerManagedTx,
listener);
+ (connection, maxSession, isTransacted, ack, !isContainerManagedTx ||
isNotSupportedTx, listener);
}
finally
{
_______________________________________________
Jboss-development mailing list
[EMAIL PROTECTED]
https://lists.sourceforge.net/lists/listinfo/jboss-development
