constants.java

java开源的企业总线.xmlBlaster

   public final static String ONOVERFLOW_DISCARDOLDEST = "discardOldest";
   /** message queue onOverflow handling */
   public final static String ONOVERFLOW_EXCEPTION = "exception";

   /** If callback fails more often than is configured the login session is destroyed */
   public final static String ONEXHAUST_KILL_SESSION = "killSession";

   /** ClientProperty of QoS for messages from persistent store */
   public final static String PERSISTENCE_ID = "__persistenceId";

   /** Prefix to create a sessionId */
   public final static String SESSIONID_PREFIX = "sessionId:";
   public final static String SUBSCRIPTIONID_PREFIX = "__subId:";
   public final static String SUBSCRIPTIONID_PtP = SUBSCRIPTIONID_PREFIX+"PtP";
   /** If subscription ID is given by client, e.g. "__subId:client/joe/session/3-34"
     * see Requirement engine.qos.subscribe.id
     */
   //public final static String SUBSCRIPTIONID_CLIENT_PREFIX__XXXXXXX = "__subId:/node/";

   public final static String INTERNAL_LOGINNAME_PREFIX_FOR_PLUGINS = "_";
   public final static String INTERNAL_OID_PREFIX_FOR_PLUGINS = "_";
   public final static String INTERNAL_OID_ADMIN_CMD = "__cmd:";
   public final static String INTERNAL_LOGINNAME_PREFIX_FOR_CORE = "__";
   public final static String INTERNAL_OID_PREFIX_FOR_CORE = "__";
   public final static String INTERNAL_OID_PREFIX = "__sys__";  // Should be replaced by INTERNAL_OID_PREFIX_FOR_CORE in future
   public final static String INTERNAL_OID_CLUSTER_PREFIX = INTERNAL_OID_PREFIX + "cluster";  // "__sys__cluster"
   public final static String INTERNAL_OID_REMOTE_PROPERTIES = INTERNAL_OID_PREFIX + "remoteProperties"; // __sys__remoteProperties
   public final static String INTERNAL_OID_RUNLEVEL_MANAGER = INTERNAL_OID_PREFIX + "RunlevelManager"; // __sys__RunlevelManager

   public final static String EVENT_OID_LOGIN = "__sys__Login";
   public final static String EVENT_OID_LOGOUT = "__sys__Logout";
   public final static String EVENT_OID_USERLIST = "__sys__UserList";
   public final static String EVENT_OID_ERASEDTOPIC = "__sys__ErasedTopic";

   /** JDBC access messages */
   public final static String JDBC_OID = INTERNAL_OID_PREFIX + "jdbc";

   /** message queue onOverflow handling "__sys__deadMessage */
   public final static String OID_DEAD_LETTER = INTERNAL_OID_PREFIX + "deadMessage";

   /** Dead messages transport in their QoS clientProperty the original message key in '__key' */
   public final static String CLIENTPROPERTY_DEADMSGKEY = INTERNAL_OID_PREFIX_FOR_CORE + "key";
   /** Dead messages transport in their QoS clientProperty the original message QoS in '__qos' */
   public final static String CLIENTPROPERTY_DEADMSGQOS = INTERNAL_OID_PREFIX_FOR_CORE + "qos";
   /** Dead messages transport in their QoS clientProperty the rcvTimestamp in '__rcvTimestamp' */
   public final static String CLIENTPROPERTY_RCVTIMESTAMP = INTERNAL_OID_PREFIX_FOR_CORE + "rcvTimestamp";
   /** Dead messages transport in their QoS clientProperty the original message oid in '__oid' */
   public final static String CLIENTPROPERTY_OID = INTERNAL_OID_PREFIX_FOR_CORE + "oid";
   /** Dead messages transport in their QoS clientProperty the error reason in '__deadMessageReason' */
   public final static String CLIENTPROPERTY_DEADMSGREASON = INTERNAL_OID_PREFIX_FOR_CORE + "deadMessageReason";
   /** The plugin xml markup send to RunlevelManager '__plugin.xml' */
   public final static String CLIENTPROPERTY_PLUGIN_XML = INTERNAL_OID_PREFIX_FOR_CORE + "plugin.xml";
   /** The plugin xml markup send to RunlevelManager '__plugin.jarName' */
   public final static String CLIENTPROPERTY_PLUGIN_JARNAME = INTERNAL_OID_PREFIX_FOR_CORE + "plugin.jarName";

   /** ConnectReturnQos their QoS clientProperty the rcvTimestampStr in '__rcvTimestampStr' */
   public final static String CLIENTPROPERTY_RCVTIMESTAMPSTR = INTERNAL_OID_PREFIX_FOR_CORE + "rcvTimestampStr";

   /** For xml key attribute, contentMimeExtended="1.0" */
   public static final String DEFAULT_CONTENT_MIME_EXTENDED = "1.0";

   public static final String INDENT = " ";
   public static final String OFFSET = "\n" + INDENT;


   /** XmlKey queryType enum */
   public static final String OID_URL_PREFIX = "oid:";
   public static final String XPATH = "XPATH";
   public static final String XPATH_URL_PREFIX = "xpath:";
   public static final String EXACT = "EXACT";
   public static final String EXACT_URL_PREFIX = "exact:";
   public static final String DOMAIN = "DOMAIN";
   public static final String DOMAIN_URL_PREFIX = "domain:";
   public static final String SUBSCRIPTIONID_URL_PREFIX = "subscriptionId:";
   public static final String REGEX = "REGEX";

   public static final String TOXML_NOSECURITY = "noSecurity";
   public static final String TOXML_EXTRAOFFSET = "extraOffset";
   public static final String TOXML_FORCEREADABLE = "forceReadable";
   public static final String TOXML_ENCLOSINGTAG = "enclosingTag";
   public static final String TOXML_MAXCONTENTLEN = "maxContentLen";

   public static final String EVENTPLUGIN_PROP_SUMMARY = "_summary";
   public static final String EVENTPLUGIN_PROP_DESCRIPTION = "_description";
   public static final String EVENTPLUGIN_PROP_EVENTTYPE = "_eventType";
   public static final String EVENTPLUGIN_PROP_ERRORCODE = "_errorCode";
   public static final String EVENTPLUGIN_PROP_PUBSESSIONID = "_publicSessionId";
   public static final String EVENTPLUGIN_PROP_SUBJECTID = "_subjectId";
   public static final String EVENTPLUGIN_PROP_ABSOLUTENAME = "_absoluteName";
   public static final String EVENTPLUGIN_PROP_NODEID = "_nodeId";

   /** Stuff used for Streaming */

   /** This is the key of a client property telling the number of
    * this chunk in the sequence. The value itself is a long.
    */
   // public final static String CHUNK_SEQ_NUM = "__CHUNK_SEQ_NUM";
   // public final static String CHUNK_SEQ_NUM = XBConnectionMetaData.JMSX_GROUP_SEQ;

   /** If this exists it is always set to boolean 'true' */
   // public final static String CHUNK_EOF = "__CHUNK_EOF";
   // public final static String CHUNK_EOF = XBConnectionMetaData.JMSX_GROUP_EOF;

   /** If set, an exception occured in this chunk. It contains the
    * exception. It is used to perform clean up in case of exceptions.
    */
   // public final static String CHUNK_EXCEPTION = "__CHUNK_EXCEPTION";
   // public final static String CHUNK_EXCEPTION = XBConnectionMetaData.JMSX_GROUP_EX;

   /** This is the same for all chunks in a message. It shall be a
    * globally unique Identifier. */
   // public final static String STREAM_ID = "__STREAM_ID";
   // public final static String STREAM_ID = XBConnectionMetaData.JMSX_GROUP_ID;

   public final static String JMS_PREFIX = "__jms:";

   public final static String JMS_REPLY_TO = "__jms:JMSReplyTo";

   public final static String UPDATE_BULK_ACK = "__updateBulkAck";

   /** Mimetypes */
   // see @apache/mime.conf or so

   /**
    * Hypertext Markup Language
    */
   public final static String MIME_HTML = "text/html";

   /**
    * Cascading Style Sheet
    */
   public final static String MIME_CSS = "text/css";

   /**
    * Javascript
    */
   public final static String MIME_JS = "text/javascript";

   /**
    * The mime type for the xml.
    * See http://www.rfc-editor.org/rfc/rfc3023.txt
    */
   public final static String MIME_XML = "text/xml";

   /**
    * Joint Photographic Experts Group
    */
   public final static String MIME_JPG = "image/jpeg";

   /**
    * Portable Network Graphics Format Image
    */
   public final static String MIME_PNG = "image/png";

   /**
    * GIF Image
    */
   public final static String MIME_GIF = "image/gif";

   /**
    * Adds to the key a prefix JMS_PREFIX if and only if the key is one of the JMSX properties
    * defined by the XmlBlaster. It does not add anything if it already starts with JMS_PREFIX.
    *
    * @param key
    * @param log
    * @return
    */
   public static String addJmsPrefix(String key, Logger log) {
      if (key.startsWith(JMS_PREFIX)) {
         log.fine("JMS Property '" + key + "' is already starting with '" + JMS_PREFIX + "'");
         return key;
      }
      if (XBConnectionMetaData.getReservedProps().contains(key) || XBConnectionMetaData.getStandardProps().contains(key))
         key = JMS_PREFIX + key;
      return key;
   }



}