Contents
JEE
Java Platform, Enterprise Edition
JEE version |
Application Server |
JEE5 |
JBoss5 Glassfish2.1 |
JEE6 |
JBossAS7 Wildfly7.1 Glassfish3.x JBossEAP6 |
JEE7 |
Wildfly8 Glassfish4.x |
JEE8 |
Wildfly14 Glassfish5.x |
JEE9 |
Wildfly25 Glassfish6.x |
JEE7 Tutorial
https://docs.oracle.com/javaee/7/tutorial/index.html
Key features: https://blogs.oracle.com/arungupta/entry/java_ee_7_key_features
Reference implementation: https://glassfish.java.net/getstarted.html
Java EE7 APIs: https://docs.oracle.com/javaee/7/tutorial/overview007.htm
Install Glassfish 4.1
https://glassfish.java.net/download.html
http://download.java.net/glassfish/4.1.1/release/glassfish-4.1.1.zip
JDK 8 u20 or above is recommended for GlassFish 4.1.
1 cd /tmp
2 wget http://download.oracle.com/otn-pub/java/jdk/8u25-b17/jdk-8u25-linux-x64.tar.gz
3 wget http://dlc.sun.com.edgesuite.net/glassfish/4.1/release/glassfish-4.1.zip
4 unzip glassfish-4.1.zip
5 tar xvzf jdk-8u25-linux-x64.tar.gz
6 mv jdk1.8.0_25/ /usr/java
7 mv glassfish4/ /opt/appsrv/
8 cd /usr/java/jdk1.8.0_25
9 chmod 555 * -R
10 /usr/java/jdk1.8.0_25/bin/java -version
11 cd /opt/appsrv/glassfish4/bin
12 JAVA_HOME=/usr/java/jdk1.8.0_25 AS_JAVA=/usr/java/jdk1.8.0_25 asadmin start-domain
13 # http://localhost:4848/
14 asadmin change-admin-password
15 asadmin enable-secure-admin
16 asadmin stop-domain
17 asadmin start-domain
Install Glassfish 4.1 on FreeBSD 10.3
Uses MariaDB instead of MySQL.
Enter admin user name [default: admin]> Enter the admin password> #is empty !!!! Enter the new admin password> Enter the new admin password again> Command change-admin-password executed successfully.
- ./asadmin enable-secure-admin
Enter admin user name> admin Enter admin password for user "admin"> You must restart all running servers for the change in secure admin to take effect. Command enable-secure-admin executed successfully.
mysql -u root -p Enter password: Welcome to the MariaDB monitor. Commands end with ; or \g. Your MariaDB connection id is 2 Server version: 10.1.14-MariaDB FreeBSD Ports Copyright (c) 2000, 2016, Oracle, MariaDB Corporation Ab and others. Type 'help;' or '\h' for help. Type '\c' to clear the current input statement. MariaDB [(none)]> create database mysqljdbc; Query OK, 1 row affected (0.00 sec) MariaDB [(none)]> create user 'mysqljdbc'@'%' identified by '12345678'; Query OK, 0 rows affected (0.01 sec) MariaDB [(none)]> GRANT ALL PRIVILEGES ON mysqljdbc.* TO 'mysqljdbc'@'%'; Query OK, 0 rows affected (0.00 sec) MariaDB [(none)]> exit Bye
1 cd /usr/local/glassfish-4.1/glassfish/domains/domain1/lib
2 wget http://central.maven.org/maven2/org/mariadb/jdbc/mariadb-java-client/1.5.2/mariadb-java-client-1.5.2.jar
3 # jms resources, destination resources
4 # JNDI name: jms/Queuex
5 # physical destination name: Queuex
6 # JMS connection factory
7 # type: javax.jms.ConnectionFactory
8 # JNDI name: jms/ConnectionFactory
9 # JDBC connection pool
10 # Pool name: MariaDBPool
11 # resource type: javax.sql.DataSource
12 # Datasource class name: org.mariadb.jdbc.MariaDbDataSource
13 # Connection Validation: Required
14 # Validation method meta-data
15 # user mysqljdbc
16 # userName mysqljdbc
17 # databaseName mysqljdbc
18 # PortNumber 3306
19 # Password 12345678
20 # ServerName localhost
21 # LoginTimeout 0
22 # JDBC resource
23 # jndi name: jdbc/mysql
24 # connection pool: MariaDBPool
25
Docker Ubuntu image install Glassfish4.1
1 docker pull ubuntu
2 docker create --name containerx -p 1022:22 -p 1848:4848 -p 1080:8080 ubuntu
3 docker start containerx
4 docker exec -t -i containerx
5 apt-get update
6 apt-get install tzdata-java openjdk-7-jdk wget unzip
7 java
8 java -version
9 apt-get install
10 cd /tmp
11 wget http://dlc.sun.com.edgesuite.net/glassfish/4.1/release/glassfish-4.1.zip
12 unzip glassfish-4.1.zip
13 mkdir -p /opt/appsrv
14 mv glassfish4/ /opt/appsrv/
15 cd /opt/appsrv/glassfish4/
16 bin/asadmin start-domain
17 bin/asadmin change-admin-password
18 bin/asadmin enable-secure-admin
19 bin/asadmin stop-domain
20 bin/asadmin start-domain
21 exit
https://github.com/sebsto/docker-glassfish4/blob/master/Dockerfile
JEE6 EJB 3.1 sample for Glassfish 3.1.2.2 and JBoss 7.1.1 (EJB + JPA + Web Service + MDB + Schedule)
Also runs with Glashfish 4.1.
Structure:
. |-- pom.xml |-- src | `-- main | |-- java | | `-- org | | `-- allowed | | `-- bitarus | | |-- MessageEntity.java | | |-- ScheduleRemote.java | | |-- ScheduleWS.java | | |-- Scheduler.java | | `-- TestMDB.java | `-- resources | `-- META-INF | |-- ejb-jar.xml | `-- persistence.xml
pom.xml
1 <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/xsd/maven-4.0.0.xsd">
2 <modelVersion>4.0.0</modelVersion>
3 <groupId>org.allowed.bitarus</groupId>
4 <artifactId>ejbjee6</artifactId>
5 <version>0.0.1</version>
6 <packaging>ejb</packaging>
7 <dependencies>
8 <dependency>
9 <groupId>javax</groupId>
10 <artifactId>javaee-api</artifactId>
11 <version>6.0</version>
12 <scope>provided</scope>
13 </dependency>
14 </dependencies>
15 </project>
16 <!--
17 mkdir -p src/main/java/org/allowed/bitarus
18 touch src/main/java/org/allowed/bitarus/Scheduler.java
19 touch src/main/java/org/allowed/bitarus/ScheduleRemote.java
20 touch src/main/java/org/allowed/bitarus/ScheduleWS.java
21 touch src/main/java/org/allowed/bitarus/TestMDB.java
22 touch src/main/java/org/allowed/bitarus/MessageEntity.java
23 mkdir -p src/main/resources/META-INF
24 touch src/main/resources/META-INF/ejb-jar.xml
25 touch src/main/resources/META-INF/persistence.xml
26
27 mvn clean compile package
28 # Tested in GlassFish Server Open Source Edition 3.1.2.2 (build 5)
29 -->
./src/main/resources/META-INF/ejb-jar.xml
./src/main/resources/META-INF/persistence.xml
1 <persistence>
2 <persistence-unit name="puMysql" transaction-type="JTA">
3 <jta-data-source>jdbc/mysql</jta-data-source>
4 <properties>
5 <!--property name="eclipselink.ddl-generation" value="create-or-extend-tables"/-->
6 <property name="eclipselink.ddl-generation" value="drop-and-create-tables"/>
7 <property name="eclipselink.ddl-generation.output-mode" value="both"/>
8 <property name="eclipselink.target-database" value="MySQL"/>
9 </properties>
10 </persistence-unit>
11 </persistence>
12 <!--
13 Copy mysql-connector-java-5.1.30-bin.jar
14 cp mysql-connector-java-5.1.30-bin.jar /opt/glassfish-3.1.2.2/glassfish/domains/domain1/lib/
15 mysql -u root -p
16 create database mysqljdbc;
17 create user 'mysqljdbc'@'%' identified by '12345678';
18 GRANT ALL PRIVILEGES ON mysqljdbc.* TO 'mysqljdbc'@'%';
19 mysql -u mysqljdbc -p
20
21 JDBC Connection Pool
22 Name: MySQLPool
23 Resource type: javax.sql.DataSource
24 Datasource class name: com.mysql.jdbc.jdbc2.optional.MysqlDataSource
25 Additional properties
26 portNumber: 3306
27 databaseName: mysqljdbc
28 user: mysqljdbc
29 password: 12345678
30 serverName: 127.0.0.1
31
32 JDBC Resource:
33 New,
34 Pool Name: MySQLPool
35 JNDI name: jdbc/mysql
36 -->
./src/main/java/org/allowed/bitarus/Scheduler.java
1 package org.allowed.bitarus;
2 import javax.ejb.Singleton;
3 import javax.ejb.Schedule;
4 import javax.ejb.ScheduleExpression;
5 import javax.annotation.Resource;
6 import javax.ejb.Timeout;
7 import javax.ejb.TimerConfig;
8 import javax.ejb.TimerService;
9 import javax.ejb.Timer;
10 import javax.annotation.PostConstruct;
11 import javax.ejb.Startup;
12 import javax.jms.ConnectionFactory;
13 import javax.jms.Queue;
14 import javax.jms.Connection;
15 import javax.jms.Session;
16 import javax.jms.MessageProducer;
17 import javax.jms.TextMessage;
18 @Singleton
19 @Startup
20 public class Scheduler {
21 @Resource(mappedName="jms/ConnectionFactory")
22 private ConnectionFactory connectionFactory;
23 @Resource(mappedName="jms/Queuex")
24 private Queue queue;
25
26 @Resource
27 private TimerService timerService;
28
29 @PostConstruct
30 private void postConstruct() {
31 TimerConfig config = new TimerConfig("OneMinutePassed", false);
32 ScheduleExpression se = new ScheduleExpression();
33 se.minute("*");
34 se.hour("*");
35 timerService.createCalendarTimer(se, config);
36 }
37
38 public String addSchedule(String second,String minute,String hour,String info){
39 TimerConfig config = new TimerConfig(info, false);
40 ScheduleExpression se = new ScheduleExpression();
41 se.second(second);
42 se.minute(minute);
43 se.hour(hour);
44 timerService.createCalendarTimer(se, config);
45 return "Added " + info;
46 }
47
48 @Schedule(minute="*/5", hour="*")
49 private void eachFiveMinutes(){
50 System.out.println("Called each five minute");
51 }
52
53 @Timeout
54 public void timeout(Timer timer) {
55 if ("OneMinutePassed".equals(timer.getInfo())) {
56 System.out.println("OneMinutePassed !!!");
57 /*for(Timer t : timerService.getTimers() ){
58 System.out.println(">>> "+ t.getInfo() );
59 }*/
60 }else{
61 System.out.println("!!! "+ timer.getInfo() );
62 // send jms message
63 try{
64 Connection connection = connectionFactory.createConnection();
65 Session session = connection.createSession(false,Session.AUTO_ACKNOWLEDGE);
66 MessageProducer mp = session.createProducer(queue);
67 TextMessage message = session.createTextMessage();
68 message.setText( timer.getInfo().toString() );
69 mp.send(message);
70 mp.close();
71 session.close();
72 connection.close();
73 }catch(Exception ex){ ex.printStackTrace(); }
74 }
75 }
76 }
./src/main/java/org/allowed/bitarus/ScheduleRemote.java
./src/main/java/org/allowed/bitarus/ScheduleWS.java
1 package org.allowed.bitarus;
2 import javax.ejb.Stateless;
3 import javax.jws.WebMethod;
4 import javax.jws.WebService;
5 import javax.ejb.ScheduleExpression;
6 import javax.annotation.Resource;
7 import javax.ejb.TimerService;
8 import javax.ejb.TimerConfig;
9 import javax.ejb.EJB;
10 @Stateless
11 @WebService
12 public class ScheduleWS implements ScheduleRemote{
13 @Resource
14 private TimerService timerService;
15 @EJB
16 Scheduler sc;
17
18 @WebMethod
19 public String addSchedule(String second,String minute,String hour,String info){
20 return sc.addSchedule(second, minute, hour, info);
21 }
22 }
./src/main/java/org/allowed/bitarus/TestMDB.java
1 package org.allowed.bitarus;
2
3 import javax.ejb.MessageDriven;
4 import javax.jms.Message;
5 import javax.jms.TextMessage;
6 import javax.persistence.PersistenceContext;
7 import javax.persistence.EntityManager;
8 @MessageDriven(mappedName="jms/Queuex")
9 public class TestMDB{
10 @PersistenceContext(unitName="puMysql")
11 EntityManager em;
12
13 public void onMessage(Message inMessage) {
14 try{
15 String text = ( (TextMessage) inMessage).getText() ;
16 System.out.println( text );
17 MessageEntity me = new MessageEntity();
18 me.setMessage( text );
19 me.setCreationDate( new java.util.Date() );
20 em.persist(me);
21 }catch(Exception ex){
22 ex.printStackTrace();
23 }
24 }
25 }
./src/main/java/org/allowed/bitarus/MessageEntity.java
1 package org.allowed.bitarus;
2
3 import java.util.Date;
4 import javax.persistence.Id;
5 import javax.persistence.Entity;
6 import javax.persistence.Column;
7 import javax.persistence.GeneratedValue;
8 import javax.persistence.GenerationType;
9 import javax.persistence.TemporalType;
10 import javax.persistence.Temporal;
11 @Entity
12 public class MessageEntity{
13 @Id
14 @GeneratedValue(strategy = GenerationType.IDENTITY)
15 // @GeneratedValue(strategy = GenerationType.AUTO)
16 // @OneToMany
17 // @NamedQueries( { @NamedQuery(name="MessageEntity.byId",query="Select me From MessageEntity e where e.id = :id;") , @NamedQuery() } )
18 // JPQL Select me From MessageEntity e where e.id = :id;
19 // Query q = em.createQuery("Select me From MessageEntity e where e.id = :id;");
20 // Query q = em.createNamedQuery("MessageEntity.byId");
21 // q.setParameter("id",12);
22 // List<MessageEntity> res = q.getResultList ();
23 private long id;
24 @Column
25 @Temporal(TemporalType.TIMESTAMP)
26 private Date creationDate;
27 @Column
28 private String message;
29
30 public long getId(){return this.id;}
31 public void setId(long id){ this.id=id;}
32
33 public Date getCreationDate(){return this.creationDate;}
34 public void setCreationDate(Date creationDate){ this.creationDate=creationDate;}
35
36 public String getMessage(){return this.message;}
37 public void setMessage(String message){ this.message=message;}
38 }
Glassfish OpenMQ standalone client
Structure
. |-- pom.xml |-- src | `-- main | `-- java | `-- org | `-- allowed | `-- bitarus | `-- JmsClient.java
pom.xml
1 <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/xsd/maven-4.0.0.xsd">
2 <modelVersion>4.0.0</modelVersion>
3 <groupId>org.allowed.bitarus</groupId>
4 <artifactId>jmsclient</artifactId>
5 <version>0.0.1</version>
6 <packaging>jar</packaging>
7 <dependencies>
8 <dependency>
9 <groupId>org.glassfish.mq</groupId>
10 <artifactId>imq</artifactId>
11 <version>5.1</version>
12 </dependency>
13 </dependencies>
14 <build>
15 <plugins>
16 <plugin>
17 <artifactId>maven-assembly-plugin</artifactId>
18 <version>2.4</version>
19 <configuration>
20 <descriptorRefs>
21 <descriptorRef>jar-with-dependencies</descriptorRef>
22 </descriptorRefs>
23 <archive>
24 <manifest>
25 <mainClass>org.allowed.bitarus.JmsClient</mainClass>
26 </manifest>
27 </archive>
28 </configuration>
29 <executions>
30 <execution>
31 <id>make-assembly</id>
32 <phase>package</phase>
33 <goals>
34 <goal>single</goal>
35 </goals>
36 </execution>
37 </executions>
38 </plugin>
39 </plugins>
40 </build>
41 </project>
src/main/java/org/allowed/bitarus/JmsClient.java
1 package org.allowed.bitarus;
2 import com.sun.messaging.ConnectionConfiguration;
3 import com.sun.messaging.ConnectionFactory;
4 import com.sun.messaging.Queue;
5 import javax.jms.Connection;
6 import javax.jms.JMSException;
7 import javax.jms.Message;
8 import javax.jms.MessageProducer;
9 import javax.jms.Session;
10
11 public class JmsClient {
12
13 public static void main( String[] args )
14 {
15 try{
16 ConnectionFactory connFactory = new ConnectionFactory();
17 connFactory.setProperty(ConnectionConfiguration.imqAddressList, "127.0.0.1:7676");
18 Queue q = new Queue("Queuex");
19 Connection connection = connFactory.createConnection();
20 System.out.println("After create connection");
21 Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
22 MessageProducer producer = session.createProducer(q);
23 Message message = session.createTextMessage("Bitarus test message");
24 producer.send(message);
25 producer.close();
26 session.close();
27 connection.close();
28 System.out.println("After send message");
29 }catch(Exception ex){
30 ex.printStackTrace();
31 }
32
33 System.out.println("End");
34 }
35 }
Check OpenMQ MessageQueue state
Check used tcp ports by OpenMQ
Should show in text the available ports, with 7676 on the list and other dynamic port with the text jms tcp normal next to it. That dynamic port should also be added in NAT port forwarding if required together withport 7676.
JMS message selector
Filter queue messages based on a JMS property value.
Creates a MessageConsumer for the specified destination, using a message selector.
Message selector in a MessageDrivenBean
From Message
A JMS message selector allows a client to specify, by header field references and property references, the messages it is interested in. Only messages whose header and property values match the selector are delivered. A message selector matches a message if the selector evaluates to true when the message's header field values and property values are substituted for their corresponding identifiers in the selector. Message header field references are restricted to JMSDeliveryMode, JMSPriority, JMSMessageID, JMSTimestamp, JMSCorrelationID, and JMSType. The following message selector selects messages with a message type of car and color of blue and weight greater than 2500 pounds: "JMSType = 'car' AND color = 'blue' AND weight > 2500"
JMS header fields:
- JMSDeliveryMode
- JMSPriority
- JMSMessageID
- JMSTimestamp
- JMSCorrelationID
- JMSType
Glassfish 5.1.0 - Jakarta EE 8 Specification
1 # GlassFish 5.1 requires Oracle JDK 8 Update 191.
2 cd ~/Downloads
3 tar tvzf OpenJDK8U-jdk_x64_linux_hotspot_8u472b08.tar.gz
4 unzip -t glassfish-5.1.0.zip
5 mv OpenJDK8U-jdk_x64_linux_hotspot_8u472b08.tar.gz ~/
6 mv glassfish-5.1.0.zip ~/
7 cd ~/
8 tar xvzf OpenJDK8U-jdk_x64_linux_hotspot_8u472b08.tar.gz
9 unzip glassfish-5.1.0.zip
10 cd ~/glassfish5/bin
11
12 export JAVA_HOME=/home/vitor/jdk8u472-b08
13 export AS_JAVA=/home/vitor/jdk8u472-b08
14 ./asadmin change-admin-password
15 #Enter admin user name [default: admin]>
16 #Enter the admin password> <empty pass>
17 #Enter the new admin password>
18 #Enter the new admin password again>
19 #Command change-admin-password executed successfully.
20
21 ./asadmin start-domain
22 # http://localhost:4848/
23 # http://localhost:4848/common/index.jsf
24
25 ./asadmin stop-domain
26 ./asadmin start-domain
27 #Waiting for domain1 to start ...
28 #Successfully started the domain : domain1
29 #domain Location: /home/vitor/glassfish5/glassfish/domains/domain1
30 #Log File: /home/vitor/glassfish5/glassfish/domains/domain1/logs/server.log
31 #Admin Port: 4848
32 #Command start-domain executed successfully.
33 # Error Could not initialize class sun.security.ssl.SSLEngineImpl in log
34 # Remove grizzly-npn-bootstrap.jar
35 kill $(ps uax | grep glass | head -1 | awk '//{print $2}')
36 cd ~/glassfish5
37 rm ./glassfish/modules/endorsed/grizzly-npn-bootstrap.jar
38 cd bin/
39 ./asadmin start-domain
As issues with OpenJDK
Glassfish 6 - Jakarta EE 9 specification
Eclipse GlassFish 6.2.5 requires JDK 11 or newer.
1 cd ~/Downloads
2 mv glassfish-6.2.5.zip ~/
3 mv OpenJDK11U-jdk_x64_linux_hotspot_11.0.29_7.tar.gz ~/
4
5 cd ~
6 unzip glassfish-6.2.5.zip
7 tar tvzf OpenJDK11U-jdk_x64_linux_hotspot_11.0.29_7.tar.gz
8 tar xvzf OpenJDK11U-jdk_x64_linux_hotspot_11.0.29_7.tar.gz
9
10 export JAVA_HOME=/home/vitor/jdk-11.0.29+7
11 export AS_JAVA=/home/vitor/jdk-11.0.29+7
12
13 cd ~/glassfish6/bin
14 ./asadmin change-admin-password
15 #Enter admin user name [default: admin]>
16 #Enter the admin password> <empty pass>
17 #Enter the new admin password>
18 #Enter the new admin password again>
19 #Command change-admin-password executed successfully.
20
21 ./asadmin start-domain
22 # http://localhost:4848/
23
24 ./asadmin enable-secure-admin
25 #Enter admin user name> admin
26 #Enter admin password for user "admin">
27 #You must restart all running servers for the change in secure admin to take effect.
28 #Command enable-secure-admin executed successfully.
29 ./asadmin stop-domain
30 #Waiting for the domain to stop .
31 #Command stop-domain executed successfully.
32 ./asadmin start-domain
33 #Waiting for domain1 to start ...
34 #Successfully started the domain : domain1
35 #domain Location: /home/vitor/glassfish6/glassfish/domains/domain1
36 #Log File: /home/vitor/glassfish6/glassfish/domains/domain1/logs/server.log
37 #Admin Port: 4848
38 #Command start-domain executed successfully.
39 # https://localhost:4848/common/index.jsf
40 podman run --rm -d --name mariadb -p 3306:3306 --env MARIADB_ROOT_PASSWORD=12345678 mariadb:latest
41 podman exec -it mariadb bash
42 mariadb -h localhost -u root -p
43 # create database mysqljdbc;
44 # create user 'mysqljdbc'@'%' identified by '12345678';
45 # GRANT ALL PRIVILEGES ON mysqljdbc.* TO 'mysqljdbc'@'%';
46 # exit
47 # exit
48 # JDBC driver https://repo1.maven.org/maven2/org/mariadb/jdbc/mariadb-java-client/3.5.6/mariadb-java-client-3.5.6.jar
49
50 mkdir -p src/main/java/org/bitarus/
51 mkdir -p src/main/resources/META-INF
52 touch pom.xml
53 touch src/main/java/org/bitarus/Scheduler.java
54 touch src/main/java/org/bitarus/ScheduleRemote.java
55 touch src/main/java/org/bitarus/ScheduleWS.java
56 touch src/main/java/org/bitarus/TestMDB.java
57 touch src/main/java/org/bitarus/MessageEntity.java
58 touch src/main/resources/META-INF/ejb-jar.xml
59 touch src/main/resources/META-INF/persistence.xml
JDBC connection pool and resource
1 # JDBC connection pool, new
2 # Pool name: MariaDBPool
3 # resource type: javax.sql.DataSource
4 # Next
5 # Datasource class name: org.mariadb.jdbc.MariaDbDataSource
6 # Advanced tab,
7 # Connection Validation: Required
8 # Validation method: meta-data
9 # Additional properties
10 # user mysqljdbc
11 # userName mysqljdbc
12 # databaseName mysqljdbc
13 # PortNumber 3306
14 # Password 12345678
15 # ServerName localhost
16 # LoginTimeout 0
17 # Url jdbc:mariadb://localhost:3306/mysqljdbc
18 # useSSL false
19 # JDBC resource tab
20 # jndi name: jdbc/mysql
21 # connection pool: MariaDBPool
22
23 cp ~/Downloads/mariadb-java-client-3.5.6.jar ~/glassfish6/glassfish/domains/domain1/lib/
24 cp ~/Downloads/mariadb-java-client-3.5.6.jar ~/glassfish6/glassfish/lib/
25 ./asadmin stop-domain
26 ./asadmin start-domain
JMS queue
1 # Resources
2 # jms resources,
3 # destination resources
4 # JNDI name: jms/Queuex
5 # physical destination name: Queuex
6 # resource type: jakarta.jms.Queue
7 # status: true
8 # connection factories
9 # JMS connection factory
10 # Resource Type: jakarta.jms.ConnectionFactory
11 # JNDI name: jms/ConnectionFactory
12 # status: true
13
pom.xml
1 <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/xsd/maven-4.0.0.xsd">
2 <modelVersion>4.0.0</modelVersion>
3 <groupId>org.bitarus</groupId>
4 <artifactId>ejbjee9</artifactId>
5 <version>0.0.1</version>
6 <packaging>ejb</packaging>
7 <dependencies>
8 <dependency>
9 <groupId>jakarta.platform</groupId>
10 <artifactId>jakarta.jakartaee-api</artifactId>
11 <version>9.0.0</version>
12 <scope>provided</scope>
13 </dependency>
14 </dependencies>
15 </project>
src/main/resources/META-INF/ejb-jar.xml
src/main/resources/META-INF/persistence.xml
1 <persistence>
2 <persistence-unit name="puMysql" transaction-type="JTA">
3 <jta-data-source>jdbc/mysql</jta-data-source>
4 <properties>
5 <!--property name="eclipselink.ddl-generation" value="create-or-extend-tables"/-->
6 <property name="eclipselink.ddl-generation" value="drop-and-create-tables"/>
7 <property name="eclipselink.ddl-generation.output-mode" value="both"/>
8 <property name="eclipselink.target-database" value="MySQL"/>
9 </properties>
10 </persistence-unit>
11 </persistence>
src/main/java/org/bitarus/MessageEntity.java
1 package org.bitarus;
2
3 import java.util.Date;
4 import jakarta.persistence.Id;
5 import jakarta.persistence.Entity;
6 import jakarta.persistence.Column;
7 import jakarta.persistence.GeneratedValue;
8 import jakarta.persistence.GenerationType;
9 import jakarta.persistence.TemporalType;
10 import jakarta.persistence.Temporal;
11 @Entity
12 public class MessageEntity{
13 @Id
14 @GeneratedValue(strategy = GenerationType.IDENTITY)
15 // @GeneratedValue(strategy = GenerationType.AUTO)
16 // @OneToMany
17 // @NamedQueries( { @NamedQuery(name="MessageEntity.byId",query="Select me From MessageEntity e where e.id = :id;") , @NamedQuery() } )
18 // JPQL Select me From MessageEntity e where e.id = :id;
19 // Query q = em.createQuery("Select me From MessageEntity e where e.id = :id;");
20 // Query q = em.createNamedQuery("MessageEntity.byId");
21 // q.setParameter("id",12);
22 // List<MessageEntity> res = q.getResultList ();
23 private long id;
24 @Column
25 @Temporal(TemporalType.TIMESTAMP)
26 private Date creationDate;
27 @Column
28 private String message;
29
30 public long getId(){ return this.id; }
31 public void setId(long id){ this.id=id; }
32
33 public Date getCreationDate(){ return this.creationDate; }
34 public void setCreationDate(Date creationDate){ this.creationDate=creationDate; }
35
36 public String getMessage(){ return this.message; }
37 public void setMessage(String message){ this.message=message; }
38 }
src/main/java/org/bitarus/ScheduleRemote.java
src/main/java/org/bitarus/Scheduler.java
1 package org.bitarus;
2 import jakarta.ejb.Singleton;
3 import jakarta.ejb.Schedule;
4 import jakarta.ejb.ScheduleExpression;
5 import jakarta.annotation.Resource;
6 import jakarta.ejb.Timeout;
7 import jakarta.ejb.TimerConfig;
8 import jakarta.ejb.TimerService;
9 import jakarta.ejb.Timer;
10 import jakarta.annotation.PostConstruct;
11 import jakarta.ejb.Startup;
12 import jakarta.jms.ConnectionFactory;
13 import jakarta.jms.Queue;
14 import jakarta.jms.Connection;
15 import jakarta.jms.Session;
16 import jakarta.jms.MessageProducer;
17 import jakarta.jms.TextMessage;
18 @Singleton
19 @Startup
20 public class Scheduler {
21 @Resource(mappedName="jms/ConnectionFactory")
22 private ConnectionFactory connectionFactory;
23 @Resource(mappedName="jms/Queuex")
24 private Queue queue;
25
26 @Resource
27 private TimerService timerService;
28
29 @PostConstruct
30 private void postConstruct() {
31 TimerConfig config = new TimerConfig("OneMinutePassed", false);
32 ScheduleExpression se = new ScheduleExpression();
33 se.minute("*");
34 se.hour("*");
35 timerService.createCalendarTimer(se, config);
36 }
37
38 public String addSchedule(String second,String minute,String hour,String info){
39 TimerConfig config = new TimerConfig(info, false);
40 ScheduleExpression se = new ScheduleExpression();
41 se.second(second);
42 se.minute(minute);
43 se.hour(hour);
44 timerService.createCalendarTimer(se, config);
45 return "Added " + info;
46 }
47
48 @Schedule(minute="*/5", hour="*")
49 private void eachFiveMinutes(){
50 System.out.println("Called each five minute");
51 }
52
53 @Timeout
54 public void timeout(Timer timer) {
55 if ("OneMinutePassed".equals(timer.getInfo())) {
56 System.out.println("OneMinutePassed !!!");
57 /*for(Timer t : timerService.getTimers() ){
58 System.out.println(">>> "+ t.getInfo() );
59 }*/
60 }else{
61 System.out.println("!!! "+ timer.getInfo() );
62 // send jms message
63 try{
64 Connection connection = connectionFactory.createConnection();
65 Session session = connection.createSession(false,Session.AUTO_ACKNOWLEDGE);
66 MessageProducer mp = session.createProducer(queue);
67 TextMessage message = session.createTextMessage();
68 message.setText( timer.getInfo().toString() );
69 mp.send(message);
70 mp.close();
71 session.close();
72 connection.close();
73 }catch(Exception ex){ ex.printStackTrace(); }
74 }
75 }
76 }
src/main/java/org/bitarus/ScheduleWS.java
1 package org.bitarus;
2 import jakarta.ejb.Stateless;
3 import jakarta.jws.WebMethod;
4 import jakarta.jws.WebService;
5 import jakarta.ejb.ScheduleExpression;
6 import jakarta.annotation.Resource;
7 import jakarta.ejb.TimerService;
8 import jakarta.ejb.TimerConfig;
9 import jakarta.ejb.EJB;
10 @Stateless
11 @WebService
12 public class ScheduleWS implements ScheduleRemote{
13 @Resource
14 private TimerService timerService;
15 @EJB
16 Scheduler sc;
17
18 /*
19 http://localhost:8080/ScheduleWSService/ScheduleWS?WSDL
20 http://localhost:8080/ScheduleWSService/ScheduleWS?Tester
21 addSchedule("0", "*/2" , "0" , "infox1" )
22 */
23 @WebMethod
24 public String addSchedule(String second,String minute,String hour,String info){
25 return sc.addSchedule(second, minute, hour, info);
26 }
27 }
src/main/java/org/bitarus/TestMDB.java
1 package org.bitarus;
2
3 import jakarta.ejb.MessageDriven;
4 import jakarta.jms.Message;
5 import jakarta.jms.TextMessage;
6 import jakarta.persistence.PersistenceContext;
7 import jakarta.persistence.EntityManager;
8 @MessageDriven(mappedName="jms/Queuex")
9 public class TestMDB{
10 @PersistenceContext(unitName="puMysql")
11 EntityManager em;
12
13 public void onMessage(Message inMessage) {
14 try{
15 String text = ( (TextMessage) inMessage).getText() ;
16 System.out.println( text );
17 MessageEntity me = new MessageEntity();
18 me.setMessage( text );
19 me.setCreationDate( new java.util.Date() );
20 em.persist(me);
21 }catch(Exception ex){
22 ex.printStackTrace();
23 }
24 }
25 }