You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@tomee.apache.org by tv...@apache.org on 2017/10/27 21:34:43 UTC
[2/2] tomee git commit: unit test
unit test
Project: http://git-wip-us.apache.org/repos/asf/tomee/repo
Commit: http://git-wip-us.apache.org/repos/asf/tomee/commit/73d788ac
Tree: http://git-wip-us.apache.org/repos/asf/tomee/tree/73d788ac
Diff: http://git-wip-us.apache.org/repos/asf/tomee/diff/73d788ac
Branch: refs/heads/master
Commit: 73d788ac3fcf661c756a136feacf0a75024d65a0
Parents: 8558e49
Author: Thiago Veronezi <th...@veronezi.org>
Authored: Fri Oct 27 16:09:09 2017 -0400
Committer: Thiago Veronezi <th...@veronezi.org>
Committed: Fri Oct 27 16:09:09 2017 -0400
----------------------------------------------------------------------
.../org/apache/openejb/activemq/JMS2AMQTest.java | 17 +++++++++++++++--
1 file changed, 15 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/tomee/blob/73d788ac/container/openejb-core/src/test/java/org/apache/openejb/activemq/JMS2AMQTest.java
----------------------------------------------------------------------
diff --git a/container/openejb-core/src/test/java/org/apache/openejb/activemq/JMS2AMQTest.java b/container/openejb-core/src/test/java/org/apache/openejb/activemq/JMS2AMQTest.java
index aa8f8d2..ba6ab54 100644
--- a/container/openejb-core/src/test/java/org/apache/openejb/activemq/JMS2AMQTest.java
+++ b/container/openejb-core/src/test/java/org/apache/openejb/activemq/JMS2AMQTest.java
@@ -268,6 +268,18 @@ public class JMS2AMQTest {
}
@Test
+ public void sendMessageToMdb() throws Exception {
+ try (final JMSContext context = cf.createContext()) {
+ Message message = context.createMessage();
+ message.setStringProperty("text", TEXT);
+ context.createProducer().send(destination, message);
+ assertTrue(Listener.sync());
+ } catch (final JMSRuntimeException ex) {
+ fail(ex.getMessage());
+ }
+ }
+
+ @Test
public void sendToMdbWithDefaultCf() throws Exception {
defaultContext.createProducer().send(destination, TEXT);
assertTrue(Listener.sync());
@@ -378,9 +390,10 @@ public class JMS2AMQTest {
public void onMessage(final Message message) {
try {
try {
- ok = TextMessage.class.isInstance(message)
+ ok = (TextMessage.class.isInstance(message)
&& TEXT.equals(TextMessage.class.cast(message).getText())
- && TEXT.equals(message.getBody(String.class));
+ && TEXT.equals(message.getBody(String.class)))
+ || message.getStringProperty("text").equals(TEXT);
} catch (final JMSException e) {
// no-op
}