simpletopicpublisher.java

Java开发的权限管理的例子

package org.artemis.right.jms.topic;
/*
*
* Copyright 2002 Sun Microsystems, Inc. All Rights Reserved.
* 
* Redistribution and use in source and binary forms, with or
* without modification, are permitted provided that the following
* conditions are met:
* 
* - Redistributions of source code must retain the above copyright
*   notice, this list of conditions and the following disclaimer.
* 
* - Redistribution in binary form must reproduce the above
*   copyright notice, this list of conditions and the following
*   disclaimer in the documentation and/or other materials
*   provided with the distribution.
* 
* Neither the name of Sun Microsystems, Inc. or the names of
* contributors may be used to endorse or promote products derived
* from this software without specific prior written permission.
* 
* This software is provided "AS IS," without a warranty of any
* kind. ALL EXPRESS OR IMPLIED CONDITIONS, REPRESENTATIONS AND
* WARRANTIES, INCLUDING ANY IMPLIED WARRANTY OF MERCHANTABILITY,
* FITNESS FOR A PARTICULAR PURPOSE OR NON-INFRINGEMENT, ARE HEREBY
* EXCLUDED. SUN AND ITS LICENSORS SHALL NOT BE LIABLE FOR ANY
* DAMAGES OR LIABILITIES SUFFERED BY LICENSEE AS A RESULT OF OR
* RELATING TO USE, MODIFICATION OR DISTRIBUTION OF THIS SOFTWARE OR
* ITS DERIVATIVES. IN NO EVENT WILL SUN OR ITS LICENSORS BE LIABLE
* FOR ANY LOST REVENUE, PROFIT OR DATA, OR FOR DIRECT, INDIRECT,
* SPECIAL, CONSEQUENTIAL, INCIDENTAL OR PUNITIVE DAMAGES, HOWEVER
* CAUSED AND REGARDLESS OF THE THEORY OF LIABILITY, ARISING OUT OF
* THE USE OF OR INABILITY TO USE THIS SOFTWARE, EVEN IF SUN HAS
* BEEN ADVISED OF THE POSSIBILITY OF SUCH DAMAGES.
* 
* You acknowledge that this software is not designed, licensed or
* intended for use in the design, construction, operation or
* maintenance of any nuclear facility.
* 
*/
/**
* The SimpleTopicPublisher class consists only of a main method,
* which publishes several messages to a topic.
* 
* Run this program in conjunction with SimpleTopicSubscriber.  
* Specify a topic name on the command line when you run the
* program.  By default, the program sends one message.  
* Specify a number after the topic name to send that number 
* of messages.
*/
import java.util.Hashtable;

import javax.jms.*;
import javax.naming.*;

public class SimpleTopicPublisher {

   /**
    * Main method.
    *
    * @param args     the topic used by the example and,
    *                 optionally, the number of messages to send
    */
   public static void main(String[] args) {
       String                  topicName = "jms/CommuTopic";
       Context                 jndiContext = null;
       TopicConnectionFactory  topicConnectionFactory = null;
       TopicConnection         topicConnection = null;
       TopicSession            topicSession = null;
       Topic                   topic = null;
       TopicPublisher          topicPublisher = null;
       TextMessage             message = null;
       final int               NUM_MSGS=3;
//     Defines the JNDI context factory.
         String JNDI_FACTORY="weblogic.jndi.WLInitialContextFactory";

//       Defines the JNDI provider url.
         String PROVIDER_URL=" t3://localhost:7001";

        
       
       /* 
        * Create a JNDI API InitialContext object if none exists
        * yet.
        */
       try {
    	   Hashtable env = new Hashtable();
           env.put(Context.INITIAL_CONTEXT_FACTORY, JNDI_FACTORY);
           env.put(Context.PROVIDER_URL, PROVIDER_URL);
           jndiContext= new InitialContext(env);
       } catch (NamingException e) {
           System.out.println("Could not create JNDI API " +
               "context: " + e.toString());
           e.printStackTrace();
           System.exit(1);
       }
       
       /* 
        * Look up connection factory and topic.  If either does
        * not exist, exit.
        */
       try {
           topicConnectionFactory = (TopicConnectionFactory)
               jndiContext.lookup("CommuConnectionReceverFactory");
           topic = (Topic) jndiContext.lookup(topicName);
       } catch (NamingException e) {
           System.out.println("JNDI API lookup failed: " +
               e.toString());
           e.printStackTrace();
           System.exit(1);
       }

       /*
        * Create connection.
        * Create session from connection; false means session is
        * not transacted.
        * Create publisher and text message.
        * Send messages, varying text slightly.
        * Finally, close connection.
        */
       try {
           topicConnection = 
               topicConnectionFactory.createTopicConnection();
           topicSession = 
               topicConnection.createTopicSession(false, 
                   Session.AUTO_ACKNOWLEDGE);
           topicPublisher = topicSession.createPublisher(topic);
           message = topicSession.createTextMessage();
           for (int i = 0; i < NUM_MSGS; i++) {
               message.setText("This is message " + (i + 1));
               System.out.println("Publishing message: " + 
                   message.getText());
               topicPublisher.publish(message);
           }
       } catch (JMSException e) {
           System.out.println("Exception occurred: " + 
               e.toString());
       } finally {
           if (topicConnection != null) {
               try {
                   topicConnection.close();
               } catch (JMSException e) {}
           }
       }
   }
}