Rename test
Project: http://git-wip-us.apache.org/repos/asf/tomee/repo Commit: http://git-wip-us.apache.org/repos/asf/tomee/commit/e354a7f7 Tree: http://git-wip-us.apache.org/repos/asf/tomee/tree/e354a7f7 Diff: http://git-wip-us.apache.org/repos/asf/tomee/diff/e354a7f7 Branch: refs/heads/fb_tomee8 Commit: e354a7f70c92c0fb9e2add355f80d6936be903a8 Parents: a73c93f Author: Jonathan Gallimore <j...@jrg.me.uk> Authored: Tue Jan 23 10:53:23 2018 +0000 Committer: Jonathan Gallimore <j...@jrg.me.uk> Committed: Tue Jan 23 10:53:23 2018 +0000 ---------------------------------------------------------------------- .../arquillian/tests/jms/EnvEntryTest.java | 151 +++++++++++++++++++ .../arquillian/tests/jms/JmsEnvEntryTest.java | 151 ------------------- 2 files changed, 151 insertions(+), 151 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/tomee/blob/e354a7f7/arquillian/arquillian-tomee-tests/arquillian-tomee-jms-tests/src/test/java/org/apache/openejb/arquillian/tests/jms/EnvEntryTest.java ---------------------------------------------------------------------- diff --git a/arquillian/arquillian-tomee-tests/arquillian-tomee-jms-tests/src/test/java/org/apache/openejb/arquillian/tests/jms/EnvEntryTest.java b/arquillian/arquillian-tomee-tests/arquillian-tomee-jms-tests/src/test/java/org/apache/openejb/arquillian/tests/jms/EnvEntryTest.java new file mode 100644 index 0000000..1b34223 --- /dev/null +++ b/arquillian/arquillian-tomee-tests/arquillian-tomee-jms-tests/src/test/java/org/apache/openejb/arquillian/tests/jms/EnvEntryTest.java @@ -0,0 +1,151 @@ +/** + * 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.arquillian.tests.jms; + +import org.jboss.arquillian.container.test.api.Deployment; +import org.jboss.arquillian.junit.Arquillian; +import org.jboss.arquillian.test.api.ArquillianResource; +import org.jboss.shrinkwrap.api.ShrinkWrap; +import org.jboss.shrinkwrap.api.asset.StringAsset; +import org.jboss.shrinkwrap.api.spec.JavaArchive; +import org.jboss.shrinkwrap.descriptor.api.Descriptors; +import org.jboss.shrinkwrap.descriptor.api.ejbjar31.EjbJarDescriptor; +import org.junit.Test; +import org.junit.runner.RunWith; + +import javax.ejb.EJB; +import java.util.concurrent.Callable; + +import static org.junit.Assert.assertEquals; + +@RunWith(Arquillian.class) +public class EnvEntryTest { + @EJB + private MessageBean messageBean; + + @Deployment + public static JavaArchive getArchive() { + + final EjbJarDescriptor ejbJarDescriptor = Descriptors.create(EjbJarDescriptor.class); + ejbJarDescriptor.getOrCreateEnterpriseBeans() + .createMessageDriven() + .ejbName("RedBean") + .ejbClass(RedBean.class.getName()) + .messagingType("javax.jms.MessageListener") + .transactionType("Container") + .messageDestinationType("javax.jms.Topic") + .getOrCreateActivationConfig() + .createActivationConfigProperty() + .activationConfigPropertyName("destinationType") + .activationConfigPropertyValue("javax.jms.Topic").up() + .createActivationConfigProperty() + .activationConfigPropertyName("destination") + .activationConfigPropertyValue("red").up().up() + .createEnvEntry().envEntryName("color").envEntryType("java.lang.String").envEntryValue("red").up().up() + .createMessageDriven() + .ejbName("BlueBean") + .ejbClass(BlueBean.class.getName()) + .messagingType("javax.jms.MessageListener") + .transactionType("Container") + .messageDestinationType("javax.jms.Topic") + .getOrCreateActivationConfig() + .createActivationConfigProperty() + .activationConfigPropertyName("destinationType") + .activationConfigPropertyValue("javax.jms.Topic").up() + .createActivationConfigProperty() + .activationConfigPropertyName("destination") + .activationConfigPropertyValue("blue").up().up() + .createEnvEntry().envEntryName("color").envEntryType("java.lang.String").envEntryValue("blue").up().up() + .createMessageDriven() + .ejbName("NoColorBean") + .ejbClass(NoColorSpecifiedBean.class.getName()) + .messagingType("javax.jms.MessageListener") + .transactionType("Container") + .messageDestinationType("javax.jms.Topic") + .getOrCreateActivationConfig() + .createActivationConfigProperty() + .activationConfigPropertyName("destinationType") + .activationConfigPropertyValue("javax.jms.Topic").up() + .createActivationConfigProperty() + .activationConfigPropertyName("destination") + .activationConfigPropertyValue("nocolor").up().up(); + + final String ejbJarXml = ejbJarDescriptor.exportAsString(); + + + final JavaArchive archive = ShrinkWrap.create(JavaArchive.class, "jms-env-entry.jar") + .addClasses(BaseMdbBean.class, BlueBean.class, Color.class, NoColorSpecifiedBean.class, RedBean.class, MessageBean.class) + .add(new StringAsset("<beans/>"), "META-INF/beans.xml") + .add(new StringAsset(ejbJarXml), "META-INF/ejb-jar.xml"); + + System.out.println(archive.toString(true)); + + return archive; + } + + @Test + public void test() throws Exception { + messageBean.clear(); + + messageBean.callRed(); + assertXMessages(1); + assertEquals("red",messageBean.getColors().get(0)); + messageBean.clear(); + + messageBean.callBlue(); + assertXMessages(1); + assertEquals("blue",messageBean.getColors().get(0)); + messageBean.clear(); + + messageBean.callNoColor(); + assertXMessages(1); + assertEquals("<not specified>",messageBean.getColors().get(0)); + messageBean.clear(); + } + + public void assertXMessages(final int x) { + attempt(5, 100, new Callable<Void>() { + + @Override + public Void call() throws Exception { + assertEquals(x, messageBean.getColors().size()); + return null; + } + }); + } + + + public <T> T attempt(int tries, int delay, Callable<T> callable) { + for (int i = 0; i < tries; i++) { + try { + return callable.call(); + } catch (Throwable t) { + if (i == (tries - 1)) { + throw new RuntimeException(t); + } + + try { + Thread.sleep(delay); + } catch (InterruptedException e) { + // ignore + } + } + } + + throw new IllegalStateException("We shouldn't reach this exception"); + } +} http://git-wip-us.apache.org/repos/asf/tomee/blob/e354a7f7/arquillian/arquillian-tomee-tests/arquillian-tomee-jms-tests/src/test/java/org/apache/openejb/arquillian/tests/jms/JmsEnvEntryTest.java ---------------------------------------------------------------------- diff --git a/arquillian/arquillian-tomee-tests/arquillian-tomee-jms-tests/src/test/java/org/apache/openejb/arquillian/tests/jms/JmsEnvEntryTest.java b/arquillian/arquillian-tomee-tests/arquillian-tomee-jms-tests/src/test/java/org/apache/openejb/arquillian/tests/jms/JmsEnvEntryTest.java deleted file mode 100644 index 9a4cced..0000000 --- a/arquillian/arquillian-tomee-tests/arquillian-tomee-jms-tests/src/test/java/org/apache/openejb/arquillian/tests/jms/JmsEnvEntryTest.java +++ /dev/null @@ -1,151 +0,0 @@ -/** - * 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.arquillian.tests.jms; - -import org.jboss.arquillian.container.test.api.Deployment; -import org.jboss.arquillian.junit.Arquillian; -import org.jboss.arquillian.test.api.ArquillianResource; -import org.jboss.shrinkwrap.api.ShrinkWrap; -import org.jboss.shrinkwrap.api.asset.StringAsset; -import org.jboss.shrinkwrap.api.spec.JavaArchive; -import org.jboss.shrinkwrap.descriptor.api.Descriptors; -import org.jboss.shrinkwrap.descriptor.api.ejbjar31.EjbJarDescriptor; -import org.junit.Test; -import org.junit.runner.RunWith; - -import javax.ejb.EJB; -import java.util.concurrent.Callable; - -import static org.junit.Assert.assertEquals; - -@RunWith(Arquillian.class) -public class JmsEnvEntryTest { - @EJB - private MessageBean messageBean; - - @Deployment - public static JavaArchive getArchive() { - - final EjbJarDescriptor ejbJarDescriptor = Descriptors.create(EjbJarDescriptor.class); - ejbJarDescriptor.getOrCreateEnterpriseBeans() - .createMessageDriven() - .ejbName("RedBean") - .ejbClass(RedBean.class.getName()) - .messagingType("javax.jms.MessageListener") - .transactionType("Container") - .messageDestinationType("javax.jms.Topic") - .getOrCreateActivationConfig() - .createActivationConfigProperty() - .activationConfigPropertyName("destinationType") - .activationConfigPropertyValue("javax.jms.Topic").up() - .createActivationConfigProperty() - .activationConfigPropertyName("destination") - .activationConfigPropertyValue("red").up().up() - .createEnvEntry().envEntryName("color").envEntryType("java.lang.String").envEntryValue("red").up().up() - .createMessageDriven() - .ejbName("BlueBean") - .ejbClass(BlueBean.class.getName()) - .messagingType("javax.jms.MessageListener") - .transactionType("Container") - .messageDestinationType("javax.jms.Topic") - .getOrCreateActivationConfig() - .createActivationConfigProperty() - .activationConfigPropertyName("destinationType") - .activationConfigPropertyValue("javax.jms.Topic").up() - .createActivationConfigProperty() - .activationConfigPropertyName("destination") - .activationConfigPropertyValue("blue").up().up() - .createEnvEntry().envEntryName("color").envEntryType("java.lang.String").envEntryValue("blue").up().up() - .createMessageDriven() - .ejbName("NoColorBean") - .ejbClass(NoColorSpecifiedBean.class.getName()) - .messagingType("javax.jms.MessageListener") - .transactionType("Container") - .messageDestinationType("javax.jms.Topic") - .getOrCreateActivationConfig() - .createActivationConfigProperty() - .activationConfigPropertyName("destinationType") - .activationConfigPropertyValue("javax.jms.Topic").up() - .createActivationConfigProperty() - .activationConfigPropertyName("destination") - .activationConfigPropertyValue("nocolor").up().up(); - - final String ejbJarXml = ejbJarDescriptor.exportAsString(); - - - final JavaArchive archive = ShrinkWrap.create(JavaArchive.class, "jms-env-entry.jar") - .addClasses(BaseMdbBean.class, BlueBean.class, Color.class, NoColorSpecifiedBean.class, RedBean.class, MessageBean.class) - .add(new StringAsset("<beans/>"), "META-INF/beans.xml") - .add(new StringAsset(ejbJarXml), "META-INF/ejb-jar.xml"); - - System.out.println(archive.toString(true)); - - return archive; - } - - @Test - public void test() throws Exception { - messageBean.clear(); - - messageBean.callRed(); - assertXMessages(1); - assertEquals("red",messageBean.getColors().get(0)); - messageBean.clear(); - - messageBean.callBlue(); - assertXMessages(1); - assertEquals("blue",messageBean.getColors().get(0)); - messageBean.clear(); - - messageBean.callNoColor(); - assertXMessages(1); - assertEquals("<not specified>",messageBean.getColors().get(0)); - messageBean.clear(); - } - - public void assertXMessages(final int x) { - attempt(5, 100, new Callable<Void>() { - - @Override - public Void call() throws Exception { - assertEquals(x, messageBean.getColors().size()); - return null; - } - }); - } - - - public <T> T attempt(int tries, int delay, Callable<T> callable) { - for (int i = 0; i < tries; i++) { - try { - return callable.call(); - } catch (Throwable t) { - if (i == (tries - 1)) { - throw new RuntimeException(t); - } - - try { - Thread.sleep(delay); - } catch (InterruptedException e) { - // ignore - } - } - } - - throw new IllegalStateException("We shouldn't reach this exception"); - } -}
