国产一级a片免费看高清,亚洲熟女中文字幕在线视频,黄三级高清在线播放,免费黄色视频在线看

1 : 下載JBOSS ESB

http://www.jboss.org/jbossesb/downloads.html

本例使用版本4.7

2:安裝Eclipse JBOSS plugin

http://download.jboss.org/jbosstools/updates/nightly/trunk/

help-->install new soft-->新增一個(gè) location輸入上面地址

有許多插件，只需選擇JBoss AS Tools plugin和JBoss ESB Tools plugin

3: 在Eclipse里新建一個(gè)ESB項(xiàng)目:

安裝好插件后點(diǎn)新建一個(gè)ESB項(xiàng)目 "New-->ESB-->ESB Project".

服務(wù)器可以選擇JBOSS 或者ESB Server

Step 4:創(chuàng)建ESB project
首先在esbcontent/META-INF 下新建一個(gè)配置文件: jboss-esb.xml
輸入如下內(nèi)容

Xml代碼

1. <?xml version = "1.0" encoding = "UTF-8"?>  
2. <jbossesb xmlns="http://anonsvn.labs.jboss.com/labs/jbossesb/trunk/product/etc/schemas/xml/jbossesb-1.2.0.xsd"  
3.  xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://anonsvn.labs.jboss.com/labs/jbossesb/trunk/product/etc/schemas/xml/jbossesb-1.2.0.xsd http://anonsvn.jboss.org/repos/labs/labs/jbossesb/trunk/product/etc/schemas/xml/jbossesb-1.2.0.xsd"  
4.  parameterReloadSecs="5">  
5.  <providers>     
6.           <jms-provider name="JBossMQ" connection-factory="ConnectionFactory">     
7.               <jms-bus busid="quickstartGwChannel">     
8.                   <jms-message-filter     
9.                       dest-type="QUEUE"     
10.                       dest-name="queue/quickstart_helloworld_Request_gw" />     
11.               </jms-bus>     
12.               <jms-bus busid="quickstartEsbChannel">     
13.                   <jms-message-filter     
14.                       dest-type="QUEUE"     
15.                       dest-name="queue/quickstart_helloworld_Request_esb"  />     
16.               </jms-bus>     
17.      
18.           </jms-provider>     
19.       </providers>     
20.             
21.       <services>     
22.         <service       
23.             category="FirstServiceESB"       
24.             name="SimpleListener"       
25.             description="Hello World">     
26.             <listeners>     
27.                 <jms-listener name="JMS-Gateway"     
28.                     busidref="quickstartGwChannel"     
29.                     is-gateway="true"/>     
30.                 <jms-listener name="helloWorld"     
31.                               busidref="quickstartEsbChannel" />     
32.             </listeners>     
33.             <actions mep="OneWay">     
34.                    <action name="action1"       
35.                     class="org.jboss.soa.esb.samples.quickstart.helloworld.MyJMSListenerAction"       
36.                     process="displayMessage"/>     
37.             </actions>          
38.         </service>     
39.       </services>     
40.     
41.  </jbossesb>  

<?xml version = "1.0" encoding = "UTF-8"?><jbossesb xmlns="http://anonsvn.labs.jboss.com/labs/jbossesb/trunk/product/etc/schemas/xml/jbossesb-1.2.0.xsd"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://anonsvn.labs.jboss.com/labs/jbossesb/trunk/product/etc/schemas/xml/jbossesb-1.2.0.xsd http://anonsvn.jboss.org/repos/labs/labs/jbossesb/trunk/product/etc/schemas/xml/jbossesb-1.2.0.xsd"parameterReloadSecs="5"><providers><jms-provider name="JBossMQ" connection-factory="ConnectionFactory"><jms-bus busid="quickstartGwChannel"><jms-message-filterdest-type="QUEUE"dest-name="queue/quickstart_helloworld_Request_gw" /></jms-bus><jms-bus busid="quickstartEsbChannel"><jms-message-filterdest-type="QUEUE"dest-name="queue/quickstart_helloworld_Request_esb"  /></jms-bus></jms-provider></providers><services><servicecategory="FirstServiceESB"name="SimpleListener"description="Hello World"><listeners><jms-listener name="JMS-Gateway"busidref="quickstartGwChannel"is-gateway="true"/><jms-listener name="helloWorld"busidref="quickstartEsbChannel" /></listeners><actions mep="OneWay"><action name="action1"class="org.jboss.soa.esb.samples.quickstart.helloworld.MyJMSListenerAction"process="displayMessage"/></actions></service></services></jbossesb>

 <actions mep="OneWay"> 
                   <action name="action1"   
                    class="org.jboss.soa.esb.samples.quickstart.helloworld.MyJMSListenerAction"   
                    process="displayMessage"/> 
這個(gè)類(lèi)根據(jù)自己實(shí)際路徑修改

新建MyJMSListenerAction 類(lèi)

Java代碼

1. package org.jboss.soa.esb.samples.quickstart.helloworld;   
2.   
3. import org.jboss.soa.esb.actions.AbstractActionLifecycle;   
4. import org.jboss.soa.esb.helpers.ConfigTree;   
5. import org.jboss.soa.esb.message.Message;   
6.   
7. public class MyJMSListenerAction extends AbstractActionLifecycle{   
8.     protected ConfigTree  _config;      
9.        
10.       public MyJMSListenerAction(ConfigTree config) {       
11.        _config = config;       
12.       }       
13.          
14.       public Message displayMessage(Message message) throws Exception{      
15.                   
16.        System.out.println("Body: " +message.getBody().get());             
17.        return message;       
18.                           
19.       }      
20.   
21. }  

package org.jboss.soa.esb.samples.quickstart.helloworld;import org.jboss.soa.esb.actions.AbstractActionLifecycle;import org.jboss.soa.esb.helpers.ConfigTree;import org.jboss.soa.esb.message.Message;public class MyJMSListenerAction extends AbstractActionLifecycle{protected ConfigTree  _config;public MyJMSListenerAction(ConfigTree config) {_config = config;}public Message displayMessage(Message message) throws Exception{System.out.println("Body: " +message.getBody().get());return message;}}

在esbcontent目錄下新建: jbm-queue-service.xml .

Xml代碼

1. <?xml version="1.0" encoding="UTF-8"?>  
2. <server>  
3.   <mbean code="org.jboss.jms.server.destination.QueueService"  
4.     name="jboss.esb.quickstart.destination:service=Queue,name=quickstart_helloworld_Request_esb"  
5.     xmbean-dd="xmdesc/Queue-xmbean.xml">  
6.     <depends optional-attribute-name="ServerPeer">jboss.messaging:service=ServerPeer</depends>  
7.     <depends>jboss.messaging:service=PostOffice</depends>  
8.   </mbean>  
9.   <mbean code="org.jboss.jms.server.destination.QueueService"  
10.     name="jboss.esb.quickstart.destination:service=Queue,name=quickstart_helloworld_Request_gw"  
11.     xmbean-dd="xmdesc/Queue-xmbean.xml">  
12.     <depends optional-attribute-name="ServerPeer">jboss.messaging:service=ServerPeer</depends>  
13.     <depends>jboss.messaging:service=PostOffice</depends>  
14.   </mbean>  
15. </server>  

<?xml version="1.0" encoding="UTF-8"?><server><mbean code="org.jboss.jms.server.destination.QueueService"name="jboss.esb.quickstart.destination:service=Queue,name=quickstart_helloworld_Request_esb"xmbean-dd="xmdesc/Queue-xmbean.xml"><depends optional-attribute-name="ServerPeer">jboss.messaging:service=ServerPeer</depends><depends>jboss.messaging:service=PostOffice</depends></mbean><mbean code="org.jboss.jms.server.destination.QueueService"name="jboss.esb.quickstart.destination:service=Queue,name=quickstart_helloworld_Request_gw"xmbean-dd="xmdesc/Queue-xmbean.xml"><depends optional-attribute-name="ServerPeer">jboss.messaging:service=ServerPeer</depends><depends>jboss.messaging:service=PostOffice</depends></mbean></server>

最后新建 esb 部署文件 deployment.xml 在 META-INF 文件夾下:

Xml代碼

1. <jbossesb-deployment>     
2. <depends>jboss.esb.quickstart.destination:service=Queue,name=quickstart_helloworld_Request_esb</depends>       
3.   <depends>jboss.esb.quickstart.destination:service=Queue,name=quickstart_helloworld_Request_gw</depends>     
4. </jbossesb-deployment>  

<jbossesb-deployment><depends>jboss.esb.quickstart.destination:service=Queue,name=quickstart_helloworld_Request_esb</depends><depends>jboss.esb.quickstart.destination:service=Queue,name=quickstart_helloworld_Request_gw</depends></jbossesb-deployment>

發(fā)布工程到j(luò)boss服務(wù)器，并啟動(dòng)服務(wù)器

建立一個(gè)測(cè)試Client

Java代碼

1. package org.jboss.soa.esb.samples.quickstart.helloworld.test;   
2.   
3. import java.util.Properties;   
4.   
5. import javax.jms.JMSException;   
6. import javax.jms.ObjectMessage;   
7. import javax.jms.Queue;   
8. import javax.jms.QueueConnection;   
9. import javax.jms.QueueConnectionFactory;   
10. import javax.jms.QueueSender;   
11. import javax.jms.QueueSession;   
12. import javax.naming.Context;   
13. import javax.naming.InitialContext;   
14. import javax.naming.NamingException;   
15.   
16. public class SendJMSMessage {   
17.     QueueConnection conn;      
18.     QueueSession session;      
19.     Queue que;      
20.           
21.           
22.     public void setupConnection() throws JMSException, NamingException      
23.     {      
24.         Properties properties1 = new Properties();      
25.         properties1.put(Context.INITIAL_CONTEXT_FACTORY,      
26.                 "org.jnp.interfaces.NamingContextFactory");      
27.         properties1.put(Context.URL_PKG_PREFIXES,      
28.                 "org.jboss.naming:org.jnp.interfaces");      
29.         properties1.put(Context.PROVIDER_URL, "jnp://127.0.0.1:1099");      
30.         InitialContext iniCtx = new InitialContext(properties1);      
31.      
32.         Object tmp = iniCtx.lookup("ConnectionFactory");      
33.         QueueConnectionFactory qcf = (QueueConnectionFactory) tmp;      
34.         conn = qcf.createQueueConnection();      
35.         que = (Queue) iniCtx.lookup("queue/quickstart_helloworld_Request_gw");      
36.         session = conn.createQueueSession(false, QueueSession.AUTO_ACKNOWLEDGE);      
37.         conn.start();      
38.         System.out.println("Connection Started");      
39.     }      
40.           
41.     public void stop() throws JMSException       
42.     {       
43.         conn.stop();      
44.         session.close();      
45.         conn.close();      
46.     }      
47.           
48.     public void sendAMessage(String msg) throws JMSException {      
49.               
50.         QueueSender send = session.createSender(que);              
51.         ObjectMessage tm = session.createObjectMessage(msg);      
52.               
53.         send.send(tm);              
54.         send.close();      
55.     }      
56.              
57.           
58.     public static void main(String args[]) throws Exception      
59.     {                         
60.         SendJMSMessage sm = new SendJMSMessage();      
61.         sm.setupConnection();      
62.         sm.sendAMessage("Hello World");//這里輸入消息文本       
63.         sm.stop();       
64.     }      
65. }  

package org.jboss.soa.esb.samples.quickstart.helloworld.test;import java.util.Properties;import javax.jms.JMSException;import javax.jms.ObjectMessage;import javax.jms.Queue;import javax.jms.QueueConnection;import javax.jms.QueueConnectionFactory;import javax.jms.QueueSender;import javax.jms.QueueSession;import javax.naming.Context;import javax.naming.InitialContext;import javax.naming.NamingException;public class SendJMSMessage {QueueConnection conn;QueueSession session;Queue que;public void setupConnection() throws JMSException, NamingException{Properties properties1 = new Properties();properties1.put(Context.INITIAL_CONTEXT_FACTORY,"org.jnp.interfaces.NamingContextFactory");properties1.put(Context.URL_PKG_PREFIXES,"org.jboss.naming:org.jnp.interfaces");properties1.put(Context.PROVIDER_URL, "jnp://127.0.0.1:1099");InitialContext iniCtx = new InitialContext(properties1);Object tmp = iniCtx.lookup("ConnectionFactory");QueueConnectionFactory qcf = (QueueConnectionFactory) tmp;conn = qcf.createQueueConnection();que = (Queue) iniCtx.lookup("queue/quickstart_helloworld_Request_gw");session = conn.createQueueSession(false, QueueSession.AUTO_ACKNOWLEDGE);conn.start();System.out.println("Connection Started");}public void stop() throws JMSException{conn.stop();session.close();conn.close();}public void sendAMessage(String msg) throws JMSException {QueueSender send = session.createSender(que);ObjectMessage tm = session.createObjectMessage(msg);send.send(tm);send.close();}public static void main(String args[]) throws Exception{SendJMSMessage sm = new SendJMSMessage();sm.setupConnection();sm.sendAMessage("Hello World");//這里輸入消息文本sm.stop();}}

運(yùn)行客戶(hù)端,會(huì)在服務(wù)器端看到

14:30:30,046 INFO  [STDOUT] Body: Hello World