Hi All,

I'd appreciate if someone could help me with JBoss,  Websphere MQ transactional behaviour.

Below are the code snippet  & configurations.

Code: The code below look up QCF and Queue and send a message to the queue. Then wait for 5 sec and throw an error. I'd expect the first message to roll back and thus no message should be put to queue. However I can see the first message put to the queue.

boolean flag = true;

InitialContext ctx = new InitialContext();
            ConnectionFactory qcf = (ConnectionFactory) ctx
                    .lookup("java:realtimereportingqcf");

            log.error("ConnectionFactory is " + qcf);

            Queue queue = (Queue) ctx.lookup("realtimereporting");

            try {
                con = qcf.createConnection();
                s = con.createSession(false, Session.AUTO_ACKNOWLEDGE);
                producer = s.createProducer(queue);
                producer.send(s.createTextMessage(" Test Message... "));
               
                try {
                    Thread.sleep(5000);
                    if(flag)
                        throw new RuntimeException();
                   
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
               
                producer.send(s.createTextMessage("Test Message... "));

            } catch (JMSException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }

Configurations

Jboss deploy/mq directory contains wmq.jmsra-ds.xml  wmq.jmsra.rar

wmq.jmsra-ds.xml

<?xml version="1.0" encoding="UTF-8"?>
<connection-factories>

  <!-- ==================================================================== -->
  <!-- Websphere MQ service deployment                                      -->
  <!-- ==================================================================== -->

    <tx-connection-factory>
        <jndi-name>realtimereportingqcf</jndi-name>
        <local-transaction>true</local-transaction>
        <rar-name>wmq.jmsra.rar</rar-name>
        <connection-definition>javax.jms.ConnectionFactory</connection-definition>
        <config-property name="channel" type="java.lang.String">REPORT.SVRCONN</config-property>
        <config-property name="hostName" type="java.lang.String">xyz.uk.com</config-property>
        <config-property name="port" type="java.lang.String">1425</config-property>
        <config-property name="queueManager" type="java.lang.String">QM123</config-property>
        <config-property name="transportType" type="java.lang.String">CLIENT</config-property>
        <security-domain-and-application>JmsXARealm</security-domain-and-application>
        <max-pool-size>20</max-pool-size>
     </tx-connection-factory>
        <!-- Create queue for outbound messages -->
      <mbean code="org.jboss.resource.deployment.AdminObject" name="jca.wmq:name=realtimereporting">
        <depends optional-attribute-name="RARName">jboss.jca:service=RARDeployment,name='wmq.jmsra.rar'</depends>
        <attribute name="JNDIName">realtimereporting</attribute>
        <attribute name="Type">javax.jms.Queue</attribute>
        <attribute name="Properties">
            baseQueueManagerName=QM123
            baseQueueName=REPORT.QUEUE
        </attribute>
     </mbean>

</connection-factories>

ejb-jar.xml

     <session>
            <display-name>ServiceBean</display-name>
            <ejb-name>ServiceBean</ejb-name>
            <home>com.service.session.ServiceHome</home>
            <remote>com.service.session.Service</remote>
            <ejb-class>com.service.session.ServiceBean</ejb-class>
            <session-type>Stateless</session-type>
            <transaction-type>Container</transaction-type>
            <resource-ref>
                <description>The JMS TopicConnection Factory</description>
                <res-ref-name>realtimereportingqcf</res-ref-name>
                <res-type>javax.jms.QueueConnectionFactory</res-type>
                <res-auth>Container</res-auth>
            </resource-ref>
        </session>

     <container-transaction>
            <method>
                <ejb-name>ServiceBean</ejb-name>
                <method-name>entryProcess</method-name>
            </method>
            <trans-attribute>NotSupported</trans-attribute>
        </container-transaction>

jboss.xml

         <session>

            <ejb-name>ServiceBean</ejb-name>

            <jndi-name>ServiceBean</jndi-name>

            <resource-ref>

                <res-ref-name>realtimereportingqcf</res-ref-name>

                <jndi-name>realtimereportingqcf</jndi-name>

            </resource-ref>           

        </session>

Thanks for your help and support

Regards

JK