Class Utils


  • public final class Utils
    extends Object
    Utility methods for JMS protocol. WARNING - the API for this class is likely to change!
    • Constructor Detail

      • Utils

        public Utils()
    • Method Detail

      • close

        public static void close​(MessageConsumer closeable,
                                 Logger log)
      • close

        public static void close​(Session closeable,
                                 Logger log)
      • close

        public static void close​(Connection closeable,
                                 Logger log)
      • close

        public static void close​(MessageProducer closeable,
                                 Logger log)
      • messageProperties

        public static String messageProperties​(Message msg)
      • lookupDestination

        public static Destination lookupDestination​(Context context,
                                                    String name)
                                             throws NamingException
        Method will lookup a given destination (topic/queue) using JNDI.
        Parameters:
        context - context to use for lookup
        name - the destination name
        Returns:
        the destination, never null
        Throws:
        NamingException - if the name cannot be found as a Destination
      • getFromEnvironment

        public static final String getFromEnvironment​(Context context,
                                                      String key)
                                               throws NamingException
        Get value from Context environment taking into account non fully compliant JNDI implementations
        Parameters:
        context - context to use
        key - key to lookup in contexts environment
        Returns:
        String or null if context.getEnvironment() is not compliant
        Throws:
        NamingException - if a naming problem occurs while getting the environment
      • getConnection

        public static Connection getConnection​(Context ctx,
                                               String factoryName)
                                        throws JMSException,
                                               NamingException
        Obtain the queue connection from the context and factory name.
        Parameters:
        ctx - context to use
        factoryName - name of the object factory to look up in context
        Returns:
        the queue connection
        Throws:
        JMSException - when creation of the connection fails
        NamingException - when lookup in context fails
      • addJMSProperties

        public static void addJMSProperties​(Message msg,
                                            Map<String,​Object> map)
                                     throws JMSException
        Set JMS Properties to msg
        Parameters:
        msg - Message to operate on
        map - Map of Properties to be set on the message
        Throws:
        JMSException - when msg throws a JMSException while the properties get set