Inspiration... just a few words and

Just a few words and new feature will be born, nice ideas always find the support www.inspire-software.com/en/index/view/open-source-GeDA-generic-DTO-assembler-dto-entity-auto-binding.html

OMG What is the best comment in source code you have ever encountered?

Nothing to say just http://stackoverflow.com/questions/184618?page=1&tab=votes#tab-top
ROFL

Hornetq JMS integration with Tomcat. Spring configuration. Part 2 of 2

In second part i want to show spring configuration, that allow to use hornetq from spring beans via well know spring JmsTemplate.

    <bean name="mbeanServer" 
          class="java.lang.management.ManagementFactory" 
          factory-method="getPlatformMBeanServer"/>

    <bean name="hornetQSecurityManagerImpl" 
          class="org.hornetq.spi.core.security.HornetQSecurityManagerImpl"/>

    <bean name="fileConfiguration" 
          class="org.hornetq.core.config.impl.FileConfiguration" 
          init-method="start" 
          destroy-method="stop"/> 

    <bean name="hornetQServerImpl" 
          class="org.hornetq.core.server.impl.HornetQServerImpl">
        <constructor-arg ref="fileConfiguration"/>
        <constructor-arg ref="mbeanServer"/>
        <constructor-arg ref="hornetQSecurityManagerImpl"/>
    </bean>

    <bean name="jmsServerManagerImpl" 
          class="org.hornetq.jms.server.impl.JMSServerManagerImpl" 
          init-method="start" 
          destroy-method="stop"> 
        <constructor-arg ref="hornetQServerImpl"/>
    </bean>

    <bean id="inVmConnectionFactory" 
          class="org.hornetq.jms.client.HornetQConnectionFactory">
        <constructor-arg ref="inVmTransportConfiguration"/>
    </bean>

    <bean id="inVmTransportConfiguration" 
          class="org.hornetq.api.core.TransportConfiguration">
        <constructor-arg index="0" value="org.hornetq.core.remoting.impl.invm.InVMConnectorFactory"/>
    </bean>

    <bean id="jndiTemplate" class="org.springframework.jndi.JndiTemplate">
        <property name="environment">
            <props>
                <prop key="java.naming.factory.initial">org.apache.naming.java.javaURLContextFactory</prop>
                <prop key="java.naming.factory.url.pkgs">org.apache.naming</prop>
            </props>
        </property>
    </bean>

    <bean id="jmsQueueConnectionFactory" class="org.springframework.jndi.JndiObjectFactoryBean">
        <property name="jndiTemplate" ref="jndiTemplate"/>
        <property name="jndiName" value="HQConnectionFactory"/>
    </bean>


    <bean id="customerRegistrationQueue" class="org.springframework.jndi.JndiObjectFactoryBean">
        <property name="jndiTemplate" ref="jndiTemplate"/>
        <property name="jndiName" value="queue/CustomerRegistrationQueue"/>
    </bean>
    <bean id="customerRegistrationJMSTemplate" class="org.springframework.jms.core.JmsTemplate">
        <property name="connectionFactory" ref="jmsQueueConnectionFactory"/>
        <property name="defaultDestination" ref="customerRegistrationQueue"/>
    </bean>

Configured JmsTemplate can be use in your spring bean. Actually i use jms notification in several system aspects. It allow to have fully decoupled system parts.

My base aspect class is following:

/** 
 * 
 * Base class for notification aspects. 
 * 
 */ 
public class BaseNotificationAspect {

    private final JmsTemplate jmsTemplate;

    /** 
     * Construct base notification aspect class. 
     * @param jmsTemplate jms teplate to use 
     */ 
    public BaseNotificationAspect(final JmsTemplate jmsTemplate) {
        this.jmsTemplate = jmsTemplate; 
    } 

    /** 
     * Send registration notification. 
     * @param serializableMessage  object to send 
     */ 
    protected void sendNotification(final Serializable serializableMessage) {
        if (jmsTemplate != null) {
            jmsTemplate.send(new MessageCreator() { 
                public Message createMessage(final Session session) throws JMSException {
                    return session.createObjectMessage(serializableMessage);
                } 
            }); 
        } 
    } 
}

And derived class has following description as sprind bean:

    <bean id="customerRegistrationAspect" class="com.some.product.name.service.domain.aspect.impl.CustomerRegistrationAspect">
        <constructor-arg index="0" ref="customerRegistrationJMSTemplate"/>
    </bean>

Hornetq JMS integration with Tomcat. Configure jms provider. Part 1 of 2

How to integrate hornetq jms provider with tomcat and apache/tomcat JNDI service.

If you are here, so you realy need to have ability to process some event in asynchronous fashion in your web application on tomcat or other lightweight web server. I dont want to use dedicated jms service , so i need in JVM communications only.

First of all lets check hornetq and tomcat jndi server jar dependency:

 
  <dependency> 
    <groupId>tomcat</groupId> 
    <artifactId>naming-factory</artifactId> 
    <version>5.5.23</version> 
    <scope>test</scope> 
  </dependency> 
  <dependency> 
    <groupId>tomcat</groupId> 
    <artifactId>naming-resources</artifactId> 
    <version>5.5.23</version> 
    <scope>test</scope> 
  </dependency> 
  <dependency> 
     <groupId>org.hornetq</groupId> 
     <artifactId>hornetq-core</artifactId> 
     <version>2.0.0.GA</version> 
     <scope>compile</scope> 
  </dependency> 
  <dependency> 
     <groupId>org.hornetq</groupId> 
     <artifactId>hornetq-jms</artifactId> 
     <version>2.0.0.GA</version> 
     <scope>compile</scope> 
  </dependency> 
  <dependency> 
     <groupId>org.hornetq</groupId> 
     <artifactId>hornetq-logging</artifactId> 
     <version>2.0.0.GA</version> 
     <scope>compile</scope> 
  </dependency> 
  <dependency> 
     <groupId>org.hornetq</groupId> 
     <artifactId>hornetq-transports</artifactId> 
     <version>2.0.0.GA</version> 
     <scope>compile</scope> 
  </dependency> 
  <dependency> 
     <groupId>org.jboss.netty</groupId> 
     <artifactId>netty</artifactId> 
     <version>3.1.0.GA</version> 
  </dependency> 
  <dependency> 
     <groupId>org.jboss.javaee</groupId> 
     <artifactId>jboss-jms-api</artifactId> 
     <version>1.1.0.GA</version> 
     <scope>compile</scope> 
  </dependency> 

As you can see there is no dependency from jboss jnpserver, because im gonne to use tomcat JNDI service.

Configuration in jndi.properties

java.naming.factory.initial=org.apache.naming.java.javaURLContextFactory 
java.naming.factory.url.pkgs=org.apache.naming 

#java.naming.factory.initial=org.jnp.interfaces.NamingContextFactory 
#java.naming.factory.url.pkgs=org.jboss.naming:org.jnp.interfaces 
#java.naming.provider.url=jnp://localhost:1099 

My hornetq-jms.xml is following:

<?xml version="1.0" encoding="UTF-8"?>  
<configuration xmlns="urn:hornetq" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"     
    xsi:schemaLocation="urn:hornetq /schema/hornetq-jms.xsd">  
    <connection-factory name="InVMConnectionFactory">
      <connectors>
         <connector-ref connector-name="in-vm"/>  
      </connectors>
      <entries> 
          <entry name="/HQConnectionFactory"/>
      </entries>
   </connection-factory>  
   <queue name="DLQ"><entry name="/queue/DLQ"/></queue>
   <queue name="ExpiryQueue"><entry name="/queue/ExpiryQueue"/>
   </queue><queue name="CustomerRegistrationQueue"><entry name="/queue/CustomerRegistrationQueue"/></queue>
</configuration>

Only in JVM connection factory is used and it binded to read/write JNDI context with HQConnectionFactory name.
At this point some can say, that context in tomcat is read only, but if you are have the brain you can perform small investigation and found, that you can bind to jndi context in tomcat, but not in java:/ context. For more information check the method checkWritable in org.apache.naming.NamingContext. If you ac try to use java:/ConnectionFactory name you will get the "javax.naming.NamingException: Context is read only".



File hornetq-configuration.xml

<configuration xmlns="urn:hornetq"
               xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" 
               xsi:schemaLocation="urn:hornetq /schema/hornetq-configuration.xsd"> 

   <connectors>
       <connector name="in-vm"> 
         <factory-class>org.hornetq.core.remoting.impl.invm.InVMConnectorFactory</factory-class> 
      </connector>
   </connectors>

   <acceptors>
       <acceptor name="in-vm"> 
         <factory-class>org.hornetq.core.remoting.impl.invm.InVMAcceptorFactory</factory-class> 
         <param key="server-id" value="0"/>         
      </acceptor>
   </acceptors>

   <security-settings> 
      <security-setting match="#">
          <permission type="createDurableQueue" roles="guest"/>
          <permission type="deleteDurableQueue" roles="guest"/>
          <permission type="createTempQueue" roles="guest"/>
          <permission type="deleteTempQueue" roles="guest"/>
          <permission type="send" roles="guest"/>
          <permission type="consume" roles="guest"/>
          <permission type="manage" roles="guest"/>
      </security-setting> 
   </security-settings> 

   <address-settings> 
      <!--default for catch all--> 
      <address-setting match="#">
         <dead-letter-address>jms.queue.DLQ</dead-letter-address> 
         <expiry-address>jms.queue.ExpiryQueue</expiry-address> 
         <redelivery-delay>0</redelivery-delay> 
         <max-size-bytes>-1</max-size-bytes> 
         <page-size-bytes>10485760</page-size-bytes> 
         <message-counter-history-day-limit>10</message-counter-history-day-limit> 
      </address-setting> 
   </address-settings> 

   <paging-directory>${hornetq.data.dir}/paging</paging-directory> 
   <bindings-directory>${hornetq.data.dir}/bindings</bindings-directory> 
   <journal-directory>${hornetq.data.dir}/journal</journal-directory> 
   <large-messages-directory>${hornetq.data.dir}/large-messages</large-messages-directory> 
</configuration>

In servlet container wwe will need the hornetq-users.xml because of security issues.

<configuration xmlns="urn:hornetq"
               xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" 
    xsi:schemaLocation="urn:hornetq ../schemas/hornetq-users.xsd "> 
    <defaultuser name="guest" password="guest">
        <role name="guest"/>
    </defaultuser>
</configuration>    

Thats all with HornetQ and Tomcat. Next article will be with spring configuration files, that allow you to use hornetq via spring

Wicket and Groovy integration

Forgot to add to "Wicket and Groovy integration" :
in your wicket application init method must have

getApplicationSettings().setClassResolver(new GroovyClassResolver(this));

Wicket and Groovy integration.

Perfect idea to integrate wicket and groovy. From one side the wicket way - strong separation between code and markup, from other side groovy as code behind the markup. And to get extra flexibility i can use the wicket auto components with groovy behind ! Cool !!!

Nice try for wicket 1.3 and "old" groovy 1.6 you can find here http://bigheadco.blogspot.com/2007/03/wicket-and-groovy.html BTW wicket-contrib-groovy was moved to attic in svn repository.

So for wicket 1.4 and groovy 1.7.4 need only two classes from stuff above GroovyWarClassLoader and GroovyClassResolver. The rest is obsolete, because groovy 1.7 support anonymous inner classes and nested classes. Original GroovyWarClassLoader and GroovyClassResolver need to be modified for wicket 1.4.

 
/*
 * $Id: GroovyWarClassLoader.java 524 2006-01-08 09:30:40Z jdonnerstag $
 * $Revision: 524 $ $Date: 2006-01-08 01:30:40 -0800 (Sun, 08 Jan 2006) $
 *
 * ==================================================================== Licensed
 * under the Apache License, Version 2.0 (the "License"); you may not use this
 * file except in compliance with the License. You may obtain a copy of the
 * License at
 *
 * http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
 * WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
 * License for the specific language governing permissions and limitations under
 * the License.
 */ 
package wicket.contrib.groovy; 
 
import groovy.lang.GroovyClassLoader; 
 
import java.io.IOException; 
import java.io.InputStream; 
import java.net.URL; 
 
import org.apache.commons.logging.Log; 
import org.apache.commons.logging.LogFactory; 
import org.codehaus.groovy.control.CompilationFailedException; 
 
 
/**
 * I had some issues with the GroovyClassLoader (1.0.7-beta) which failed to
 * load a groovy files contained in the same war file. E.g.
 *
 * <pre>
 *  wicket-examples.war!/web-inf/classes/groovy/A.groovy
 *  wicket-examples.war!/web-inf/classes/groovy/B.groovy
 *
 *  public class A {
 *     public A() {
 *        B b = new B()
 *     }
 *  }
 * </pre>
 *
 * GroovyClassLoader did not load Groovy class B.
 *
 * @author Juergen Donnerstag
 */ 
public class GroovyWarClassLoader extends GroovyClassLoader
{ 
 /** Logger */ 
 final private static Log log = LogFactory.getLog(GroovyWarClassLoader.class); 
 
 /**
  * Constructor
  *
  * @param loader
  *            The servlet's class loader
  */ 
 public GroovyWarClassLoader(ClassLoader loader) 
 { 
  super(loader); 
 } 
 
 /**
  * First try parent's implementation. If it fails, it'll throw a
  * ClassCastException. Catch it and than apply additional means to load the
  * class.
  *
  * @param name
  *            Class name incl. package
  * @return The Class loaded, if found
  * @throws ClassNotFoundException,
  *             if class could not be loaded
  */ 
 protected Class findClass(final String name) throws ClassNotFoundException
 { 
  try 
  { 
   // Try Groovies default implementation first
   return super.findClass(name); 
  } 
  catch (ClassNotFoundException ex) 
  { 
   log.debug("class name: " + name); 
 
   // classname => filename
   //String filename = Strings.replaceAll(name, ".", "/") + ".groovy";
            String filename = name.replace('.','/') + ".groovy"; 
 
   // File exists?
   final URL url = getResource(filename); 
   if (url != null) 
   { 
    try 
    { 
     // Get Groovy to parse the file and create the Class
     final InputStream in = url.openStream(); 
     if (in != null) 
     { 
      Class clazz = parseClass(in); 
      if (clazz != null) 
      { 
       return clazz; 
      } 
     } 
     else 
     { 
      log.warn("Groovy file not found: " + filename); 
     } 
    } 
    catch (CompilationFailedException e) 
    { 
     throw new ClassNotFoundException("Error parsing groovy file: " 
       + filename, e); 
    } 
    catch (IOException e) 
    { 
     throw new ClassNotFoundException("Error reading groovy file: " 
       + filename, e); 
    } 
    catch (Throwable e) 
    { 
     throw new ClassNotFoundException("Error while reading groovy file: " 
       + filename, e); 
    } 
   } 
 
   throw ex; 
  } 
 } 
} 

----------------------------------------------------------------------------------------------------

 
/*
 * $Id: GroovyClassResolver.java 548 2006-01-19 23:59:30Z joco01 $
 * $Revision: 548 $ $Date: 2006-01-19 15:59:30 -0800 (Thu, 19 Jan 2006) $
 *
 * ==============================================================================
 * Licensed under the Apache License, Version 2.0 (the "License"); you may not
 * use this file except in compliance with the License. You may obtain a copy of
 * the License at
 *
 * http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
 * WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
 * License for the specific language governing permissions and limitations under
 * the License.
 */ 
package wicket.contrib.groovy; 
 
import java.io.InputStream; 
import java.io.IOException; 
import java.util.*; 
 
import org.apache.commons.logging.Log; 
import org.apache.commons.logging.LogFactory; 
import org.codehaus.groovy.control.CompilationFailedException; 
 
import org.apache.wicket.Application; 
import org.apache.wicket.application.IClassResolver; 
import org.apache.wicket.WicketRuntimeException; 
import org.apache.wicket.application.DefaultClassResolver; 
import org.apache.wicket.util.listener.IChangeListener; 
import org.apache.wicket.util.resource.IResourceStream; 
import org.apache.wicket.util.watch.IModificationWatcher; 
 
import java.util.concurrent.ConcurrentHashMap; 
import java.net.URL; 
 
/**
 * Extends the default Page Factory to allow for Groovy based classes.
 * Modifications to groovy files are tracked and files are reloaded if modified.
 *
 * @author Juergen Donnerstag
 */ 
public class GroovyClassResolver implements IClassResolver
{ 
 /** Logging */ 
 private static final Log log = LogFactory.getLog(GroovyClassResolver.class); 
 
 /**
  * Caching map of class name to groovy class; not sure if GroovyClassLoader
  * does it as well
  */ 
 //private final Map classCache = new ConcurrentReaderHashMap();
 private final Map classCache = new ConcurrentHashMap(); 
 
 /** Default class resolver */ 
 private final IClassResolver defaultClassResolver = new DefaultClassResolver(); 
 
 /** Application */ 
 private final Application application; 
 
 /**
  * Constructor
  *
  * @param application
  *            Application
  */ 
 public GroovyClassResolver(final Application application) 
 { 
  this.application = application; 
 } 
 
    /**
     *
     * @see org.apache.wicket.application.IClassResolver#getResources(java.lang.String)
     */ 
    public Iterator<URL> getResources(String name) 
    { 
        HashSet<URL> loadedFiles = new HashSet<URL>(); 
        try 
        { 
            // Try the classloader for the wicket jar/bundle
            Enumeration<URL> resources = Application.class.getClassLoader().getResources(name); 
            loadResources(resources, loadedFiles); 
 
            // Try the classloader for the user's application jar/bundle
            resources = Application.get().getClass().getClassLoader().getResources(name); 
            loadResources(resources, loadedFiles); 
 
            // Try the context class loader
            resources = Thread.currentThread().getContextClassLoader().getResources(name); 
            loadResources(resources, loadedFiles); 
        } 
        catch (IOException e) 
        { 
            throw new WicketRuntimeException(e); 
        } 
 
        return loadedFiles.iterator(); 
    } 
 
    /**
     *
     * @param resources
     * @param loadedFiles
     */ 
    private void loadResources(Enumeration<URL> resources, Set<URL> loadedFiles) 
    { 
        if (resources != null) 
        { 
            while (resources.hasMoreElements()) 
            { 
                final URL url = resources.nextElement(); 
                if (!loadedFiles.contains(url)) 
                { 
                    loadedFiles.add(url); 
                } 
            } 
        } 
    } 
 
 
 
 
 /**
  * Resolve the class for the given classname. First try standard java
  * classes, then groovy files. Groovy file name must be
  * &lt;classname&gt;.groovy.
  *
  * @param classname
  *            The object's class name
  * @return The class
  * @see IClassResolver#resolveClass(String)
  */ 
 public Class resolveClass(final String classname)  throws ClassNotFoundException
 { 
  try 
  { 
   return defaultClassResolver.resolveClass(classname); 
  } 
  catch (WicketRuntimeException ex) 
  { 
   ; // default resolver failed. Try the groovy specific loader next
  } 
  catch (ClassNotFoundException ex) 
  { 
   ; // default resolver failed. Try the groovy specific loader next
  } 
 
  // If definition already loaded, ...
  Class groovyPageClass = (Class) classCache.get(classname); 
  if (groovyPageClass != null) 
  { 
   return groovyPageClass; 
  } 
 
  // Else, try Groovy.
  final IResourceStream resource = application.getResourceSettings() 
    .getResourceStreamLocator().locate(getClass(), 
      classname.replace('.', '/'), null, null, ".groovy"); 
 
  if (resource != null) 
  { 
   try 
   { 
    // Load the groovy file, get the Class and watch for changes
    groovyPageClass = loadGroovyFileAndWatchForChanges(classname, resource); 
    if (groovyPageClass != null) 
    { 
     return groovyPageClass; 
    } 
   } 
   catch (WicketRuntimeException ex) 
   { 
    throw new WicketRuntimeException("Unable to load class with name: " 
      + classname, ex); 
   } 
  } 
  else 
  { 
   throw new WicketRuntimeException("File not found: " + resource); 
  } 
 
  throw new WicketRuntimeException("Unable to load class with name: " + classname); 
 } 
 
 
    /**
  * Load a Groovy file, create a Class object and put it into the cache
  *
  * @param classname
  *            The class name to be created by the Groovy filename
  * @param resource
  *            The Groovy resource
  * @return the Class object created by the groovy resouce
  */ 
 private final Class loadGroovyFile(String classname, final IResourceStream resource) 
 { 
  // Ensure that we use the correct classloader so that we can find
  // classes in an application server.
  ClassLoader cl = Thread.currentThread().getContextClassLoader(); 
  if (cl == null) 
  { 
   cl = GroovyClassResolver.class.getClassLoader(); 
  } 
 
  final GroovyWarClassLoader groovyClassLoader = new GroovyWarClassLoader(cl); 
  Class clazz = null; 
 
  try 
  { 
   final InputStream in = resource.getInputStream(); 
   if (in != null) 
   { 
    clazz = groovyClassLoader.parseClass(in); 
    if (clazz != null) 
    { 
     // this is necessary because with groovy the filename can be
     // different from the class definition included.
     if (false == classname.equals(clazz.getName())) 
     { 
      log.warn("Though it is possible, the Groovy file name and " 
        + "the java class name defined in that file SHOULD " 
        + "match and follow the java rules"); 
     } 
     classname = clazz.getName(); 
    } 
   } 
   else 
   { 
    log.warn("Groovy file not found: " + resource); 
   } 
  } 
  catch (CompilationFailedException e) 
  { 
   throw new WicketRuntimeException("Error parsing groovy file: " + resource, e); 
  } 
  catch (Throwable e) 
  { 
   throw new WicketRuntimeException("Error while reading groovy file: " 
     + resource, e); 
  } 
  finally 
  { 
   if (clazz == null) 
   { 
    // Groovy file not found; error while compiling etc..
    // Remove it from cache
    classCache.remove(classname); 
   } 
   else 
   { 
    // Put the new class definition into the cache
    classCache.put(classname, clazz); 
   } 
  } 
 
  return clazz; 
 } 
 
 /**
  * Load the groovy file and watch for changes. If changes to the groovy
  * happens, than reload the file.
  *
  * @param classname
  * @param resource
  * @return Loaded class
  */ 
 private Class loadGroovyFileAndWatchForChanges(final String classname, 
   final IResourceStream resource) 
 { 
  // Watch file in the future
  final IModificationWatcher watcher = application.getResourceSettings() 
    .getResourceWatcher(true); 
 
  if (watcher != null) 
  { 
   watcher.add(resource, new IChangeListener() 
   { 
    public void onChange() 
    { 
     try 
     { 
      log.info("Reloading groovy file from " + resource); 
 
      // Reload file and update cache
      final Class clazz = loadGroovyFile(classname, resource); 
      log.debug("Groovy file contained definition for class: " 
        + clazz.getName()); 
     } 
     catch (Exception e) 
     { 
      log.error("Unable to load groovyy file: " + resource, e); 
     } 
    } 
   }); 
  } 
 
  log.info("Loading groovy file from " + resource); 
  return loadGroovyFile(classname, resource); 
 } 
}

Nobody perfect or bugs everywhere.

    People , who live within latin1 encoding made a mistakes according to different locales and cultures.

    In case of flex sdk 4 I found following error: Number as model, NumberValidator , TextInput and BindingUtils in Russian locale, that has a , (comma) as decimal separator , inposible to input real number. The scenario is : user input, decimal separator, NumberValidation validate it in correct way, but BindingUtils can not convert text with comma to Number and set NaN value to target Number field and value in TextInput became a string NaN and validator can not pass this value :)

LOL !!! After registration in adobe jira, i can not login to post the bug

upd: bug is created http://bugs.adobe.com/jira/browse/SDK-26785

Shit software

Hey !!!
People, who call self software engineer, please rtfm about process scheduling in windows with at daemon for check updates. Do not start separate process at logon to update your shit soft! Do not start at all ! I`ll call you when you need me ... may be.

No destination with id 'serviceName' is registered with any service.

WOW ! "No destination with id 'serviceName' is registered with any service." !
First of all check the spring config file. Is bean definition has a <flex:remoting-destination/> ?

"Statement is closed" SQLExeption or OutOfMemory exception during dbunit testing.

Do you have a problem with "Statement is closed" SQLExeption during dbunit testing ?
I had, because wrong dataSource configuration, so check the maxOpenPreparedStatements parameter. Your dataSource should looks like described below:

  1 <bean id="dataSource" class="org.apache.commons.dbcp.BasicDataSource">
  2         <property name="driverClassName" value="org.hsqldb.jdbcDriver"/>
  3         <property name="url" value="jdbc:hsqldb:mem:testnpadb"/>
  4         <property name="username" value="sa"/>
  5         <property name="password" value=""/>
  6         <property name="initialSize" value="5"/>
  7         <property name="maxActive" value="100"/>
  8         <property name="poolPreparedStatements" value="true"/>
  9         <property name="maxOpenPreparedStatements" value="100"/>
 10         <property name="defaultAutoCommit" value="true"/>
 11     </bean>

OutOfMemory ? Check the tear down method, guess you have to shutdown spring context.

Lack of documentation or "Name jdbc is not bound in this Context"

If you get the "Name jdbc is not bound in this Context" exception with Realm configured in your context.xml you have configure Realm with localDataSource="true" to achive the desirable result

<Context path="/webshopwicket" docBase="/npa/jewelry" crossContext="true">

    <Resource auth="Container" name="mail/Session" type="javax.mail.Session"/>

    <Resource name="jdbc/npajndi"

              auth="Container"
              scope="Shareable"
              type="javax.sql.DataSource"
              maxActive="100"
              maxIdle="30"

              maxWait="10000"
              removeAbandoned="true"
              username="root"
              password=""
              driverClassName="com.mysql.jdbc.Driver"

              url="jdbc:mysql://localhost/npa?AutoReconnect=true&amp;useUnicode=true&amp;characterEncoding=utf-8"
            />


    <Realm className="org.apache.catalina.realm.DataSourceRealm" debug="4"

        localDataSource="true"
        dataSourceName="jdbc/npajndi"
        userTable="TMANAGER"
        userNameCol="email"
        userCredCol="password"

        userRoleTable="TMANAGERROLE"
        roleNameCol="code"/>


</Context>

Идеология

Идеология в наше время это не система идей, а скорее всего система предубеждений и надуманных запретов.

End to end identity propagation with jboss 4, hibernate and oracle. Part 3

Usual way to get the database connection - use data source. I saw a toons of applications, that use the DataSource#getConnection() method to get the data base connection via configured in application server data source. And usual situation, data source configured with priveledged user (root for mysql, schema owner in oracle case, sa for mssql, etc.) name and his password. LOL data source tell you - here the access key, and there the place where you can get everything and even more. To prevent unauthorized access need to use DataSource#getConnection(String userName, String userPassord) instead of DataSource#getConnection(). At this point need to solve following issues:

• how to configure hibernate to get the JDBC connection with user name and password ?
• how to configure jboss, application and data source ?
• passing the password ?
• is created connection will be in connection pool ?

Here the answers:

If you are look to hibernate configuration documentation you can find an amazing configuration parameter - hibernate.connection.provider_class - That has classname of a custom org.hibernate.connection.ConnectionProvider which provides JDBC connections to Hibernate WOW ! This in definitely that need to use !

The source code see below.

/**
* User: iazarny
* Date: 18.08.2008
* Time: 17:44:21
*
* This custom connection provider will work via JBoss datasource with
* application-managment-security configuration
* @see@ hibernate.connection.provider_class configation parameter for Hibernate JPA provider
*/
public class OracleConnectionProvider implements ConnectionProvider {

private static Logger logger = Logger.getLogger(OracleConnectionProvider.class);

private static InitialContext ctx;
private static DataSource ds;
static {
try {
    ctx = new InitialContext();
    ds = (DataSource) ctx.lookup("java:/CrTimeDS");
} catch (NamingException e) {
    logger.fatal("Error ",e);
}
}

private Properties properties;


public void configure(Properties properties) throws HibernateException {
this.properties = properties;
}

public Connection getConnection() throws SQLException {
String userName = null;
String password = null;
if(SecurityAssociation.getPrincipal()!=null) {
    userName = SecurityAssociation.getPrincipal().getName();
    password = SecurityAssociation.getCredential().toString();
    logger.info("SecurityAssociation.getPrincipal = " + userName);
    logger.info("SecurityAssociation.getCredential() = " + password!=null );
}
if (password==null) {
    userName = properties.getProperty(Environment.USER);
    password = properties.getProperty(Environment.PASS);
    logger.info("Environment.USER = " + userName);
    logger.info("Environment.PASS = " + password!=null );    
}


return ds.getConnection(userName,password);

}

public void closeConnection(Connection connection) throws SQLException {
logger.info("OracleConnectionProvider connection return to pool " + connection );
connection.close();
}

public void close() throws HibernateException {
logger.info("OracleConnectionProvider detach from DataSouce");
ds = null;
}

public boolean supportsAggressiveRelease() {
return false;
}
}

Guess you remember from End to end identity propagation with jboss 4, hibernate and oracle. Part 2 how to configure tamcat/jboss-web valves to get the current user password from SecurityAssociation.

As you can see from connection provider example need to configure CrTimeDS datasource.

<?xml version="1.0" encoding="UTF-8"?>
<datasources>
<local-tx-datasource>
   <jndi-name>CrTimeDS</jndi-name>
   <connection-url>jdbc:oracle:thin:@127.0.0.1:1521:az3</connection-url>
   <driver-class>oracle.jdbc.driver.OracleDriver</driver-class>
   <!-- username and password not necessary, because of application-managed-security -->
   <user-name></user-name>
   <password></password>
   <exception-sorter-class-name>org.jboss.resource.adapter.jdbc.vendor.OracleExceptionSorter
   </exception-sorter-class-name>
   <min-pool-size>10</min-pool-size>
   <max-pool-size>200</max-pool-size>
   <blocking-timeout-millis>1000</blocking-timeout-millis>
   <idle-timeout-minutes>1</idle-timeout-minutes>
   <application-managed-security/>
   <metadata>
       <type-mapping>Oracle9i</type-mapping>
   </metadata>
</local-tx-datasource>
</datasources>

In the persistence.xml connection provider wired with hibernate. In case if hibernate will try to check data base schema against domain model on application start and you find a lot of stack traces you need to add copule of lines.
<property name="hibernate.connection.username" value="readSchemaOnlyUser"/>
<property name="hibernate.connection.password" value="readSchemaOnlyPassword"/>

The readSchemaOnlyUser user in oracle, that can read schema meta data, but not actuall data. It easy with oracle

<?xml version="1.0" encoding="UTF-8"?>
<persistence xmlns="http://java.sun.com/xml/ns/persistence"
          xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
          xsi:schemaLocation="http://java.sun.com/xml/ns/persistence
          http://java.sun.com/xml/ns/persistence/persistence_1_0.xsd"  version="1.0">
 <persistence-unit name="crtimedbUnit" transaction-type="JTA">
     <provider>org.hibernate.ejb.HibernatePersistence</provider>
     <jta-data-source>java:/CrTimeDS</jta-data-source>
     <properties>
         <property name="hibernate.dialect" value="org.hibernate.dialect.Oracle9Dialect"/>
         <property name="hibernate.connection.charset" value="UTF-8"/>
         <property name="hibernate.cache.use_second_level_cache" value="false"/>
         <property name="hibernate.cache.provider_class" value="org.hibernate.cache.NoCacheProvider"/>
         <property name="hibernate.archive.autodetection" value="class"/>
         <property name="hibernate.default_schema" value="CRTIME"/>
         <property name="hibernate.connection.provider_class" value="com.crtime.connection.provider.OracleConnectionProvider"/>
     </properties>
 </persistence-unit>
</persistence>

In web application configuration jboss-web.xml you have to configure security domain

<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE jboss-web PUBLIC "-//JBoss//DTD Web Application 2.3V2//EN"
      "http://www.jboss.org/j2ee/dtd/jboss-web_3_2.dtd">
<jboss-web>
  <security-domain>java:/jaas/crtime-webapp</security-domain>
</jboss-web>

And last question is created connection for user willl be pooled ? Simple answer - yes it is. If you not sure - dig the jboss source code :)

Hmmm... 3 articles, guess nedd to provide overview how it works from end to end.

When not authorized user hit the page he will be promted by login to input his name and password. Provided login name and password will be checked via CrTimeAuthDS datasource by standard java login module (see part 1) in case if result is successful, user become authorized. Database connection will be obtained configured CrTimeDS and hibernate connection provider by using DataSource#getConnection(user, password) method. So user not impersonalized at data base level as well as web and middleware levels.