## page was renamed from JEE = JEE = Java Platform, Enterprise Edition ||'''JEE version'''||'''Application Server'''|| ||JEE5 ||JBoss5 Glassfish2.1 || ||JEE6 || [[https://download.jboss.org/jbossas/7.1/jboss-as-7.1.1.Final/jboss-as-7.1.1.Final.zip|JBossAS7]] Wildfly7.1 Glassfish3.x JBossEAP6 || ||JEE7 ||Wildfly8 Glassfish4.x || ||JEE8 ||Wildfly14 Glassfish5.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. {{{#!highlight sh cd /tmp wget http://download.oracle.com/otn-pub/java/jdk/8u25-b17/jdk-8u25-linux-x64.tar.gz wget http://dlc.sun.com.edgesuite.net/glassfish/4.1/release/glassfish-4.1.zip unzip glassfish-4.1.zip tar xvzf jdk-8u25-linux-x64.tar.gz mv jdk1.8.0_25/ /usr/java mv glassfish4/ /opt/appsrv/ cd /usr/java/jdk1.8.0_25 chmod 555 * -R /usr/java/jdk1.8.0_25/bin/java -version cd /opt/appsrv/glassfish4/bin JAVA_HOME=/usr/java/jdk1.8.0_25 AS_JAVA=/usr/java/jdk1.8.0_25 asadmin start-domain # http://localhost:4848/ asadmin change-admin-password asadmin enable-secure-admin asadmin stop-domain asadmin start-domain }}} === Install Glassfish 4.1 on FreeBSD 10.3 === Uses MariaDB instead of MySQL. {{{#!highlight sh pkg install glassfish-4.1 # Add glassfish_enable="YES" in /etc/rc.conf. pkg install elinks elinks http://localhost:8080 cd /usr/local/glassfish-4.1/bin ./asadmin change-admin-password }}} {{{ 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. }}} {{{#!highlight sh /usr/local/etc/rc.d/glassfish restart pkg install mariadb101-server-10.1.14 # mariadb vi /etc/rc.conf # mysql_enable="YES" cd /usr/local/etc/rc.d ./mysql-server start mysql_secure_installation # set mysql root pass ... }}} {{{ 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 }}} {{{#!highlight sh cd /usr/local/glassfish-4.1/glassfish/domains/domain1/lib wget http://central.maven.org/maven2/org/mariadb/jdbc/mariadb-java-client/1.5.2/mariadb-java-client-1.5.2.jar # jms resources, destination resources # JNDI name: jms/Queuex # physical destination name: Queuex # JMS connection factory # type: javax.jms.ConnectionFactory # JNDI name: jms/ConnectionFactory # JDBC connection pool # Pool name: MariaDBPool # resource type: javax.sql.DataSource # Datasource class name: org.mariadb.jdbc.MariaDbDataSource # Connection Validation: Required # Validation method meta-data # user mysqljdbc # userName mysqljdbc # databaseName mysqljdbc # PortNumber 3306 # Password 12345678 # ServerName localhost # LoginTimeout 0 # JDBC resource # jndi name: jdbc/mysql # connection pool: MariaDBPool }}} == Docker Ubuntu image install Glassfish4.1 == {{{#!highlight sh docker pull ubuntu docker create --name containerx -p 1022:22 -p 1848:4848 -p 1080:8080 ubuntu docker start containerx docker exec -t -i containerx apt-get update apt-get install tzdata-java openjdk-7-jdk wget unzip java java -version apt-get install cd /tmp wget http://dlc.sun.com.edgesuite.net/glassfish/4.1/release/glassfish-4.1.zip unzip glassfish-4.1.zip mkdir -p /opt/appsrv mv glassfish4/ /opt/appsrv/ cd /opt/appsrv/glassfish4/ bin/asadmin start-domain bin/asadmin change-admin-password bin/asadmin enable-secure-admin bin/asadmin stop-domain bin/asadmin start-domain 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''' {{{#!highlight xml 4.0.0 org.allowed.bitarus ejbjee6 0.0.1 ejb javax javaee-api 6.0 provided }}} '''./src/main/resources/META-INF/ejb-jar.xml''' {{{#!highlight xml }}} '''./src/main/resources/META-INF/persistence.xml''' {{{#!highlight xml jdbc/mysql }}} '''./src/main/java/org/allowed/bitarus/Scheduler.java''' {{{#!highlight java package org.allowed.bitarus; import javax.ejb.Singleton; import javax.ejb.Schedule; import javax.ejb.ScheduleExpression; import javax.annotation.Resource; import javax.ejb.Timeout; import javax.ejb.TimerConfig; import javax.ejb.TimerService; import javax.ejb.Timer; import javax.annotation.PostConstruct; import javax.ejb.Startup; import javax.jms.ConnectionFactory; import javax.jms.Queue; import javax.jms.Connection; import javax.jms.Session; import javax.jms.MessageProducer; import javax.jms.TextMessage; @Singleton @Startup public class Scheduler { @Resource(mappedName="jms/ConnectionFactory") private ConnectionFactory connectionFactory; @Resource(mappedName="jms/Queuex") private Queue queue; @Resource private TimerService timerService; @PostConstruct private void postConstruct() { TimerConfig config = new TimerConfig("OneMinutePassed", false); ScheduleExpression se = new ScheduleExpression(); se.minute("*"); se.hour("*"); timerService.createCalendarTimer(se, config); } public String addSchedule(String second,String minute,String hour,String info){ TimerConfig config = new TimerConfig(info, false); ScheduleExpression se = new ScheduleExpression(); se.second(second); se.minute(minute); se.hour(hour); timerService.createCalendarTimer(se, config); return "Added " + info; } @Schedule(minute="*/5", hour="*") private void eachFiveMinutes(){ System.out.println("Called each five minute"); } @Timeout public void timeout(Timer timer) { if ("OneMinutePassed".equals(timer.getInfo())) { System.out.println("OneMinutePassed !!!"); /*for(Timer t : timerService.getTimers() ){ System.out.println(">>> "+ t.getInfo() ); }*/ }else{ System.out.println("!!! "+ timer.getInfo() ); // send jms message try{ Connection connection = connectionFactory.createConnection(); Session session = connection.createSession(false,Session.AUTO_ACKNOWLEDGE); MessageProducer mp = session.createProducer(queue); TextMessage message = session.createTextMessage(); message.setText( timer.getInfo().toString() ); mp.send(message); mp.close(); session.close(); connection.close(); }catch(Exception ex){ ex.printStackTrace(); } } } } }}} '''./src/main/java/org/allowed/bitarus/ScheduleRemote.java''' {{{#!highlight java package org.allowed.bitarus; import javax.ejb.Remote; @Remote public interface ScheduleRemote{ String addSchedule(String second,String minute,String hour,String info); } }}} '''./src/main/java/org/allowed/bitarus/ScheduleWS.java''' {{{#!highlight java package org.allowed.bitarus; import javax.ejb.Stateless; import javax.jws.WebMethod; import javax.jws.WebService; import javax.ejb.ScheduleExpression; import javax.annotation.Resource; import javax.ejb.TimerService; import javax.ejb.TimerConfig; import javax.ejb.EJB; @Stateless @WebService public class ScheduleWS implements ScheduleRemote{ @Resource private TimerService timerService; @EJB Scheduler sc; @WebMethod public String addSchedule(String second,String minute,String hour,String info){ return sc.addSchedule(second, minute, hour, info); } } }}} '''./src/main/java/org/allowed/bitarus/TestMDB.java''' {{{#!highlight java package org.allowed.bitarus; import javax.ejb.MessageDriven; import javax.jms.Message; import javax.jms.TextMessage; import javax.persistence.PersistenceContext; import javax.persistence.EntityManager; @MessageDriven(mappedName="jms/Queuex") public class TestMDB{ @PersistenceContext(unitName="puMysql") EntityManager em; public void onMessage(Message inMessage) { try{ String text = ( (TextMessage) inMessage).getText() ; System.out.println( text ); MessageEntity me = new MessageEntity(); me.setMessage( text ); me.setCreationDate( new java.util.Date() ); em.persist(me); }catch(Exception ex){ ex.printStackTrace(); } } } }}} '''./src/main/java/org/allowed/bitarus/MessageEntity.java''' {{{#!highlight java package org.allowed.bitarus; import java.util.Date; import javax.persistence.Id; import javax.persistence.Entity; import javax.persistence.Column; import javax.persistence.GeneratedValue; import javax.persistence.GenerationType; import javax.persistence.TemporalType; import javax.persistence.Temporal; @Entity public class MessageEntity{ @Id @GeneratedValue(strategy = GenerationType.IDENTITY) // @GeneratedValue(strategy = GenerationType.AUTO) // @OneToMany // @NamedQueries( { @NamedQuery(name="MessageEntity.byId",query="Select me From MessageEntity e where e.id = :id;") , @NamedQuery() } ) // JPQL Select me From MessageEntity e where e.id = :id; // Query q = em.createQuery("Select me From MessageEntity e where e.id = :id;"); // Query q = em.createNamedQuery("MessageEntity.byId"); // q.setParameter("id",12); // List res = q.getResultList (); private long id; @Column @Temporal(TemporalType.TIMESTAMP) private Date creationDate; @Column private String message; public long getId(){return this.id;} public void setId(long id){ this.id=id;} public Date getCreationDate(){return this.creationDate;} public void setCreationDate(Date creationDate){ this.creationDate=creationDate;} public String getMessage(){return this.message;} public void setMessage(String message){ this.message=message;} } }}} == Glassfish OpenMQ standalone client == '''Structure''' {{{ . |-- pom.xml |-- src | `-- main | `-- java | `-- org | `-- allowed | `-- bitarus | `-- JmsClient.java }}} '''pom.xml''' {{{#!highlight xml 4.0.0 org.allowed.bitarus jmsclient 0.0.1 jar org.glassfish.mq imq 5.1 maven-assembly-plugin 2.4 jar-with-dependencies org.allowed.bitarus.JmsClient make-assembly package single }}} ''' src/main/java/org/allowed/bitarus/JmsClient.java''' {{{#!highlight java package org.allowed.bitarus; import com.sun.messaging.ConnectionConfiguration; import com.sun.messaging.ConnectionFactory; import com.sun.messaging.Queue; import javax.jms.Connection; import javax.jms.JMSException; import javax.jms.Message; import javax.jms.MessageProducer; import javax.jms.Session; public class JmsClient { public static void main( String[] args ) { try{ ConnectionFactory connFactory = new ConnectionFactory(); connFactory.setProperty(ConnectionConfiguration.imqAddressList, "127.0.0.1:7676"); Queue q = new Queue("Queuex"); Connection connection = connFactory.createConnection(); System.out.println("After create connection"); Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE); MessageProducer producer = session.createProducer(q); Message message = session.createTextMessage("Bitarus test message"); producer.send(message); producer.close(); session.close(); connection.close(); System.out.println("After send message"); }catch(Exception ex){ ex.printStackTrace(); } System.out.println("End"); } } }}} === Check OpenMQ MessageQueue state === {{{#!highlight sh cd /opt/glassfish-3.1.2.2/mq/bin imqcmd list dst # input the admin user and pass }}} === Check used tcp ports by OpenMQ === {{{#!highlight sh nc openmqServer 7676 telnet openmqServer 7676 }}} 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 == [[ https://docs.oracle.com/cd/E19798-01/821-1841/bncer/index.html | JMS Message Selectors ]] Filter queue messages based on a JMS property value. [[ http://docs.oracle.com/javaee/6/api/javax/jms/Session.html#createConsumer(javax.jms.Destination, java.lang.String) | Session createConsumer ]] Creates a MessageConsumer for the specified destination, using a message selector. {{{#!highlight java // on the producer myMessage.setStringProperty("PropertyX", "teste"); // on the consumer to receive messages with the property PropertyX with value teste sessionx.createConsumer(queuex,"PropertyX='teste'"); }}} Message selector in a MessageDrivenBean {{{#!highlight java @MessageDriven(mappedName="jms/Queuex", activationConfig = { @ActivationConfigProperty(propertyName = "messageSelector",propertyValue = "PropertyX='teste'") }) }}} From [[http://docs.oracle.com/javaee/5/api/javax/jms/Message.html | 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.0.1 ==