{"id":1591,"date":"2010-05-05T12:19:38","date_gmt":"2010-05-05T17:19:38","guid":{"rendered":"http:\/\/jianmingli.com\/wp\/?p=1591"},"modified":"2010-08-03T11:33:24","modified_gmt":"2010-08-03T16:33:24","slug":"oracle-oc4j-aq-tutorial-myaqtest","status":"publish","type":"post","link":"https:\/\/jianmingli.com\/wp\/?p=1591","title":{"rendered":"Oracle OC4J AQ JMS Test"},"content":{"rendered":"

Overview<\/h2><\/span>\n

* Download how-to-connect-to-oemsjmsd.zip<\/a>
\n* Start JDev (10.1.3.3.0)
\n* Setup AQ
\n* Create Resource Adapter
\n* Create EAR and deploy EAR
\n* Test with a client<\/p>\n

Setup AQ<\/h2><\/span>\n

* Create MyAQUser.sql as follows:<\/p>\n

\r\nDROP USER MyAQUser CASCADE;\r\n\r\nGRANT connect, resource,AQ_ADMINISTRATOR_ROLE TO MyAQUser IDENTIFIED BY MyAQUserPass;\r\nGRANT execute ON sys.dbms_aqadm TO MyAQUser;\r\nGRANT execute ON sys.dbms_aq    TO MyAQUser;\r\nGRANT execute ON sys.dbms_aqin  TO MyAQUser;\r\nGRANT execute ON sys.dbms_aqjms TO MyAQUser;\r\n\r\nconnect MyAQUser\/MyAQUserPass;\r\n-- Create table to hold the queue, then create queue.\r\n-- For topics multiple_consumers must be true\r\nBEGIN\r\n   DBMS_AQADM.CREATE_QUEUE_TABLE(\r\n        Queue_table => 'QTab',\r\n        Queue_payload_type => 'SYS.AQ$_JMS_MESSAGE',\r\n        sort_list => 'PRIORITY,ENQ_TIME',\r\n        multiple_consumers => false,\r\n        compatible => '8.1.5');\r\n\r\n   DBMS_AQADM.CREATE_QUEUE(\r\n      Queue_name => 'MY_QUEUE',\r\n      Queue_table => 'QTab');\r\n\r\n   DBMS_AQADM.START_QUEUE(\r\n      queue_name => 'MY_QUEUE');\r\n\r\n   DBMS_AQADM.CREATE_QUEUE_TABLE(\r\n        Queue_table => 'TTab',\r\n        Queue_payload_type => 'SYS.AQ$_JMS_MESSAGE',\r\n        sort_list => 'PRIORITY,ENQ_TIME',\r\n        multiple_consumers => true,\r\n        compatible => '8.1.5');\r\n\r\n   DBMS_AQADM.CREATE_QUEUE(\r\n      Queue_name => 'MY_TOPIC',\r\n      Queue_table => 'TTab');\r\n\r\n   DBMS_AQADM.START_QUEUE(\r\n      queue_name => 'MY_TOPIC');\r\nEND;\r\n\/\r\n<\/pre>\n
* Connect sys as sysdba
\n* @MyAQUser.sql<\/p>\n
Resource Adapter<\/h2><\/span>\n
Overview<\/h3><\/span>\n
* Create an application called ‘MyAQTest’
\n* Create an empty project called ‘MyAQRA’
\n* Create ra.xml
\n* Create oc4j-ra.xml
\n* Rebuild all<\/p>\n
ra.xml<\/h3><\/span>\n
* Right click project:  New -> Deployment Profiles -> RAR File
\n* Deployment Profile Name: MyAQRA
\n* Replace ra.xml content with one from howto
\n* Globally replace:
\n‘OEMSJMSDRADisplayName’ with ‘My AQ JMS Resource Adapter’
\n‘OEMSJMSDReference’ with ‘MyAQJMSResourceProvider’
\n‘MY_QUEUE’ if a different queue name is used in ‘Setup AQ’ section.
\n‘MY_TOPIC’ if a different queue name is used in ‘Setup AQ’ section.<\/p>\n
oc4j-ra.xml<\/h3><\/span>\n
* Right click project: New -> Deployment Descriptor -> OC4J Deployment Descriptor Wizard -> oc4j-ra.xml
\n* Replace content with that of howto
\n* Globally replace:
\n‘OEMSJMSDRAInstanceName’ with ‘MyAQConnector’
\n‘OEMSJMSDRASubcontext’ with ‘MyAQJMSCtx’
\n‘OEMSJMSDReference’ with ‘MyAQJMSResourceProvider’<\/p>\n
EAR Project<\/h2><\/span>\n
Overview<\/h3><\/span>\n
* Create an empty project called ‘MyAQEAR’
\n* Create ‘data-sources.xml’
\n* Create ‘orion-application.xml’
\n* Create ‘oc4j-connectors.xml’
\n* Create a new Deployment Profile of EAR File type. Name it ‘MyAQEAR’<\/p>\n
data-sources.xml<\/h3><\/span>\n
* Right click project: New -> Deployment Descriptor -> OC4J Deployment Descriptor Wizard -> data-sources.xml
\n* Replace content with that of howto
\n* Move all proxy-interface elements inside connection-factory element.
\n* Globally replace:
\n‘MyChannelDemoDataSourcePool’ to ‘MyAQUserDSPool’
\n‘MyChannelDemoDataSource’ to ‘MyAQUserDS’
\n‘oemsjmsdthin’ to ‘MyAQUserDS’
\n‘MyChannelDemoUser’ to ‘MyAQUser’
\n‘MyChannelDemoPassword’ to ‘MyAQUserPass’
\n* Set url accordingly: ‘jdbc:oracle:thin:@localhost:1521:orcl’<\/p>\n
orion-application.xml<\/h3><\/span>\n
* Right click project: New -> Deployment Descriptor -> OC4J Deployment Descriptor Wizard -> orion-application.xml
\n* Replace content with that of howto
\n* Globally replace:
\n‘OEMSJMSDReference’ with ‘MyAQJMSResourceProvider’
\n‘MyChannelDemoDataSource’ to ‘MyAQUserDS’<\/p>\n
oc4j-connectors.xml<\/h3><\/span>\n
* Right click project: New -> Deployment Descriptor -> OC4J Deployment Descriptor Wizard -> oc4j-connectors.xml
\n* Replace content with that of howto
\n* Globally replace:
\n‘OEMSJMSDRAInstanceName’ with ‘MyAQConnector’
\n‘OEMSJMSDRASubcontext’ with ‘MyAQJMSCtx’
\n‘OEMSJMSDRADeploy’ to ‘MyAQRA’
\n‘OEMSJMSDReference’ with ‘MyAQJMSResourceProvider’
\n‘MY_QUEUE’ if a different queue name is used in ‘Setup AQ’ section.
\n‘MY_TOPIC’ if a different queue name is used in ‘Setup AQ’ section.<\/p>\n
Deployment Profile<\/h3><\/span>\n
* Click Rebuild All button
\n* Create a new Deployment Profile of EAR File type. Name it ‘MyAQJMSResourceAdatper’
\n* Select MyAQRA.deploy in Application Assembly screen.
\n* Create a new File Group named ‘FG1’ of Packaging type.
\n* click File Groups -> FG1 -> Filters
\n* Select ‘oc4j-connectors.xml’ only.<\/p>\n
Deploy EAR<\/h3><\/span>\n
* Right click MyAQJMSResourceAdatper.deploy
\n* Click Deploy to LocalApplicationServer<\/p>\n
Test Client<\/h2><\/span>\n
* Create a new Java Application Project called ‘MyAQJMSClient’
\n* Add to project class path
\nC:\\prog\\oracle\\product\\10.1.3.1\\OracleAS_1\\lib\\dms.jar
\nC:\\prog\\oracle\\product\\10.1.3.1\\OracleAS_1\\jdbc\\lib\\ojdbc14.jar
\nC:\\prog\\oracle\\product\\10.1.3.1\\OracleAS_1\\j2ee\\home\\jazn.jar
\nC:\\prog\\oracle\\product\\10.1.3.1\\OracleAS_1\\j2ee\\home\\oc4j.jar
\nC:\\prog\\oracle\\product\\10.1.3.1\\OracleAS_1\\j2ee\\home\\oc4jclient.jar
\nC:\\prog\\oracle\\product\\10.1.3.1\\OracleAS_1\\j2ee\\home\\lib\\adminclient.jar
\nC:\\prog\\oracle\\product\\10.1.3.1\\OracleAS_1\\j2ee\\home\\lib\\bcel.jar
\nC:\\prog\\oracle\\product\\10.1.3.1\\OracleAS_1\\j2ee\\home\\lib\\connector.jar
\nC:\\prog\\oracle\\product\\10.1.3.1\\OracleAS_1\\j2ee\\home\\lib\\javax77.jar
\nC:\\prog\\oracle\\product\\10.1.3.1\\OracleAS_1\\j2ee\\home\\lib\\jms.jar
\nC:\\prog\\oracle\\product\\10.1.3.1\\OracleAS_1\\j2ee\\home\\lib\\oc4j-internal.jar
\n* Create a new Java Class named ‘AbstractJMSClient’: New -> General -> Java Class<\/p>\n
\r\npackage myaqjmsclient;\r\n\r\nimport javax.jms.*;\r\nimport javax.naming.*;\r\n\r\npublic class AbstractJMSClient {\r\n    private static final String CONN_FACTORY =\r\n        \"java:comp\/env\/jms\/QueueConnectionFactory\";\r\n    private static final String HELLO_Q = \r\n        \"java:comp\/env\/jms\/helloQueue\";\r\n\r\n    private QueueConnectionFactory factory = null;\r\n\r\n    protected Queue getQueue() throws NamingException {\r\n        Context ctx = new InitialContext();\r\n        QueueConnectionFactory factory = getQueueConnectionFactory();\r\n        Queue q = (Queue) ctx.lookup(HELLO_Q);\r\n        return q;\r\n    }\r\n\r\n    protected QueueConnection getQueueConnection() throws NamingException,\r\n            JMSException {\r\n        return getQueueConnectionFactory().createQueueConnection();\r\n    }\r\n\r\n    private QueueConnectionFactory getQueueConnectionFactory()\r\n            throws NamingException {\r\n        Context ctx = new InitialContext();\r\n        factory = (QueueConnectionFactory) ctx.lookup(CONN_FACTORY);\r\n        return factory;\r\n    }\r\n}\r\n\r\n<\/pre>\n
* Create a new Java Class named ‘SendHelloAQ’: New -> General -> Java Class -> Extends ‘myaqjmsclient.AbstractJMSClient’ and check ‘Generate Main Method’<\/p>\n
\r\npackage myaqjmsclient;\r\n\r\nimport javax.jms.*;\r\nimport javax.naming.NamingException;\r\n\r\npublic class SendHelloAQ extends AbstractJMSClient {\r\n    public static void main(String[] args) throws Exception {\r\n        SendHelloAQ sendHelloAQ = new SendHelloAQ();\r\n        sendHelloAQ.send();\r\n    }\r\n\r\n    public void send() throws JMSException, NamingException {\r\n        Queue q = getQueue();\r\n        QueueConnection connection = getQueueConnection();\r\n        connection.start();\r\n        QueueSession session = connection.createQueueSession(false,\r\n                Session.AUTO_ACKNOWLEDGE);\r\n        QueueSender sender = session.createSender(q);\r\n        TextMessage msg = session.createTextMessage();\r\n        msg.setText(\"Hello AQ!\");\r\n        sender.send(msg);\r\n\r\n        sender.close();\r\n        session.close();\r\n        connection.close();\r\n\r\n        System.out.println(\"Message Sent\");\r\n    }\r\n}\r\n<\/pre>\n
* Create a new Java Class named ‘ReceiveHelloAQ’: New -> General -> Java Class -> Extends ‘myaqjmsclient.AbstractJMSClient’ and check ‘Generate Main Method’<\/p>\n
\r\npackage myaqjmsclient;\r\n\r\nimport javax.jms.*;\r\nimport javax.naming.NamingException;\r\n\r\npublic class ReceiveHelloAQ extends AbstractJMSClient {\r\n    public static void main(String[] args) throws Exception {\r\n        ReceiveHelloAQ receiveHelloAQ = new ReceiveHelloAQ();\r\n        receiveHelloAQ.receive();\r\n    }\r\n\r\n    public void receive() throws NamingException, JMSException {\r\n        Queue q = getQueue();\r\n        QueueConnection connection = getQueueConnection();\r\n        connection.start();\r\n        QueueSession session = connection.createQueueSession(false,\r\n                Session.AUTO_ACKNOWLEDGE);\r\n        QueueReceiver receiver = session.createReceiver(q);\r\n        TextMessage msg = (TextMessage)receiver.receiveNoWait();\r\n\r\n        if(msg != null)\r\n            System.out.println(\"Received: \" + msg.getText());\r\n        else\r\n            System.out.println(\"No message received\");\r\n\r\n        receiver.close();\r\n        session.close();\r\n        connection.close();\r\n    }\r\n}\r\n<\/pre>\n
* Create a new file named ‘jndi.properties’<\/p>\n
\r\njava.naming.factory.initial=com.evermind.server.ApplicationClientInitialContextFactory\r\njava.naming.provider.url=ormi:\/\/localhost:12401\/MyAQJMSResourceAdatper\r\n# Or use opmn:ormi for automatic port determination\r\n#java.naming.provider.url=opmn:ormi:\/\/localhost\/MyAQJMSResourceAdatper:home\r\njava.naming.security.principal=oc4jadmin\r\njava.naming.security.credentials=welcome1\r\n<\/pre>\n
* Create a new ‘application-client.xml’: New -> Deployment Profiles -> Client JAR File -> Profile Name: MyAQJMSClient<\/p>\n
\r\n\r\n\r\n    MyAQJMSClient-app-client<\/display-name>\r\n    \r\n        jms\/QueueConnectionFactory<\/res-ref-name>\r\n        javax.jms.QueueConnectionFactory<\/res-type>\r\n        Container<\/res-auth>\r\n        Shareable<\/res-sharing-scope>\r\n    <\/resource-ref>\r\n    \r\n        jms\/helloQueue<\/resource-env-ref-name>\r\n        javax.jms.Queue<\/resource-env-ref-type>\r\n    <\/resource-env-ref>\r\n<\/application-client>\r\n<\/pre>\n
* Create a new ‘orion-application-client.xml’: New -> Deployment Descriptors -> OC4J Deployment Descriptor Wizard -> orion-application-client.xml -> Version 10.0<\/p>\n
\r\n\r\n\r\n    \r\n    \r\n    \r\n    \r\n<\/orion-application-client>\r\n<\/pre>\n
* Run ‘SendHelloAQ.java’ to send a message.<\/p>\n
\r\nset ORA_AS_HOME=C:\\prog\\oracle\\product\\10.1.3.1\\OracleAS_1\r\nset JAVA_HOME=%ORA_AS_HOME%\\jdk\r\n\r\nset MY_CP=.;%ORA_AS_HOME%\\lib\\dms.jar;%ORA_AS_HOME%\\jdbc\\lib\\ojdbc14.jar;%ORA_AS_HOME%\\j2ee\\home\\jazn.jar;%ORA_AS_HOME%\\j2ee\\home\\oc4j.jar;%ORA_AS_HOME%\\j2ee\\home\\oc4jclient.jar;%ORA_AS_HOME%\\j2ee\\home\\lib\\adminclient.jar;%ORA_AS_HOME%\\j2ee\\home\\lib\\bcel.jar;%ORA_AS_HOME%\\j2ee\\home\\lib\\connector.jar;%ORA_AS_HOME%\\j2ee\\home\\lib\\javax77.jar;%ORA_AS_HOME%\\j2ee\\home\\lib\\jms.jar;%ORA_AS_HOME%\\j2ee\\home\\lib\\oc4j-internal.jar\r\n\r\n%JAVA_HOME%\/bin\/java -cp %MY_CP% myaqjmsclient.SendHelloAQ\r\n<\/pre>\n
* Run ‘ReceiveHelloAQ.java’ to receive a message.<\/p>\n
\r\nset ORA_AS_HOME=C:\\prog\\oracle\\product\\10.1.3.1\\OracleAS_1\r\nset JAVA_HOME=%ORA_AS_HOME%\\jdk\r\n\r\nset MY_CP=.;%ORA_AS_HOME%\\lib\\dms.jar;%ORA_AS_HOME%\\jdbc\\lib\\ojdbc14.jar;%ORA_AS_HOME%\\j2ee\\home\\jazn.jar;%ORA_AS_HOME%\\j2ee\\home\\oc4j.jar;%ORA_AS_HOME%\\j2ee\\home\\oc4jclient.jar;%ORA_AS_HOME%\\j2ee\\home\\lib\\adminclient.jar;%ORA_AS_HOME%\\j2ee\\home\\lib\\bcel.jar;%ORA_AS_HOME%\\j2ee\\home\\lib\\connector.jar;%ORA_AS_HOME%\\j2ee\\home\\lib\\javax77.jar;%ORA_AS_HOME%\\j2ee\\home\\lib\\jms.jar;%ORA_AS_HOME%\\j2ee\\home\\lib\\oc4j-internal.jar\r\n\r\n%JAVA_HOME%\/bin\/java -cp %MY_CP% myaqjmsclient.ReceiveHelloAQ\r\n<\/pre>\n
References<\/h2><\/span>\n
* http:\/\/blogs.oracle.com\/olaf\/2007\/07\/oc4j_configuring_and_using_aq.html<\/a>
\n* http:\/\/www.oracle.com\/technology\/tech\/java\/oc4j\/1013\/how_to\/how-to-connect-to-oemsjmsd\/doc\/how-to-connect-to-oemsjmsd.html<\/a>
\n* http:\/\/www.oracle.com\/technology\/tech\/java\/oc4j\/1013\/how_to\/index.html<\/a><\/p>\n
* http:\/\/mike-lehmann.blogspot.com\/2006\/09\/simple-mdb-with-oracle-database-jms.html<\/a><\/p>\n","protected":false},"excerpt":{"rendered":"
Overview * Download how-to-connect-to-oemsjmsd.zip * Start JDev (10.1.3.3.0) * Setup AQ * Create Resource Adapter * Create EAR and deploy EAR * Test with a client Setup AQ * Create MyAQUser.sql as follows: DROP USER MyAQUser CASCADE; GRANT connect, resource,AQ_ADMINISTRATOR_ROLE … Continue reading →<\/span><\/a><\/p>\n","protected":false},"author":2,"featured_media":0,"comment_status":"closed","ping_status":"closed","sticky":false,"template":"","format":"standard","meta":{"_exactmetrics_skip_tracking":false,"_exactmetrics_sitenote_active":false,"_exactmetrics_sitenote_note":"","_exactmetrics_sitenote_category":0,"jetpack_post_was_ever_published":false,"_jetpack_newsletter_access":"","_jetpack_dont_email_post_to_subs":false,"_jetpack_newsletter_tier_id":0,"_jetpack_memberships_contains_paywalled_content":false,"_jetpack_memberships_contains_paid_content":false,"footnotes":"","jetpack_publicize_message":"","jetpack_publicize_feature_enabled":true,"jetpack_social_post_already_shared":false,"jetpack_social_options":{"image_generator_settings":{"template":"highway","default_image_id":0,"font":"","enabled":false},"version":2}},"categories":[71,69],"tags":[582],"class_list":["post-1591","post","type-post","status-publish","format-standard","hentry","category-jms","category-oc4j","tag-jms"],"jetpack_publicize_connections":[],"jetpack_featured_media_url":"","jetpack_sharing_enabled":true,"jetpack_shortlink":"https:\/\/wp.me\/p8cRUO-pF","_links":{"self":[{"href":"https:\/\/jianmingli.com\/wp\/index.php?rest_route=\/wp\/v2\/posts\/1591","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/jianmingli.com\/wp\/index.php?rest_route=\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/jianmingli.com\/wp\/index.php?rest_route=\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/jianmingli.com\/wp\/index.php?rest_route=\/wp\/v2\/users\/2"}],"replies":[{"embeddable":true,"href":"https:\/\/jianmingli.com\/wp\/index.php?rest_route=%2Fwp%2Fv2%2Fcomments&post=1591"}],"version-history":[{"count":16,"href":"https:\/\/jianmingli.com\/wp\/index.php?rest_route=\/wp\/v2\/posts\/1591\/revisions"}],"predecessor-version":[{"id":1594,"href":"https:\/\/jianmingli.com\/wp\/index.php?rest_route=\/wp\/v2\/posts\/1591\/revisions\/1594"}],"wp:attachment":[{"href":"https:\/\/jianmingli.com\/wp\/index.php?rest_route=%2Fwp%2Fv2%2Fmedia&parent=1591"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/jianmingli.com\/wp\/index.php?rest_route=%2Fwp%2Fv2%2Fcategories&post=1591"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/jianmingli.com\/wp\/index.php?rest_route=%2Fwp%2Fv2%2Ftags&post=1591"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}