Skip to content

Commit d5736d5

Browse files
arun-guptaarun-gupta
committed
Merge pull request javaee-samples#116 from pdudits/master
Tests for send-receive module
2 parents 0093618 + caea0eb commit d5736d5

File tree

13 files changed

+243
-353
lines changed

13 files changed

+243
-353
lines changed

‎jms/send-receive/src/main/java/org/javaee7/jms/send/receive/Constants.java‎

Lines changed: 14 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,14 @@
1+
/*
2+
* Copyright (c) 2013 RWE IT Slovakia, s.r.o; RWE IT GmbH
3+
*/
4+
5+
package org.javaee7.jms.send.receive;
6+
7+
/**
8+
*
9+
* @author Patrik Dudits
10+
*/
11+
public class Constants {
12+
public static final String SYNC_QUEUE = "java:global/jms/mySyncQueue";
13+
public static final String ASYNC_QUEUE = "java:global/jms/myAsyncQueue";
14+
}

‎jms/send-receive/src/main/java/org/javaee7/jms/send/receive/MessageReceiverAsync.java‎

Lines changed: 12 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -43,6 +43,8 @@
4343
import java.util.logging.Logger;
4444
import javax.ejb.ActivationConfigProperty;
4545
import javax.ejb.MessageDriven;
46+
import javax.jms.JMSDestinationDefinition;
47+
import javax.jms.JMSDestinationDefinitions;
4648
import javax.jms.JMSException;
4749
import javax.jms.Message;
4850
import javax.jms.MessageListener;
@@ -51,9 +53,18 @@
5153
/**
5254
* @author Arun Gupta
5355
*/
56+
@JMSDestinationDefinitions(
57+
@JMSDestinationDefinition(name = Constants.ASYNC_QUEUE,
58+
resourceAdapter = "jmsra",
59+
interfaceName = "javax.jms.Queue",
60+
destinationName="asyncQueue",
61+
description="My Async Queue")
62+
)
5463
@MessageDriven(activationConfig = {
5564
@ActivationConfigProperty(propertyName = "destinationLookup",
56-
propertyValue = "java:global/jms/myAsyncQueue")
65+
propertyValue = Constants.ASYNC_QUEUE),
66+
@ActivationConfigProperty(propertyName = "destinationType",
67+
propertyValue = "javax.jms.Queue"),
5768
})
5869
public class MessageReceiverAsync implements MessageListener {
5970

‎jms/send-receive/src/main/java/org/javaee7/jms/send/receive/MessageReceiverSync.java‎

Lines changed: 9 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -43,18 +43,26 @@
4343
import javax.ejb.Stateless;
4444
import javax.inject.Inject;
4545
import javax.jms.JMSContext;
46+
import javax.jms.JMSDestinationDefinition;
47+
import javax.jms.JMSDestinationDefinitions;
4648
import javax.jms.Queue;
4749

4850
/**
4951
* @author Arun Gupta
5052
*/
53+
@JMSDestinationDefinitions({@JMSDestinationDefinition(name = Constants.SYNC_QUEUE,
54+
resourceAdapter = "jmsra",
55+
interfaceName = "javax.jms.Queue",
56+
destinationName="syncQueue",
57+
description="My Sync Queue")
58+
})
5159
@Stateless
5260
public class MessageReceiverSync {
5361

5462
@Inject
5563
private JMSContext context;
5664

57-
@Resource(mappedName="java:global/jms/mySyncQueue")
65+
@Resource(mappedName=Constants.SYNC_QUEUE)
5866
Queue myQueue;
5967

6068
public String receiveMessage() {

‎jms/send-receive/src/main/java/org/javaee7/jms/send/receive/MessageSenderAsync.java‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -60,10 +60,10 @@ public class MessageSenderAsync {
6060
// @JMSConnectionFactory("java:comp/DefaultJMSConnectionFactory")
6161
JMSContext context;
6262

63-
@Resource(lookup = "java:global/jms/mySyncQueue")
63+
@Resource(lookup = Constants.SYNC_QUEUE)
6464
Queue syncQueue;
6565

66-
@Resource(lookup = "java:global/jms/myAsyncQueue")
66+
@Resource(lookup = Constants.ASYNC_QUEUE)
6767
Queue asyncQueue;
6868

6969
public void sendMessage(String message) {

‎jms/send-receive/src/main/java/org/javaee7/jms/send/receive/MessageSenderSync.java‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -55,10 +55,10 @@ public class MessageSenderSync {
5555
// @JMSConnectionFactory("java:comp/DefaultJMSConnectionFactory")
5656
JMSContext context;
5757

58-
@Resource(mappedName="java:global/jms/mySyncQueue")
58+
@Resource(mappedName=Constants.SYNC_QUEUE)
5959
Queue syncQueue;
6060

61-
@Resource(mappedName="java:global/jms/myAsyncQueue")
61+
@Resource(mappedName=Constants.ASYNC_QUEUE)
6262
Queue asyncQueue;
6363

6464
public void sendMessage(String message) {

‎jms/send-receive/src/main/java/org/javaee7/jms/send/receive/TestServletSendAsync.java‎

Lines changed: 0 additions & 147 deletions
This file was deleted.

‎jms/send-receive/src/main/java/org/javaee7/jms/send/receive/TestServletSendSync.java‎

Lines changed: 0 additions & 144 deletions
This file was deleted.

0 commit comments

Comments
 (0)