提交: 00db3ab17a4ba890862b9a70bacb87a5bf07d528 - moto_web_app (git)

moto web application

Commit MetaInfo

• 修訂: 00db3ab17a4ba890862b9a70bacb87a5bf07d528 (tree)
• 時間: 2014-01-22 19:17:38
• 作者: astoria-d <astoria-d@mail...>
• Commiter: astoria-d

Log Message

jms push integrated. still need to work due to the invalid instance scope

Change Summary

• modified: WEB-INF/classes/motoSample/ChatBean.java
• modified: WEB-INF/classes/motoSample/PushBean.java
• modified: WEB-INF/web.xml
• modified: build.xml
• modified: secured/chat.xhtml

差異

--- a/WEB-INF/classes/motoSample/ChatBean.java
+++ b/WEB-INF/classes/motoSample/ChatBean.java
@@ -179,7 +179,7 @@ public class ChatBean implements Serializable {
         catch (SQLException se) {
             log.severe("sql err!!!");
         }
-    
+        
     }
 
     public void loadOldMsg() {
@@ -235,6 +235,7 @@ public class ChatBean implements Serializable {
 
     @PostConstruct
     public void postInit() {
+        log.info("postInit");
         //log.info("PostConstruct userBean: " + userBean);
         //log.info("PostConstruct getFlights: " + userBean.getFlights());
         ArrayList<SelectItem> flights = userBean.getFlights();
@@ -252,6 +253,6 @@ public class ChatBean implements Serializable {
             }
         }
         
-        //log.info("PostConstruct: " + chatRoom);
     }
+
 }

--- a/WEB-INF/classes/motoSample/PushBean.java
+++ b/WEB-INF/classes/motoSample/PushBean.java
@@ -1,46 +1,162 @@
 package motoSample;
 
 import java.io.Serializable;
-import java.util.logging.Logger;
-import javax.inject.Inject;
-
 import javax.faces.bean.ManagedBean;
 import javax.faces.bean.RequestScoped;
+import javax.faces.bean.ManagedProperty;
+import javax.faces.context.FacesContext;
+import javax.faces.event.ActionEvent;
+
+import java.util.logging.Logger;
+import javax.inject.Inject;
+import javax.annotation.PostConstruct;
+import javax.annotation.PreDestroy;
 
 import org.richfaces.application.push.TopicKey;
 import org.richfaces.application.push.TopicsContext;
+import org.richfaces.application.push.MessageException;
+
+import javax.jms.MessageListener;
+import javax.jms.Message;
+import javax.jms.TextMessage;
+
+import javax.naming.Context;
+import javax.naming.InitialContext;
+import javax.naming.NamingException;
+
+import java.util.Properties;
+
+import javax.jms.TopicConnectionFactory;
+import javax.jms.TopicConnection;
+import javax.jms.Topic;
+import javax.jms.Session;
+import javax.jms.TopicSession;
+import javax.jms.TopicSubscriber;
+import javax.jms.TopicPublisher;
+import javax.jms.JMSException;
 
 
 @ManagedBean
 @RequestScoped
-public class PushBean implements Serializable {
+public class PushBean implements MessageListener, Serializable {
 
     @Inject
     private Logger log;
 
-    private String msg;
+    @Inject
+    private FacesContext context;
+
+    private static final String PUSH_JMS_TOPIC = "motoTest";
 
-    static int get_cnt = 0;
-    public String getMsg() {
-        msg = "msg: " + get_cnt++;
-        return msg;
+    private TopicConnectionFactory getTopicConnectionFactory() {
+        try {
+            return (TopicConnectionFactory) InitialContext.doLookup("java:/ConnectionFactory");
+        } catch (NamingException e) {
+            try {
+                return (TopicConnectionFactory) InitialContext.doLookup("ConnectionFactory");
+            } catch (NamingException e2) {
+                throw new IllegalStateException("Can't find registered ConnectionFactory");
+            }
+        }
+    }
+
+
+    private TopicConnection connection = null;
+    private TopicSession session = null;
+    private TopicPublisher publisher = null;
+    private TopicSubscriber subscriber = null;
+
+    @PostConstruct
+    public void initJms() throws JMSException, NamingException {
+
+        log.info("initJms");
+
+        if (connection == null) {
+            TopicConnectionFactory tcf = getTopicConnectionFactory();
+            connection = tcf.createTopicConnection();
+            log.info("connection ok.");
+        }
+        if (session == null) {
+            session = connection.createTopicSession(false, Session.AUTO_ACKNOWLEDGE);
+            log.info("session ok.");
+        }
+
+        Topic topic = InitialContext.doLookup("topic/" + PUSH_JMS_TOPIC);
+        log.info("topic ok.");
+        
+        if (publisher == null) {
+            publisher = session.createPublisher(topic);
+            log.info("publisher ok.");
+        }
+        if (subscriber== null) {
+            subscriber = session.createSubscriber(topic);
+            log.info("subscriber ok.");
+
+            // Set a JMS message listener
+            subscriber.setMessageListener(this);
+            log.info("lisntener bind ok.");
+        }
+        
+        // Start the JMS connection; allows messages to be delivered
+        connection.start( );
+        log.info("connection start ok.");
+        
     }
     
-    public void doPush() throws Exception {
-        log.info("push...");
-        try {
-            TopicKey topicKey = new TopicKey("motoTestTopic");
-            TopicsContext topicsContext = TopicsContext.lookup();
-
-            topicsContext.publish(topicKey, "empty message");
-        }
-        catch (Exception e) {
-            System.out.println(e.getMessage());
-            throw e;
-        }
+    public void doPush(ActionEvent event) throws MessageException, JMSException {
+        log.info("push: ");
         /*
+        TopicKey topicKey = new TopicKey(chatRoom);
+        TopicsContext topicsContext = TopicsContext.lookup();
+
+        topicsContext.publish(topicKey, "empty message");
         */
 
+        TextMessage message = session.createTextMessage();
+        message.setText("msgggggg");
+        publisher.publish(message);
+
+        //String uid = userBean.getUid();
+        //log.info("message ");
+        log.info("message published by " + this.hashCode());
     }
 
-}
\ No newline at end of file
+    public void onMessage(Message message) {
+        //String uid = userBean.getUid();
+        log.info("message received by " + this.hashCode());
+        
+    }
+
+    @PreDestroy
+    public void preDestroy() {
+        log.info("preDestroy");
+        if (publisher != null) {
+            try {
+                publisher.close();
+            } catch (JMSException e) {
+                log.severe("unable to close publisher");
+            }
+        }
+        if (subscriber != null) {
+            try {
+                subscriber.close();
+            } catch (JMSException e) {
+                log.severe("unable to close subscriber");
+            }
+        }
+        if (session != null) {
+            try {
+                session.close();
+            } catch (JMSException e) {
+                log.severe("unable to close session");
+            }
+        }
+        if (connection != null) {
+            try {
+                connection.close();
+            } catch (JMSException e) {
+                log.severe("unable to close connection");
+            }
+        }
+    }
+}

--- a/WEB-INF/web.xml
+++ b/WEB-INF/web.xml
@@ -50,7 +50,7 @@
         <param-value>true</param-value>
     </context-param>
     <context-param>
-        <param-name>org.richfaces.push.jms.disabled</param-name>
+        <param-name>org.richfaces.push.jms.enabled</param-name>
         <param-value>true</param-value>
     </context-param>
     <context-param> 

--- a/build.xml
+++ b/build.xml
@@ -26,6 +26,7 @@
  <property name="servlet" value="${env.JBOSS_HOME}\modules\javax\servlet\api\main\jboss-servlet-api_3.0_spec-1.0.0.Final.jar"/>
  <property name="cdi" value="${env.JBOSS_HOME}\modules\javax\enterprise\api\main\cdi-api-1.0-SP4.jar"/>
  <property name="richfaces" value="${lib}\richfaces-components-api-4.3.4.Final.jar:${lib}\richfaces-components-ui-4.3.4.Final.jar:${lib}\richfaces-core-api-4.3.4.Final.jar:${lib}\richfaces-core-impl-4.3.4.Final.jar"/>
+ <property name="jms" value="${env.JBOSS_HOME}\modules\javax\jms\api\main\jboss-jms-api_1.1_spec-1.0.0.Final.jar"/>
 
  <target name="clean">
    <!-- Delete our the ${build} and ${dist} directory trees -->
@@ -47,7 +48,7 @@
      srcdir="${javasrc}"
      destdir="${build}"
      debug="true"
-     classpath="${jsf}:${inject}:${servlet}:${cdi}:${richfaces}"/>
+     classpath="${jsf}:${inject}:${servlet}:${cdi}:${richfaces}:${jms}"/>
      
  </target>
 

--- a/secured/chat.xhtml
+++ b/secured/chat.xhtml
@@ -14,16 +14,9 @@
     		<h:form xmlns:a4j="http://richfaces.org/a4j"
     		    xmlns:rich="http://richfaces.org/rich">
 
-                <h:commandButton value="post" action="#{pushBean.doPush}" >
-                    <f:ajax />
-                </h:commandButton>
-
-                <a4j:push id="pushJms" address="motoTestTopic">
-                    <a4j:ajax event="dataavailable" render="pushRes" />
-                </a4j:push>
-
-                res: <h:outputText id="pushRes" value="#{pushBean.msg}"/>
-                <br />
+                <!-- a4j:push address="#{chatBean.chatRoom}">
+                    <a4j:ajax event="dataavailable" render="msgList" />
+                </a4j:push -->
 
                 chat room : 
                 <h:selectOneMenu id="charRoom" value="#{chatBean.chatRoom}" onchange="submit()" 
@@ -64,7 +57,7 @@
                     input text: <h:inputText id="msg" value="#{chatBean.msg}"/>
                 </h:panelGroup>
 
-                <h:commandButton value="post" action="#{chatBean.doPost}" >
+                <h:commandButton value="post" action="#{chatBean.doPost}" actionListener="#{pushBean.doPush}" >
                     <f:ajax execute="charRoom msg" render="chatTable" />
                 </h:commandButton>
     		</h:form>