tomee-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tveron...@apache.org
Subject [24/50] tomee git commit: Demonstrate a resource adapter that does not make any attempt whatsoever to pool endpoints
Date Thu, 18 Jan 2018 15:44:12 GMT
Demonstrate a resource adapter that does not make any attempt whatsoever to pool endpoints


Project: http://git-wip-us.apache.org/repos/asf/tomee/repo
Commit: http://git-wip-us.apache.org/repos/asf/tomee/commit/a82539c8
Tree: http://git-wip-us.apache.org/repos/asf/tomee/tree/a82539c8
Diff: http://git-wip-us.apache.org/repos/asf/tomee/diff/a82539c8

Branch: refs/heads/master
Commit: a82539c872e59be4b58371ab89ca5dd8f4206bdd
Parents: 4ddbdeb
Author: Jonathan Gallimore <jon@jrg.me.uk>
Authored: Tue Dec 19 13:37:12 2017 +0000
Committer: Otavio Santana <otaviopolianasantana@gmail.com>
Committed: Tue Dec 19 10:52:56 2017 -0300

----------------------------------------------------------------------
 .../core/mdb/PoolEndpointHandlerTest.java       |  74 +++++-----
 .../core/mdb/connector/api/InboundListener.java |  24 ++++
 .../mdb/connector/api/SampleConnection.java     |  26 ++++
 .../connector/api/SampleConnectionFactory.java  |  28 ++++
 .../connector/impl/SampleActivationSpec.java    |  54 ++++++++
 .../impl/SampleConnectionFactoryImpl.java       |  69 ++++++++++
 .../connector/impl/SampleConnectionImpl.java    |  44 ++++++
 .../connector/impl/SampleManagedConnection.java | 134 +++++++++++++++++++
 .../impl/SampleManagedConnectionFactory.java    |  99 ++++++++++++++
 .../impl/SampleManagedConnectionMetaData.java   |  56 ++++++++
 .../connector/impl/SampleResourceAdapter.java   | 117 ++++++++++++++++
 11 files changed, 683 insertions(+), 42 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/tomee/blob/a82539c8/container/openejb-core/src/test/java/org/apache/openejb/core/mdb/PoolEndpointHandlerTest.java
----------------------------------------------------------------------
diff --git a/container/openejb-core/src/test/java/org/apache/openejb/core/mdb/PoolEndpointHandlerTest.java
b/container/openejb-core/src/test/java/org/apache/openejb/core/mdb/PoolEndpointHandlerTest.java
index a716ef4..f5e36e5 100644
--- a/container/openejb-core/src/test/java/org/apache/openejb/core/mdb/PoolEndpointHandlerTest.java
+++ b/container/openejb-core/src/test/java/org/apache/openejb/core/mdb/PoolEndpointHandlerTest.java
@@ -16,6 +16,12 @@
  */
 package org.apache.openejb.core.mdb;
 
+import org.apache.openejb.core.mdb.connector.api.InboundListener;
+import org.apache.openejb.core.mdb.connector.api.SampleConnection;
+import org.apache.openejb.core.mdb.connector.api.SampleConnectionFactory;
+import org.apache.openejb.core.mdb.connector.impl.SampleActivationSpec;
+import org.apache.openejb.core.mdb.connector.impl.SampleManagedConnectionFactory;
+import org.apache.openejb.core.mdb.connector.impl.SampleResourceAdapter;
 import org.apache.openejb.jee.MessageDrivenBean;
 import org.apache.openejb.junit.ApplicationComposer;
 import org.apache.openejb.monitoring.LocalMBeanServer;
@@ -30,15 +36,7 @@ import javax.annotation.PostConstruct;
 import javax.annotation.Resource;
 import javax.ejb.ActivationConfigProperty;
 import javax.ejb.MessageDriven;
-import javax.jms.Connection;
-import javax.jms.ConnectionFactory;
-import javax.jms.JMSException;
-import javax.jms.Message;
-import javax.jms.MessageListener;
-import javax.jms.MessageProducer;
 import javax.jms.Queue;
-import javax.jms.Session;
-import javax.jms.TextMessage;
 import javax.management.ObjectName;
 import java.util.List;
 import java.util.Properties;
@@ -60,19 +58,18 @@ public class PoolEndpointHandlerTest {
     public Properties config() {
         return new PropertiesBuilder()
 
-                .p("amq", "new://Resource?type=ActiveMQResourceAdapter")
-                .p("amq.DataSource", "")
-                .p("amq.BrokerXmlConfig", "broker:(vm://localhost)")
+            .p("sra", "new://Resource?class-name=" + SampleResourceAdapter.class.getName())
 
-                .p("target", "new://Resource?type=Queue")
+            .p("mdbs", "new://Container?type=MESSAGE")
+            .p("mdbs.ResourceAdapter", "sra")
+            .p("mdbs.pool", "false")
+            .p("mdbs.ActivationSpecClass", SampleActivationSpec.class.getName())
+            .p("mdbs.MessageListenerInterface", InboundListener.class.getName())
 
-                .p("mdbs", "new://Container?type=MESSAGE")
-                .p("mdbs.ResourceAdapter", "amq")
-                .p("mdbs.pool", "true")
-
-                .p("cf", "new://Resource?type=" + ConnectionFactory.class.getName())
-                .p("cf.ResourceAdapter", "amq")
-                .build();
+            .p("cf", "new://Resource?type=" + SampleConnectionFactory.class.getName() + "&class-name="
+ SampleManagedConnectionFactory.class.getName())
+            .p("cf.ResourceAdapter", "sra")
+            .p("cf.TransactionSupport", "none")
+            .build();
     }
 
     @Module
@@ -84,7 +81,7 @@ public class PoolEndpointHandlerTest {
     private Queue destination;
 
     @Resource(name = "cf")
-    private ConnectionFactory cf;
+    private SampleConnectionFactory cf;
 
     @Before
     public void resetLatch() {
@@ -95,12 +92,10 @@ public class PoolEndpointHandlerTest {
     public void shouldSendMessage() throws Exception {
         assertNotNull(cf);
 
-        for (int i = 0; i < 1_000; i++) {
-            final Connection connection = cf.createConnection();
+        for (int i = 0; i < 100; i++) {
+            final SampleConnection connection = cf.getConnection();
             try {
-                final Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
-                final MessageProducer producer = session.createProducer(destination);
-                producer.send(session.createTextMessage(TEXT));
+                connection.sendMessage(TEXT);
             } finally {
                 connection.close();
             }
@@ -120,12 +115,10 @@ public class PoolEndpointHandlerTest {
     }
 
     @MessageDriven(activationConfig = {
-            @ActivationConfigProperty(propertyName = "destinationType", propertyValue = "javax.jms.Queue"),
-            @ActivationConfigProperty(propertyName = "destination", propertyValue = "target"),
             @ActivationConfigProperty(propertyName = "DeliveryActive", propertyValue = "false"),
             @ActivationConfigProperty(propertyName = "MdbJMXControl", propertyValue = "default:type=test")
     })
-    public static class Listener implements MessageListener {
+    public static class Listener implements InboundListener {
         public static CountDownLatch latch;
         private static final List<Boolean> BOOLEANS = new CopyOnWriteArrayList<>();
 
@@ -136,21 +129,8 @@ public class PoolEndpointHandlerTest {
             COUNTER.incrementAndGet();
         }
 
-        @Override
-        public void onMessage(final Message message) {
-            try {
-                try {
-                    boolean ok = TextMessage.class.isInstance(message) && TEXT.equals(TextMessage.class.cast(message).getText());
-                    BOOLEANS.add(ok);
-                } catch (final JMSException e) {
-                }
-            } finally {
-                latch.countDown();
-            }
-        }
-
         public static void reset() {
-            latch = new CountDownLatch(1000);
+            latch = new CountDownLatch(100);
             BOOLEANS.clear();
         }
 
@@ -163,6 +143,16 @@ public class PoolEndpointHandlerTest {
             }
             return true;
         }
+
+        @Override
+        public void receiveMessage(String message) {
+            try {
+                boolean ok = TEXT.equals(message);
+                BOOLEANS.add(ok);
+            } finally {
+                latch.countDown();
+            }
+        }
     }
 
 }
\ No newline at end of file

http://git-wip-us.apache.org/repos/asf/tomee/blob/a82539c8/container/openejb-core/src/test/java/org/apache/openejb/core/mdb/connector/api/InboundListener.java
----------------------------------------------------------------------
diff --git a/container/openejb-core/src/test/java/org/apache/openejb/core/mdb/connector/api/InboundListener.java
b/container/openejb-core/src/test/java/org/apache/openejb/core/mdb/connector/api/InboundListener.java
new file mode 100644
index 0000000..9988048
--- /dev/null
+++ b/container/openejb-core/src/test/java/org/apache/openejb/core/mdb/connector/api/InboundListener.java
@@ -0,0 +1,24 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.openejb.core.mdb.connector.api;
+
+/**
+ * @version $Revision$ $Date$
+ */
+public interface InboundListener {
+    public void receiveMessage(final String message);
+}

http://git-wip-us.apache.org/repos/asf/tomee/blob/a82539c8/container/openejb-core/src/test/java/org/apache/openejb/core/mdb/connector/api/SampleConnection.java
----------------------------------------------------------------------
diff --git a/container/openejb-core/src/test/java/org/apache/openejb/core/mdb/connector/api/SampleConnection.java
b/container/openejb-core/src/test/java/org/apache/openejb/core/mdb/connector/api/SampleConnection.java
new file mode 100755
index 0000000..7d30e56
--- /dev/null
+++ b/container/openejb-core/src/test/java/org/apache/openejb/core/mdb/connector/api/SampleConnection.java
@@ -0,0 +1,26 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+
+package org.apache.openejb.core.mdb.connector.api;
+
+public interface SampleConnection {
+    public void sendMessage(final String message);
+
+    public void close();
+}

http://git-wip-us.apache.org/repos/asf/tomee/blob/a82539c8/container/openejb-core/src/test/java/org/apache/openejb/core/mdb/connector/api/SampleConnectionFactory.java
----------------------------------------------------------------------
diff --git a/container/openejb-core/src/test/java/org/apache/openejb/core/mdb/connector/api/SampleConnectionFactory.java
b/container/openejb-core/src/test/java/org/apache/openejb/core/mdb/connector/api/SampleConnectionFactory.java
new file mode 100755
index 0000000..77a07f0
--- /dev/null
+++ b/container/openejb-core/src/test/java/org/apache/openejb/core/mdb/connector/api/SampleConnectionFactory.java
@@ -0,0 +1,28 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+package org.apache.openejb.core.mdb.connector.api;
+
+import javax.resource.Referenceable;
+import javax.resource.ResourceException;
+import java.io.Serializable;
+
+public interface SampleConnectionFactory extends Serializable, Referenceable {
+    public SampleConnection getConnection() throws ResourceException;
+
+}

http://git-wip-us.apache.org/repos/asf/tomee/blob/a82539c8/container/openejb-core/src/test/java/org/apache/openejb/core/mdb/connector/impl/SampleActivationSpec.java
----------------------------------------------------------------------
diff --git a/container/openejb-core/src/test/java/org/apache/openejb/core/mdb/connector/impl/SampleActivationSpec.java
b/container/openejb-core/src/test/java/org/apache/openejb/core/mdb/connector/impl/SampleActivationSpec.java
new file mode 100644
index 0000000..17d56a3
--- /dev/null
+++ b/container/openejb-core/src/test/java/org/apache/openejb/core/mdb/connector/impl/SampleActivationSpec.java
@@ -0,0 +1,54 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.openejb.core.mdb.connector.impl;
+
+import org.apache.openejb.core.mdb.connector.api.InboundListener;
+
+import javax.resource.ResourceException;
+import javax.resource.spi.Activation;
+import javax.resource.spi.ActivationSpec;
+import javax.resource.spi.InvalidPropertyException;
+import javax.resource.spi.ResourceAdapter;
+
+@Activation(messageListeners = InboundListener.class)
+public class SampleActivationSpec implements ActivationSpec {
+
+    private ResourceAdapter resourceAdapter;
+    private Class beanClass;
+
+    public Class getBeanClass() {
+        return beanClass;
+    }
+
+    public void setBeanClass(Class beanClass) {
+        this.beanClass = beanClass;
+    }
+
+    @Override
+    public void validate() throws InvalidPropertyException {
+    }
+
+    @Override
+    public ResourceAdapter getResourceAdapter() {
+        return resourceAdapter;
+    }
+
+    @Override
+    public void setResourceAdapter(ResourceAdapter ra) throws ResourceException {
+        this.resourceAdapter = ra;
+    }
+}

http://git-wip-us.apache.org/repos/asf/tomee/blob/a82539c8/container/openejb-core/src/test/java/org/apache/openejb/core/mdb/connector/impl/SampleConnectionFactoryImpl.java
----------------------------------------------------------------------
diff --git a/container/openejb-core/src/test/java/org/apache/openejb/core/mdb/connector/impl/SampleConnectionFactoryImpl.java
b/container/openejb-core/src/test/java/org/apache/openejb/core/mdb/connector/impl/SampleConnectionFactoryImpl.java
new file mode 100755
index 0000000..e4b3f2d
--- /dev/null
+++ b/container/openejb-core/src/test/java/org/apache/openejb/core/mdb/connector/impl/SampleConnectionFactoryImpl.java
@@ -0,0 +1,69 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+package org.apache.openejb.core.mdb.connector.impl;
+
+import org.apache.openejb.core.mdb.connector.api.SampleConnection;
+import org.apache.openejb.core.mdb.connector.api.SampleConnectionFactory;
+
+import javax.naming.NamingException;
+import javax.naming.Reference;
+import javax.resource.ResourceException;
+import javax.resource.spi.ConnectionManager;
+import java.util.logging.Logger;
+
+public class SampleConnectionFactoryImpl implements SampleConnectionFactory {
+    private static final long serialVersionUID = 1L;
+
+    private static Logger log = Logger.getLogger(SampleConnectionFactoryImpl.class.getName());
+
+    private Reference reference;
+
+    private SampleManagedConnectionFactory mcf;
+
+    private ConnectionManager connectionManager;
+
+    public SampleConnectionFactoryImpl() {
+
+    }
+
+    public SampleConnectionFactoryImpl(SampleManagedConnectionFactory mcf, ConnectionManager
cxManager) {
+        this.mcf = mcf;
+        this.connectionManager = cxManager;
+    }
+
+    @Override
+    public SampleConnection getConnection() throws ResourceException {
+        log.finest("getConnection()");
+        return (SampleConnection) connectionManager.allocateConnection(mcf, null);
+    }
+
+    @Override
+    public Reference getReference() throws NamingException {
+        log.finest("getReference()");
+        return reference;
+    }
+
+    @Override
+    public void setReference(Reference reference) {
+        log.finest("setReference()");
+        this.reference = reference;
+    }
+
+
+}

http://git-wip-us.apache.org/repos/asf/tomee/blob/a82539c8/container/openejb-core/src/test/java/org/apache/openejb/core/mdb/connector/impl/SampleConnectionImpl.java
----------------------------------------------------------------------
diff --git a/container/openejb-core/src/test/java/org/apache/openejb/core/mdb/connector/impl/SampleConnectionImpl.java
b/container/openejb-core/src/test/java/org/apache/openejb/core/mdb/connector/impl/SampleConnectionImpl.java
new file mode 100755
index 0000000..9b7681a
--- /dev/null
+++ b/container/openejb-core/src/test/java/org/apache/openejb/core/mdb/connector/impl/SampleConnectionImpl.java
@@ -0,0 +1,44 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+package org.apache.openejb.core.mdb.connector.impl;
+
+import org.apache.openejb.core.mdb.connector.api.SampleConnection;
+
+import java.util.logging.Logger;
+
+public class SampleConnectionImpl implements SampleConnection {
+    private static Logger log = Logger.getLogger(SampleConnectionImpl.class.getName());
+
+    private SampleManagedConnection mc;
+
+    private SampleManagedConnectionFactory mcf;
+
+    public SampleConnectionImpl(SampleManagedConnection mc, SampleManagedConnectionFactory
mcf) {
+        this.mc = mc;
+        this.mcf = mcf;
+    }
+
+    public void sendMessage(final String message) {
+        mc.sendMessage(message);
+    }
+
+    public void close() {
+        mc.closeHandle(this);
+    }
+}

http://git-wip-us.apache.org/repos/asf/tomee/blob/a82539c8/container/openejb-core/src/test/java/org/apache/openejb/core/mdb/connector/impl/SampleManagedConnection.java
----------------------------------------------------------------------
diff --git a/container/openejb-core/src/test/java/org/apache/openejb/core/mdb/connector/impl/SampleManagedConnection.java
b/container/openejb-core/src/test/java/org/apache/openejb/core/mdb/connector/impl/SampleManagedConnection.java
new file mode 100755
index 0000000..97098dd
--- /dev/null
+++ b/container/openejb-core/src/test/java/org/apache/openejb/core/mdb/connector/impl/SampleManagedConnection.java
@@ -0,0 +1,134 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+package org.apache.openejb.core.mdb.connector.impl;
+
+import org.apache.openejb.core.mdb.connector.api.SampleConnection;
+
+import javax.resource.NotSupportedException;
+import javax.resource.ResourceException;
+import javax.resource.spi.*;
+import javax.security.auth.Subject;
+import javax.transaction.xa.XAResource;
+import java.io.PrintWriter;
+import java.util.ArrayList;
+import java.util.Collections;
+import java.util.List;
+import java.util.logging.Logger;
+
+public class SampleManagedConnection implements ManagedConnection {
+
+    private static Logger log = Logger.getLogger(SampleManagedConnection.class.getName());
+
+    private PrintWriter logwriter;
+
+    private SampleManagedConnectionFactory mcf;
+
+    private List<ConnectionEventListener> listeners;
+
+    private SampleConnectionImpl connection;
+
+    public SampleManagedConnection(SampleManagedConnectionFactory mcf) {
+        this.mcf = mcf;
+        this.logwriter = null;
+        this.listeners = Collections.synchronizedList(new ArrayList<ConnectionEventListener>(1));
+        this.connection = null;
+    }
+
+    public Object getConnection(Subject subject,
+                                ConnectionRequestInfo cxRequestInfo) throws ResourceException
{
+        log.finest("getConnection()");
+        connection = new SampleConnectionImpl(this, mcf);
+        return connection;
+    }
+
+    public void associateConnection(Object connection) throws ResourceException {
+        log.finest("associateConnection()");
+
+        if (connection == null)
+            throw new ResourceException("Null connection handle");
+
+        if (!(connection instanceof SampleConnectionImpl))
+            throw new ResourceException("Wrong connection handle");
+
+        this.connection = (SampleConnectionImpl) connection;
+    }
+
+    public void cleanup() throws ResourceException {
+        log.finest("cleanup()");
+    }
+
+    public void destroy() throws ResourceException {
+        log.finest("destroy()");
+    }
+
+    public void addConnectionEventListener(ConnectionEventListener listener) {
+        log.finest("addConnectionEventListener()");
+
+        if (listener == null) {
+            throw new IllegalArgumentException("Listener is null");
+        }
+
+        listeners.add(listener);
+    }
+
+    public void removeConnectionEventListener(ConnectionEventListener listener) {
+        log.finest("removeConnectionEventListener()");
+        if (listener == null)
+            throw new IllegalArgumentException("Listener is null");
+        listeners.remove(listener);
+    }
+
+    void closeHandle(SampleConnection handle) {
+        ConnectionEvent event = new ConnectionEvent(this, ConnectionEvent.CONNECTION_CLOSED);
+        event.setConnectionHandle(handle);
+        for (ConnectionEventListener cel : listeners) {
+            cel.connectionClosed(event);
+        }
+    }
+
+    public PrintWriter getLogWriter() throws ResourceException {
+        log.finest("getLogWriter()");
+        return logwriter;
+    }
+
+    public void setLogWriter(PrintWriter out) throws ResourceException {
+        log.finest("setLogWriter()");
+        logwriter = out;
+    }
+
+    public LocalTransaction getLocalTransaction() throws ResourceException {
+        throw new NotSupportedException("getLocalTransaction() not supported");
+    }
+
+    public XAResource getXAResource() throws ResourceException {
+        throw new NotSupportedException("getXAResource() not supported");
+    }
+
+    public ManagedConnectionMetaData getMetaData() throws ResourceException {
+        log.finest("getMetaData()");
+        return new SampleManagedConnectionMetaData();
+    }
+
+    void sendMessage(final String message) {
+        log.finest("sendMessage()");
+
+        final SampleResourceAdapter resourceAdapter = (SampleResourceAdapter) mcf.getResourceAdapter();
+        resourceAdapter.sendMessage(message);
+    }
+}

http://git-wip-us.apache.org/repos/asf/tomee/blob/a82539c8/container/openejb-core/src/test/java/org/apache/openejb/core/mdb/connector/impl/SampleManagedConnectionFactory.java
----------------------------------------------------------------------
diff --git a/container/openejb-core/src/test/java/org/apache/openejb/core/mdb/connector/impl/SampleManagedConnectionFactory.java
b/container/openejb-core/src/test/java/org/apache/openejb/core/mdb/connector/impl/SampleManagedConnectionFactory.java
new file mode 100755
index 0000000..02acb96
--- /dev/null
+++ b/container/openejb-core/src/test/java/org/apache/openejb/core/mdb/connector/impl/SampleManagedConnectionFactory.java
@@ -0,0 +1,99 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+package org.apache.openejb.core.mdb.connector.impl;
+
+import org.apache.openejb.core.mdb.connector.api.SampleConnection;
+import org.apache.openejb.core.mdb.connector.api.SampleConnectionFactory;
+
+import javax.resource.ResourceException;
+import javax.resource.spi.*;
+import javax.security.auth.Subject;
+import java.io.PrintWriter;
+import java.util.Iterator;
+import java.util.Set;
+import java.util.logging.Logger;
+
+@ConnectionDefinition(connectionFactory = SampleConnectionFactory.class,
+        connectionFactoryImpl = SampleConnectionFactoryImpl.class,
+        connection = SampleConnection.class,
+        connectionImpl = SampleConnectionImpl.class)
+public class SampleManagedConnectionFactory implements ManagedConnectionFactory, ResourceAdapterAssociation
{
+
+    private static final long serialVersionUID = 1L;
+
+    private static Logger log = Logger.getLogger(SampleManagedConnectionFactory.class.getName());
+
+    private ResourceAdapter ra;
+
+    private PrintWriter logwriter;
+
+    public SampleManagedConnectionFactory() {
+
+    }
+
+    public Object createConnectionFactory(ConnectionManager cxManager) throws ResourceException
{
+        log.finest("createConnectionFactory()");
+        return new SampleConnectionFactoryImpl(this, cxManager);
+    }
+
+    public Object createConnectionFactory() throws ResourceException {
+        throw new ResourceException("This resource adapter doesn't support non-managed environments");
+    }
+
+    public ManagedConnection createManagedConnection(Subject subject,
+                                                     ConnectionRequestInfo cxRequestInfo)
throws ResourceException {
+        log.finest("createManagedConnection()");
+        return new SampleManagedConnection(this);
+    }
+
+    public ManagedConnection matchManagedConnections(Set connectionSet,
+                                                     Subject subject, ConnectionRequestInfo
cxRequestInfo) throws ResourceException {
+        log.finest("matchManagedConnections()");
+        ManagedConnection result = null;
+        Iterator it = connectionSet.iterator();
+        while (result == null && it.hasNext()) {
+            ManagedConnection mc = (ManagedConnection) it.next();
+            if (mc instanceof SampleManagedConnection) {
+                result = mc;
+            }
+
+        }
+        return result;
+    }
+
+    public PrintWriter getLogWriter() throws ResourceException {
+        log.finest("getLogWriter()");
+        return logwriter;
+    }
+
+    public void setLogWriter(PrintWriter out) throws ResourceException {
+        log.finest("setLogWriter()");
+        logwriter = out;
+    }
+
+    public ResourceAdapter getResourceAdapter() {
+        log.finest("getResourceAdapter()");
+        return ra;
+    }
+
+    public void setResourceAdapter(ResourceAdapter ra) {
+        log.finest("setResourceAdapter()");
+        this.ra = ra;
+    }
+}

http://git-wip-us.apache.org/repos/asf/tomee/blob/a82539c8/container/openejb-core/src/test/java/org/apache/openejb/core/mdb/connector/impl/SampleManagedConnectionMetaData.java
----------------------------------------------------------------------
diff --git a/container/openejb-core/src/test/java/org/apache/openejb/core/mdb/connector/impl/SampleManagedConnectionMetaData.java
b/container/openejb-core/src/test/java/org/apache/openejb/core/mdb/connector/impl/SampleManagedConnectionMetaData.java
new file mode 100755
index 0000000..f439fcb
--- /dev/null
+++ b/container/openejb-core/src/test/java/org/apache/openejb/core/mdb/connector/impl/SampleManagedConnectionMetaData.java
@@ -0,0 +1,56 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+package org.apache.openejb.core.mdb.connector.impl;
+
+import javax.resource.ResourceException;
+import javax.resource.spi.ManagedConnectionMetaData;
+import java.util.logging.Logger;
+
+public class SampleManagedConnectionMetaData implements ManagedConnectionMetaData {
+
+    private static Logger log = Logger.getLogger(SampleManagedConnectionMetaData.class.getName());
+
+    public SampleManagedConnectionMetaData() {
+
+    }
+
+    @Override
+    public String getEISProductName() throws ResourceException {
+        log.finest("getEISProductName()");
+        return null; //TODO
+    }
+
+    @Override
+    public String getEISProductVersion() throws ResourceException {
+        log.finest("getEISProductVersion()");
+        return null; //TODO
+    }
+
+    @Override
+    public int getMaxConnections() throws ResourceException {
+        log.finest("getMaxConnections()");
+        return 0; //TODO
+    }
+
+    @Override
+    public String getUserName() throws ResourceException {
+        log.finest("getUserName()");
+        return null; //TODO
+    }
+}

http://git-wip-us.apache.org/repos/asf/tomee/blob/a82539c8/container/openejb-core/src/test/java/org/apache/openejb/core/mdb/connector/impl/SampleResourceAdapter.java
----------------------------------------------------------------------
diff --git a/container/openejb-core/src/test/java/org/apache/openejb/core/mdb/connector/impl/SampleResourceAdapter.java
b/container/openejb-core/src/test/java/org/apache/openejb/core/mdb/connector/impl/SampleResourceAdapter.java
new file mode 100644
index 0000000..fdf011e
--- /dev/null
+++ b/container/openejb-core/src/test/java/org/apache/openejb/core/mdb/connector/impl/SampleResourceAdapter.java
@@ -0,0 +1,117 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.openejb.core.mdb.connector.impl;
+
+import org.apache.openejb.core.mdb.connector.api.InboundListener;
+
+import javax.resource.ResourceException;
+import javax.resource.spi.ActivationSpec;
+import javax.resource.spi.BootstrapContext;
+import javax.resource.spi.Connector;
+import javax.resource.spi.ResourceAdapter;
+import javax.resource.spi.ResourceAdapterInternalException;
+import javax.resource.spi.UnavailableException;
+import javax.resource.spi.endpoint.MessageEndpoint;
+import javax.resource.spi.endpoint.MessageEndpointFactory;
+import javax.transaction.xa.XAResource;
+import java.util.Collection;
+import java.util.Map;
+import java.util.concurrent.ConcurrentHashMap;
+import java.util.concurrent.ExecutorService;
+import java.util.concurrent.Executors;
+
+@Connector(description = "Sample Resource Adapter", displayName = "Sample Resource Adapter",
eisType = "Sample Resource Adapter", version = "1.0")
+public class SampleResourceAdapter implements ResourceAdapter {
+
+    private final Map<SampleActivationSpec, MessageEndpointFactory> targets = new ConcurrentHashMap<SampleActivationSpec,
MessageEndpointFactory>();
+    private final ExecutorService threadPool = Executors.newFixedThreadPool(10);
+
+    public void start(BootstrapContext bootstrapContext) throws ResourceAdapterInternalException
{
+    }
+
+    public void stop() {
+    }
+
+    public void endpointActivation(final MessageEndpointFactory messageEndpointFactory, final
ActivationSpec activationSpec)
+            throws ResourceException
+    {
+        final SampleActivationSpec sampleActivationSpec = (SampleActivationSpec) activationSpec;
+
+        try {
+            targets.put(sampleActivationSpec, messageEndpointFactory);
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+    }
+
+    public void endpointDeactivation(MessageEndpointFactory messageEndpointFactory, ActivationSpec
activationSpec) {
+        final SampleActivationSpec sampleActivationSpec = (SampleActivationSpec) activationSpec;
+        targets.remove(sampleActivationSpec);
+        threadPool.shutdownNow();
+    }
+
+    public XAResource[] getXAResources(ActivationSpec[] activationSpecs) throws ResourceException
{
+        return new XAResource[0];
+    }
+
+    public void sendMessage(final String message) {
+        threadPool.submit(new MessageSender(message));
+    }
+
+    public static class EndpointTarget {
+        private final MessageEndpoint messageEndpoint;
+
+        public EndpointTarget(final MessageEndpoint messageEndpoint) {
+            this.messageEndpoint = messageEndpoint;
+        }
+
+        public void invoke(final String message) {
+            ((InboundListener)this.messageEndpoint).receiveMessage(message);
+        }
+    }
+
+    public class MessageSender implements Runnable {
+        private final String message;
+
+        public MessageSender(final String message) {
+            this.message = message;
+        }
+
+        @Override
+        public void run() {
+            while (targets.isEmpty()) {
+                try {
+                    Thread.sleep(1000);
+                } catch (InterruptedException e) {
+                    // ignore
+                }
+            }
+
+            final Collection<MessageEndpointFactory> messageEndpointFactories = targets.values();
+            for (final MessageEndpointFactory messageEndpointFactory : messageEndpointFactories)
{
+                try {
+                    final MessageEndpoint endpoint = messageEndpointFactory.createEndpoint(null);
+                    final EndpointTarget endpointTarget = new EndpointTarget(endpoint);
+                    endpointTarget.invoke(message);
+                    endpoint.release();
+                } catch (UnavailableException e) {
+                    e.printStackTrace();
+                }
+            }
+        }
+    }
+}


Mime
View raw message