XA resources example.

.gitignore

@@ -6,4 +6,5 @@ target
 *~
 transaction.log
 */bin
-
+.idea
+*.iml

examples/xa-playground/pom.xml

@@ -0,0 +1,154 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd">
+
+    <modelVersion>4.0.0</modelVersion>
+    <parent>
+        <groupId>org.jboss.seam.jms</groupId>
+        <artifactId>seam-jms-parent</artifactId>
+        <version>3.1.0.Final</version>
+        <!--<relativePath>../../pom.xml</relativePath>-->
+    </parent>
+
+    <artifactId>xa-playground</artifactId>
+    <packaging>war</packaging>
+
+    <properties>
+        <version.jbossas>7.1.0.Beta1</version.jbossas>
+        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
+        <project.build.outputEncoding>UTF-8</project.build.outputEncoding>
+    </properties>
+
+
+    <dependencies>
+        <dependency>
+            <groupId>org.jboss.weld</groupId>
+            <artifactId>weld-core</artifactId>
+            <version>1.1.4.Final</version>
+            <scope>provided</scope>
+        </dependency>
+
+        <dependency>
+            <groupId>javax.enterprise</groupId>
+            <artifactId>cdi-api</artifactId>
+            <version>1.0</version>
+            <scope>provided</scope>
+        </dependency>
+
+        <dependency>
+            <groupId>org.jboss.solder</groupId>
+            <artifactId>solder-api</artifactId>
+            <version>3.1.0.Final</version>
+        </dependency>
+
+        <dependency>
+            <groupId>org.jboss.seam.international</groupId>
+            <artifactId>seam-international</artifactId>
+            <version>3.1.0.Final</version>
+        </dependency>
+
+        <dependency>
+            <groupId>org.jboss.seam.faces</groupId>
+            <artifactId>seam-faces</artifactId>
+            <version>3.1.0.Final</version>
+        </dependency>
+
+        <dependency>
+            <groupId>org.jboss.seam.transaction</groupId>
+            <artifactId>seam-transaction-api</artifactId>
+            <version>3.1.0.Final</version>
+        </dependency>
+
+        <dependency>
+            <groupId>org.jboss.seam.transaction</groupId>
+            <artifactId>seam-transaction</artifactId>
+            <version>3.1.0.Final</version>
+        </dependency>
+
+        <dependency>
+            <groupId>org.jboss.seam.jms</groupId>
+            <artifactId>seam-jms-api</artifactId>
+        </dependency>
+
+        <dependency>
+            <groupId>org.jboss.seam.jms</groupId>
+            <artifactId>seam-jms</artifactId>
+        </dependency>
+
+        <dependency>
+            <groupId>javax.jms</groupId>
+            <artifactId>jms</artifactId>
+            <version>1.1</version>
+        </dependency>
+
+        <dependency>
+            <groupId>org.jboss.spec.javax.ejb</groupId>
+            <artifactId>jboss-ejb-api_3.1_spec</artifactId>
+            <version>1.0.1.Final</version>
+            <scope>provided</scope>
+        </dependency>
+
+        <dependency>
+            <groupId>org.jboss.spec.javax.faces</groupId>
+            <artifactId>jboss-jsf-api_2.1_spec</artifactId>
+            <version>2.0.0.Beta1</version>
+        </dependency>
+
+        <dependency>
+            <groupId>javax.el</groupId>
+            <artifactId>el-api</artifactId>
+            <version>2.2</version>
+            <scope>provided</scope>
+        </dependency>
+
+        <dependency>
+            <groupId>com.sun.faces</groupId>
+            <artifactId>jsf-impl</artifactId>
+            <scope>provided</scope>
+        </dependency>
+
+        <dependency>
+            <groupId>javax.transaction</groupId>
+            <artifactId>jta</artifactId>
+            <version>1.1</version>
+            <scope>provided</scope>
+        </dependency>
+
+    </dependencies>
+
+    <build>
+        <finalName>${project.artifactId}</finalName>
+
+        <plugins>
+
+            <plugin>
+                <groupId>org.zeroturnaround</groupId>
+                <artifactId>jrebel-maven-plugin</artifactId>
+                <version>1.0.7</version>
+                <executions>
+                    <execution>
+                        <id>generate-rebel-xml</id>
+                        <phase>process-resources</phase>
+                        <goals>
+                            <goal>generate</goal>
+                        </goals>
+                    </execution>
+                </executions>
+            </plugin>
+
+            <plugin>
+                <groupId>org.jboss.as.plugins</groupId>
+                <artifactId>jboss-as-maven-plugin</artifactId>
+                <version>${version.jbossas}</version>
+                <configuration>
+                    <groupId>${project.groupId}</groupId>
+                    <artifactId>${project.artifactId}</artifactId>
+                    <force>true</force>
+                    <address>localhost</address>
+                </configuration>
+            </plugin>
+
+        </plugins>
+    </build>
+
+</project>

examples/xa-playground/src/main/java/org/jboss/seam/jms/example/xaplayground/CdiJmsBridge.java

@@ -0,0 +1,15 @@
+package org.jboss.seam.jms.example.xaplayground;
+
+import org.jboss.seam.jms.annotations.JmsDestination;
+import org.jboss.seam.jms.annotations.Outbound;
+
+import javax.enterprise.event.Observes;
+import javax.jms.Queue;
+
+@SuppressWarnings({"CdiManagedBeanInconsistencyInspection"})
+public interface CdiJmsBridge {
+// -------------------------- OTHER METHODS --------------------------
+
+    @Outbound
+    void mapStringToQueue(@Observes String status, @JmsDestination(jndiName = Constants.DEFAULT_QUEUE_JNDI) Queue q);
+}

examples/xa-playground/src/main/java/org/jboss/seam/jms/example/xaplayground/Constants.java

@@ -0,0 +1,7 @@
+package org.jboss.seam.jms.example.xaplayground;
+
+public interface Constants {
+// ------------------------------ FIELDS ------------------------------
+
+    String DEFAULT_QUEUE_JNDI = "java:/queue/test";
+}

examples/xa-playground/src/main/java/org/jboss/seam/jms/example/xaplayground/GoodlListener.java

@@ -0,0 +1,31 @@
+package org.jboss.seam.jms.example.xaplayground;
+
+import org.jboss.solder.logging.Logger;
+
+import javax.ejb.ActivationConfigProperty;
+import javax.ejb.MessageDriven;
+import javax.inject.Inject;
+import javax.jms.Message;
+import javax.jms.MessageListener;
+
+@MessageDriven(name = "GoodlListener",
+    activationConfig = {@ActivationConfigProperty(propertyName = "destination", propertyValue = Constants.DEFAULT_QUEUE_JNDI),
+        @ActivationConfigProperty(propertyName = "destinationType", propertyValue = "javax.jms.Queue"),
+        @ActivationConfigProperty(propertyName = "acknowledgeMode", propertyValue = "Session-transacted")})
+public class GoodlListener implements MessageListener {
+// ------------------------------ FIELDS ------------------------------
+
+    @Inject
+    private Logger logger;
+
+// ------------------------ INTERFACE METHODS ------------------------
+
+
+// --------------------- Interface MessageListener ---------------------
+
+    @Override
+    public void onMessage(Message message)
+    {
+        logger.info(message);
+    }
+}

examples/xa-playground/src/main/java/org/jboss/seam/jms/example/xaplayground/MeantException.java

@@ -0,0 +1,10 @@
+package org.jboss.seam.jms.example.xaplayground;
+
+public class MeantException extends RuntimeException {
+// --------------------------- CONSTRUCTORS ---------------------------
+
+    public MeantException()
+    {
+        super("This is meant exception");
+    }
+}

examples/xa-playground/src/main/java/org/jboss/seam/jms/example/xaplayground/TestView.java

@@ -0,0 +1,95 @@
+package org.jboss.seam.jms.example.xaplayground;
+
+import org.jboss.seam.jms.MessageManager;
+import org.jboss.seam.jms.annotations.JmsDestination;
+import org.jboss.seam.jms.example.xaplayground.inject.XA;
+import org.jboss.seam.transaction.Transactional;
+import org.jboss.solder.exception.control.CaughtException;
+import org.jboss.solder.exception.control.Handles;
+import org.jboss.solder.exception.control.HandlesExceptions;
+import org.jboss.solder.logging.Logger;
+
+import javax.enterprise.event.Event;
+import javax.enterprise.inject.Model;
+import javax.faces.context.FacesContext;
+import javax.inject.Inject;
+import javax.jms.Message;
+import javax.jms.Queue;
+import javax.transaction.UserTransaction;
+import java.util.Date;
+
+@HandlesExceptions
+@Model
+public class TestView {
+// ------------------------------ FIELDS ------------------------------
+
+    @Inject
+    Event<String> stringEvent;
+
+    @Inject
+    private FacesContext facesContext;
+
+    @Inject
+    @JmsDestination(jndiName = Constants.DEFAULT_QUEUE_JNDI)
+    private Queue mailQueue;
+
+    @Inject
+    private MessageManager messageManager;
+
+    @Inject
+    @XA
+    private MessageManager messageManagerXA;
+
+    @Inject
+    private Logger logger;
+
+// -------------------------- OTHER METHODS --------------------------
+
+    public void handleMeantException(@Handles CaughtException<MeantException> e)
+    {
+        logger.info(e.getException().getLocalizedMessage());
+        facesContext.getApplication().getNavigationHandler().handleNavigation(facesContext, null, "home");
+        e.handled();
+    }
+
+    public void sendBridgedEvents()
+    {
+        stringEvent.fire("Listening to Florence: " + new Date());
+        throw new MeantException();
+    }
+
+    @Transactional
+    public void sendBridgedEventsTransactional()
+    {
+        sendBridgedEvents();
+    }
+
+    public void sendNonXA()
+    {
+        Message jmsMessage = messageManager.createTextMessage("Hello");
+        messageManager.sendMessage(jmsMessage, mailQueue);
+        throw new MeantException();
+    }
+
+    @Transactional
+    public void sendNonXATransactional()
+    {
+        sendNonXA();
+    }
+
+    public void sendXA()
+    {
+        Message jmsMessage = messageManager.createTextMessage("Hello");
+        messageManagerXA.sendMessage(jmsMessage, mailQueue);
+        throw new MeantException();
+    }
+
+    @Inject
+    private UserTransaction seamTransaction;
+
+    @Transactional
+    public void sendXATransactional()
+    {
+        sendXA();
+    }
+}

examples/xa-playground/src/main/java/org/jboss/seam/jms/example/xaplayground/inject/JmsXAConnectionFactoryProducer.java

@@ -0,0 +1,35 @@
+package org.jboss.seam.jms.example.xaplayground.inject;
+
+import org.jboss.seam.jms.annotations.JmsDefault;
+import org.jboss.solder.logging.Logger;
+
+import javax.enterprise.context.ApplicationScoped;
+import javax.enterprise.inject.Produces;
+import javax.inject.Inject;
+import javax.jms.XAConnectionFactory;
+import javax.naming.Context;
+import javax.naming.NamingException;
+
+@ApplicationScoped
+public class JmsXAConnectionFactoryProducer {
+
+    private String connectionFactoryJNDILocation = "/JmsXA";
+
+    private Logger logger = Logger.getLogger(JmsXAConnectionFactoryProducer.class);
+
+    @Inject
+    Context context;
+
+    @Produces
+    @ApplicationScoped
+    @JmsDefault("XAConnectionFactory")
+    public XAConnectionFactory produceConnectionFactory()
+    {
+        try {
+            return (XAConnectionFactory) context.lookup(connectionFactoryJNDILocation);
+        } catch (NamingException e) {
+            logger.info("Unable to look up " + connectionFactoryJNDILocation + " in JNDI", e);
+            return null;
+        }
+    }
+}