Author: hlship
Date: Fri Oct 14 22:03:31 2011
New Revision: 1183527

URL: http://svn.apache.org/viewvc?rev=1183527&view=rev
Log:
TAP5-1539: Update a few places to use Runnable not (deprecated) 
RegistryShutdownListener

Modified:
    
tapestry/tapestry5/trunk/tapestry-hibernate-core/src/main/java/org/apache/tapestry5/hibernate/HibernateCoreModule.java
    
tapestry/tapestry5/trunk/tapestry-hibernate-core/src/main/java/org/apache/tapestry5/internal/hibernate/HibernateSessionSourceImpl.java
    
tapestry/tapestry5/trunk/tapestry-ioc/src/main/java/org/apache/tapestry5/ioc/internal/RegistryImpl.java
    
tapestry/tapestry5/trunk/tapestry-ioc/src/main/java/org/apache/tapestry5/ioc/internal/services/JustInTimeObjectCreator.java
    
tapestry/tapestry5/trunk/tapestry-ioc/src/main/java/org/apache/tapestry5/ioc/internal/services/cron/PeriodicExecutorImpl.java
    
tapestry/tapestry5/trunk/tapestry-ioc/src/main/java/org/apache/tapestry5/ioc/services/TapestryIOCModule.java
    
tapestry/tapestry5/trunk/tapestry-ioc/src/test/java/org/apache/tapestry5/ioc/internal/services/JustInTimeObjectCreatorTest.java
    
tapestry/tapestry5/trunk/tapestry-jmx/src/main/java/org/apache/tapestry5/internal/jmx/MBeanSupportImpl.java
    
tapestry/tapestry5/trunk/tapestry-jpa/src/main/java/org/apache/tapestry5/internal/jpa/EntityManagerSourceImpl.java
    
tapestry/tapestry5/trunk/tapestry-jpa/src/main/java/org/apache/tapestry5/jpa/JpaModule.java
    
tapestry/tapestry5/trunk/tapestry-spring/src/main/java/org/apache/tapestry5/internal/spring/SpringModuleDef.java
    
tapestry/tapestry5/trunk/tapestry-upload/src/main/java/org/apache/tapestry5/upload/services/UploadModule.java

Modified: 
tapestry/tapestry5/trunk/tapestry-hibernate-core/src/main/java/org/apache/tapestry5/hibernate/HibernateCoreModule.java
URL: 
http://svn.apache.org/viewvc/tapestry/tapestry5/trunk/tapestry-hibernate-core/src/main/java/org/apache/tapestry5/hibernate/HibernateCoreModule.java?rev=1183527&r1=1183526&r2=1183527&view=diff
==============================================================================
--- 
tapestry/tapestry5/trunk/tapestry-hibernate-core/src/main/java/org/apache/tapestry5/hibernate/HibernateCoreModule.java
 (original)
+++ 
tapestry/tapestry5/trunk/tapestry-hibernate-core/src/main/java/org/apache/tapestry5/hibernate/HibernateCoreModule.java
 Fri Oct 14 22:03:31 2011
@@ -45,6 +45,7 @@ public class HibernateCoreModule
         binder.bind(HibernateTransactionDecorator.class, 
HibernateTransactionDecoratorImpl.class);
         binder.bind(HibernateTransactionAdvisor.class, 
HibernateTransactionAdvisorImpl.class);
         binder.bind(HibernateConfigurer.class, 
DefaultHibernateConfigurer.class).withSimpleId();
+        binder.bind(HibernateSessionSource.class, 
HibernateSessionSourceImpl.class);
     }
 
 
@@ -117,16 +118,6 @@ public class HibernateCoreModule
         return propertyShadowBuilder.build(sessionManager, "session", 
Session.class);
     }
 
-    public static HibernateSessionSource buildHibernateSessionSource(Logger 
logger, List<HibernateConfigurer> config,
-                                                                     
RegistryShutdownHub hub)
-    {
-        HibernateSessionSourceImpl hss = new 
HibernateSessionSourceImpl(logger, config);
-
-        hub.addRegistryShutdownListener(hss);
-
-        return hss;
-    }
-
     /**
      * Adds the following configurers: <dl> <dt>Default <dd> performs default 
hibernate configuration <dt>PackageName
      * <dd> loads entities by package name</dl>

Modified: 
tapestry/tapestry5/trunk/tapestry-hibernate-core/src/main/java/org/apache/tapestry5/internal/hibernate/HibernateSessionSourceImpl.java
URL: 
http://svn.apache.org/viewvc/tapestry/tapestry5/trunk/tapestry-hibernate-core/src/main/java/org/apache/tapestry5/internal/hibernate/HibernateSessionSourceImpl.java?rev=1183527&r1=1183526&r2=1183527&view=diff
==============================================================================
--- 
tapestry/tapestry5/trunk/tapestry-hibernate-core/src/main/java/org/apache/tapestry5/internal/hibernate/HibernateSessionSourceImpl.java
 (original)
+++ 
tapestry/tapestry5/trunk/tapestry-hibernate-core/src/main/java/org/apache/tapestry5/internal/hibernate/HibernateSessionSourceImpl.java
 Fri Oct 14 22:03:31 2011
@@ -1,4 +1,4 @@
-// Copyright 2007, 2008 The Apache Software Foundation
+// Copyright 2007, 2008, 2011 The Apache Software Foundation
 //
 // Licensed under the Apache License, Version 2.0 (the "License");
 // you may not use this file except in compliance with the License.
@@ -14,18 +14,19 @@
 
 package org.apache.tapestry5.internal.hibernate;
 
-import java.util.List;
-
 import org.apache.tapestry5.hibernate.HibernateConfigurer;
 import org.apache.tapestry5.hibernate.HibernateSessionSource;
-import org.apache.tapestry5.ioc.services.RegistryShutdownListener;
+import org.apache.tapestry5.ioc.annotations.PostInjection;
+import org.apache.tapestry5.ioc.services.RegistryShutdownHub;
 import org.hibernate.Session;
 import org.hibernate.SessionFactory;
 import org.hibernate.cfg.AnnotationConfiguration;
 import org.hibernate.cfg.Configuration;
 import org.slf4j.Logger;
 
-public class HibernateSessionSourceImpl implements HibernateSessionSource, 
RegistryShutdownListener
+import java.util.List;
+
+public class HibernateSessionSourceImpl implements HibernateSessionSource
 {
     private final SessionFactory sessionFactory;
 
@@ -51,6 +52,18 @@ public class HibernateSessionSourceImpl 
         
logger.info(HibernateCoreMessages.entityCatalog(sessionFactory.getAllClassMetadata().keySet()));
     }
 
+    @PostInjection
+    public void listenForShutdown(RegistryShutdownHub hub)
+    {
+        hub.addRegistryShutdownListener(new Runnable()
+        {
+            public void run()
+            {
+                sessionFactory.close();
+            }
+        });
+    }
+
     public Session create()
     {
         return sessionFactory.openSession();
@@ -66,8 +79,4 @@ public class HibernateSessionSourceImpl 
         return configuration;
     }
 
-    public void registryDidShutdown()
-    {
-        sessionFactory.close();
-    }
 }

Modified: 
tapestry/tapestry5/trunk/tapestry-ioc/src/main/java/org/apache/tapestry5/ioc/internal/RegistryImpl.java
URL: 
http://svn.apache.org/viewvc/tapestry/tapestry5/trunk/tapestry-ioc/src/main/java/org/apache/tapestry5/ioc/internal/RegistryImpl.java?rev=1183527&r1=1183526&r2=1183527&view=diff
==============================================================================
--- 
tapestry/tapestry5/trunk/tapestry-ioc/src/main/java/org/apache/tapestry5/ioc/internal/RegistryImpl.java
 (original)
+++ 
tapestry/tapestry5/trunk/tapestry-ioc/src/main/java/org/apache/tapestry5/ioc/internal/RegistryImpl.java
 Fri Oct 14 22:03:31 2011
@@ -145,9 +145,9 @@ public class RegistryImpl implements Reg
 
         lifecycles.put("singleton", new SingletonServiceLifecycle());
 
-        registryShutdownHub.addRegistryShutdownListener(new 
RegistryShutdownListener()
+        registryShutdownHub.addRegistryShutdownListener(new Runnable()
         {
-            public void registryDidShutdown()
+            public void run()
             {
                 scoreboardAndTracker.shutdown();
             }

Modified: 
tapestry/tapestry5/trunk/tapestry-ioc/src/main/java/org/apache/tapestry5/ioc/internal/services/JustInTimeObjectCreator.java
URL: 
http://svn.apache.org/viewvc/tapestry/tapestry5/trunk/tapestry-ioc/src/main/java/org/apache/tapestry5/ioc/internal/services/JustInTimeObjectCreator.java?rev=1183527&r1=1183526&r2=1183527&view=diff
==============================================================================
--- 
tapestry/tapestry5/trunk/tapestry-ioc/src/main/java/org/apache/tapestry5/ioc/internal/services/JustInTimeObjectCreator.java
 (original)
+++ 
tapestry/tapestry5/trunk/tapestry-ioc/src/main/java/org/apache/tapestry5/ioc/internal/services/JustInTimeObjectCreator.java
 Fri Oct 14 22:03:31 2011
@@ -17,7 +17,6 @@ package org.apache.tapestry5.ioc.interna
 import org.apache.tapestry5.ioc.ObjectCreator;
 import org.apache.tapestry5.ioc.internal.EagerLoadServiceProxy;
 import org.apache.tapestry5.ioc.internal.ServiceActivityTracker;
-import org.apache.tapestry5.ioc.services.RegistryShutdownListener;
 import org.apache.tapestry5.ioc.services.Status;
 
 /**
@@ -26,7 +25,7 @@ import org.apache.tapestry5.ioc.services
  * same time (a service should be realized only once). The additional 
interfaces implemented by this class support eager
  * loading of services (at application startup), and orderly shutdown of 
proxies.
  */
-public class JustInTimeObjectCreator<T> implements ObjectCreator<T>, 
EagerLoadServiceProxy, RegistryShutdownListener
+public class JustInTimeObjectCreator<T> implements ObjectCreator<T>, 
EagerLoadServiceProxy, Runnable
 {
     private final ServiceActivityTracker tracker;
 
@@ -46,9 +45,8 @@ public class JustInTimeObjectCreator<T> 
     /**
      * Checks to see if the proxy has been shutdown, then invokes {@link 
ObjectCreator#createObject()} if it has not
      * already done so.
-     * 
-     * @throws IllegalStateException
-     *             if the registry has been shutdown
+     *
+     * @throws IllegalStateException if the registry has been shutdown
      */
     public T createObject()
     {
@@ -72,8 +70,7 @@ public class JustInTimeObjectCreator<T> 
             tracker.setStatus(serviceId, Status.REAL);
 
             creator = null;
-        }
-        catch (RuntimeException ex)
+        } catch (RuntimeException ex)
         {
             throw new 
RuntimeException(ServiceMessages.serviceBuildFailure(serviceId, ex), ex);
         }
@@ -90,9 +87,9 @@ public class JustInTimeObjectCreator<T> 
     }
 
     /**
-     * Sets the shutdown flag and releases the object and the creator.
+     * Invoked when the Registry is shutdown; sets the shutdown flag and 
releases the object and the creator.
      */
-    public void registryDidShutdown()
+    public void run()
     {
         creator = new ObjectCreator<T>()
         {

Modified: 
tapestry/tapestry5/trunk/tapestry-ioc/src/main/java/org/apache/tapestry5/ioc/internal/services/cron/PeriodicExecutorImpl.java
URL: 
http://svn.apache.org/viewvc/tapestry/tapestry5/trunk/tapestry-ioc/src/main/java/org/apache/tapestry5/ioc/internal/services/cron/PeriodicExecutorImpl.java?rev=1183527&r1=1183526&r2=1183527&view=diff
==============================================================================
--- 
tapestry/tapestry5/trunk/tapestry-ioc/src/main/java/org/apache/tapestry5/ioc/internal/services/cron/PeriodicExecutorImpl.java
 (original)
+++ 
tapestry/tapestry5/trunk/tapestry-ioc/src/main/java/org/apache/tapestry5/ioc/internal/services/cron/PeriodicExecutorImpl.java
 Fri Oct 14 22:03:31 2011
@@ -277,7 +277,7 @@ public class PeriodicExecutorImpl implem
         return shutdown;
     }
 
-    public synchronized void registryDidShutdown()
+    private synchronized void registryDidShutdown()
     {
         shutdown = true;
 

Modified: 
tapestry/tapestry5/trunk/tapestry-ioc/src/main/java/org/apache/tapestry5/ioc/services/TapestryIOCModule.java
URL: 
http://svn.apache.org/viewvc/tapestry/tapestry5/trunk/tapestry-ioc/src/main/java/org/apache/tapestry5/ioc/services/TapestryIOCModule.java?rev=1183527&r1=1183526&r2=1183527&view=diff
==============================================================================
--- 
tapestry/tapestry5/trunk/tapestry-ioc/src/main/java/org/apache/tapestry5/ioc/services/TapestryIOCModule.java
 (original)
+++ 
tapestry/tapestry5/trunk/tapestry-ioc/src/main/java/org/apache/tapestry5/ioc/services/TapestryIOCModule.java
 Fri Oct 14 22:03:31 2011
@@ -508,9 +508,9 @@ public final class TapestryIOCModule
         final ThreadPoolExecutor executorService = new 
ThreadPoolExecutor(coreSize, maxSize, keepAliveMillis,
                 TimeUnit.MILLISECONDS, workQueue);
 
-        shutdownHub.addRegistryShutdownListener(new RegistryShutdownListener()
+        shutdownHub.addRegistryShutdownListener(new Runnable()
         {
-            public void registryDidShutdown()
+            public void run()
             {
                 executorService.shutdown();
             }

Modified: 
tapestry/tapestry5/trunk/tapestry-ioc/src/test/java/org/apache/tapestry5/ioc/internal/services/JustInTimeObjectCreatorTest.java
URL: 
http://svn.apache.org/viewvc/tapestry/tapestry5/trunk/tapestry-ioc/src/test/java/org/apache/tapestry5/ioc/internal/services/JustInTimeObjectCreatorTest.java?rev=1183527&r1=1183526&r2=1183527&view=diff
==============================================================================
--- 
tapestry/tapestry5/trunk/tapestry-ioc/src/test/java/org/apache/tapestry5/ioc/internal/services/JustInTimeObjectCreatorTest.java
 (original)
+++ 
tapestry/tapestry5/trunk/tapestry-ioc/src/test/java/org/apache/tapestry5/ioc/internal/services/JustInTimeObjectCreatorTest.java
 Fri Oct 14 22:03:31 2011
@@ -1,4 +1,4 @@
-// Copyright 2007, 2009 The Apache Software Foundation
+// Copyright 2007, 2009, 2011 The Apache Software Foundation
 //
 // Licensed under the Apache License, Version 2.0 (the "License");
 // you may not use this file except in compliance with the License.
@@ -33,7 +33,7 @@ public class JustInTimeObjectCreatorTest
 
         JustInTimeObjectCreator j = new JustInTimeObjectCreator(null, creator, 
SERVICE_ID);
 
-        j.registryDidShutdown();
+        j.run();
 
         try
         {

Modified: 
tapestry/tapestry5/trunk/tapestry-jmx/src/main/java/org/apache/tapestry5/internal/jmx/MBeanSupportImpl.java
URL: 
http://svn.apache.org/viewvc/tapestry/tapestry5/trunk/tapestry-jmx/src/main/java/org/apache/tapestry5/internal/jmx/MBeanSupportImpl.java?rev=1183527&r1=1183526&r2=1183527&view=diff
==============================================================================
--- 
tapestry/tapestry5/trunk/tapestry-jmx/src/main/java/org/apache/tapestry5/internal/jmx/MBeanSupportImpl.java
 (original)
+++ 
tapestry/tapestry5/trunk/tapestry-jmx/src/main/java/org/apache/tapestry5/internal/jmx/MBeanSupportImpl.java
 Fri Oct 14 22:03:31 2011
@@ -14,25 +14,23 @@
 
 package org.apache.tapestry5.internal.jmx;
 
-import static java.lang.String.format;
-
-import java.lang.management.ManagementFactory;
-import java.util.List;
-import java.util.Set;
-
-import javax.management.MBeanServer;
-import javax.management.MBeanServerFactory;
-import javax.management.ObjectName;
-
 import org.apache.tapestry5.ioc.annotations.PostInjection;
 import org.apache.tapestry5.ioc.internal.util.CollectionFactory;
 import org.apache.tapestry5.ioc.internal.util.OneShotLock;
 import org.apache.tapestry5.ioc.services.RegistryShutdownHub;
-import org.apache.tapestry5.ioc.services.RegistryShutdownListener;
 import org.apache.tapestry5.jmx.MBeanSupport;
 import org.slf4j.Logger;
 
-public class MBeanSupportImpl implements MBeanSupport, RegistryShutdownListener
+import javax.management.MBeanServer;
+import javax.management.MBeanServerFactory;
+import javax.management.ObjectName;
+import java.lang.management.ManagementFactory;
+import java.util.List;
+import java.util.Set;
+
+import static java.lang.String.format;
+
+public class MBeanSupportImpl implements MBeanSupport
 {
     private final Logger logger;
 
@@ -67,7 +65,13 @@ public class MBeanSupportImpl implements
     @PostInjection
     public void listenForShutdown(RegistryShutdownHub hub)
     {
-        hub.addRegistryShutdownListener(this);
+        hub.addRegistryShutdownListener(new Runnable()
+        {
+            public void run()
+            {
+                registryDidShutdown();
+            }
+        });
     }
 
     public void register(Object bean, String name)
@@ -80,8 +84,7 @@ public class MBeanSupportImpl implements
         try
         {
             return new ObjectName(name);
-        }
-        catch (Exception ex)
+        } catch (Exception ex)
         {
             throw new RuntimeException(ex);
         }
@@ -101,8 +104,7 @@ public class MBeanSupportImpl implements
             this.registeredBeans.add(objectName);
 
             this.logger.info(format("Registered MBean '%s' with server", 
objectName));
-        }
-        catch (final Exception e)
+        } catch (final Exception e)
         {
             this.logger.error(format("Failed to register MBean '%s' with 
server", objectName), e);
         }
@@ -127,15 +129,14 @@ public class MBeanSupportImpl implements
 
                 if (registeredBeans.contains(objectName))
                     registeredBeans.remove(objectName);
-            }
-            catch (final Exception e)
+            } catch (final Exception e)
             {
                 this.logger.error(String.format("Failed to unregister MBean 
'%s' from server", objectName), e);
             }
         }
     }
 
-    public void registryDidShutdown()
+    private void registryDidShutdown()
     {
         lock.lock();
         // store into new data structure so we can remove them from registered 
beans

Modified: 
tapestry/tapestry5/trunk/tapestry-jpa/src/main/java/org/apache/tapestry5/internal/jpa/EntityManagerSourceImpl.java
URL: 
http://svn.apache.org/viewvc/tapestry/tapestry5/trunk/tapestry-jpa/src/main/java/org/apache/tapestry5/internal/jpa/EntityManagerSourceImpl.java?rev=1183527&r1=1183526&r2=1183527&view=diff
==============================================================================
--- 
tapestry/tapestry5/trunk/tapestry-jpa/src/main/java/org/apache/tapestry5/internal/jpa/EntityManagerSourceImpl.java
 (original)
+++ 
tapestry/tapestry5/trunk/tapestry-jpa/src/main/java/org/apache/tapestry5/internal/jpa/EntityManagerSourceImpl.java
 Fri Oct 14 22:03:31 2011
@@ -14,34 +14,33 @@
 
 package org.apache.tapestry5.internal.jpa;
 
-import java.io.InputStream;
-import java.util.Collections;
-import java.util.List;
-import java.util.Map;
-import java.util.Map.Entry;
-import java.util.Set;
-
-import javax.persistence.EntityManager;
-import javax.persistence.EntityManagerFactory;
-import javax.persistence.spi.PersistenceProvider;
-import javax.persistence.spi.PersistenceProviderResolver;
-import javax.persistence.spi.PersistenceProviderResolverHolder;
-import javax.persistence.spi.PersistenceUnitInfo;
-
 import org.apache.tapestry5.func.F;
 import org.apache.tapestry5.func.Mapper;
 import org.apache.tapestry5.func.Predicate;
 import org.apache.tapestry5.ioc.Resource;
+import org.apache.tapestry5.ioc.annotations.Local;
+import org.apache.tapestry5.ioc.annotations.PostInjection;
+import org.apache.tapestry5.ioc.annotations.Symbol;
 import org.apache.tapestry5.ioc.internal.util.CollectionFactory;
 import org.apache.tapestry5.ioc.internal.util.InternalUtils;
-import org.apache.tapestry5.ioc.services.RegistryShutdownListener;
-import org.apache.tapestry5.jpa.EntityManagerSource;
-import org.apache.tapestry5.jpa.JpaConstants;
-import org.apache.tapestry5.jpa.PersistenceUnitConfigurer;
-import org.apache.tapestry5.jpa.TapestryPersistenceUnitInfo;
+import org.apache.tapestry5.ioc.services.RegistryShutdownHub;
+import org.apache.tapestry5.jpa.*;
 import org.slf4j.Logger;
 
-public class EntityManagerSourceImpl implements EntityManagerSource, 
RegistryShutdownListener
+import javax.persistence.EntityManager;
+import javax.persistence.EntityManagerFactory;
+import javax.persistence.spi.PersistenceProvider;
+import javax.persistence.spi.PersistenceProviderResolver;
+import javax.persistence.spi.PersistenceProviderResolverHolder;
+import javax.persistence.spi.PersistenceUnitInfo;
+import java.io.InputStream;
+import java.util.Collections;
+import java.util.List;
+import java.util.Map;
+import java.util.Map.Entry;
+import java.util.Set;
+
+public class EntityManagerSourceImpl implements EntityManagerSource
 {
     private final Map<String, EntityManagerFactory> entityManagerFactories = 
CollectionFactory
             .newMap();
@@ -50,10 +49,11 @@ public class EntityManagerSourceImpl imp
 
     private final List<TapestryPersistenceUnitInfo> persistenceUnitInfos;
 
-    public EntityManagerSourceImpl(final Logger logger, final Resource 
persistenceDescriptor, PersistenceUnitConfigurer 
packageNamePersistenceUnitConfigurer, 
-            final Map<String, PersistenceUnitConfigurer> configuration)
+    public EntityManagerSourceImpl(Logger logger, 
@Symbol(JpaSymbols.PERSISTENCE_DESCRIPTOR)
+    final Resource persistenceDescriptor, @Local
+    PersistenceUnitConfigurer packageNamePersistenceUnitConfigurer,
+                                   Map<String, PersistenceUnitConfigurer> 
configuration)
     {
-        super();
         this.logger = logger;
 
         List<TapestryPersistenceUnitInfo> persistenceUnitInfos = 
parsePersistenceUnitInfos(persistenceDescriptor);
@@ -62,11 +62,10 @@ public class EntityManagerSourceImpl imp
 
         configureRemaining(persistenceUnitInfos, remainingConfigurations);
 
-        if(persistenceUnitInfos.size() == 1) 
+        if (persistenceUnitInfos.size() == 1)
         {
             
packageNamePersistenceUnitConfigurer.configure(persistenceUnitInfos.get(0));
-        }
-        else
+        } else
         {
             validateUnitInfos(persistenceUnitInfos);
         }
@@ -74,6 +73,18 @@ public class EntityManagerSourceImpl imp
         this.persistenceUnitInfos = persistenceUnitInfos;
     }
 
+    @PostInjection
+    public void listenForShutdown(RegistryShutdownHub hub)
+    {
+        hub.addRegistryShutdownListener(new Runnable()
+        {
+            public void run()
+            {
+                registryDidShutdown();
+            }
+        });
+    }
+
     private void validateUnitInfos(List<TapestryPersistenceUnitInfo> 
persistenceUnitInfos)
     {
         final List<String> affectedUnits = 
F.flow(persistenceUnitInfos).filter(new Predicate<TapestryPersistenceUnitInfo>()
@@ -90,14 +101,14 @@ public class EntityManagerSourceImpl imp
             }
         }).toList();
 
-        if(0 < affectedUnits.size())
+        if (0 < affectedUnits.size())
         {
             throw new RuntimeException(
                     String.format(
                             "Persistence units '%s' are configured to include 
managed classes that have not been explicitly listed. " +
-                            "This is forbidden when multiple persistence units 
are used in the same application. " +
-                            "Please configure persistence units to exclude 
unlisted managed classes (e.g. by removing <exclude-unlisted-classes> element) 
" +
-                            "and include them explicitly.",
+                                    "This is forbidden when multiple 
persistence units are used in the same application. " +
+                                    "Please configure persistence units to 
exclude unlisted managed classes (e.g. by removing <exclude-unlisted-classes> 
element) " +
+                                    "and include them explicitly.",
                             InternalUtils.join(affectedUnits)));
         }
     }
@@ -106,7 +117,7 @@ public class EntityManagerSourceImpl imp
     {
         List<TapestryPersistenceUnitInfo> persistenceUnitInfos = 
CollectionFactory.newList();
 
-        if(persistenceDescriptor.exists())
+        if (persistenceDescriptor.exists())
         {
             final PersistenceParser parser = new PersistenceParser();
 
@@ -115,12 +126,10 @@ public class EntityManagerSourceImpl imp
             {
                 inputStream = persistenceDescriptor.openStream();
                 persistenceUnitInfos = parser.parse(inputStream);
-            }
-            catch(Exception e)
+            } catch (Exception e)
             {
                 throw new RuntimeException(e);
-            }
-            finally
+            } finally
             {
                 InternalUtils.close(inputStream);
             }
@@ -143,7 +152,7 @@ public class EntityManagerSourceImpl imp
             {
                 configurer.configure(info);
 
-                remainingConfigurations.remove(unitName) ;
+                remainingConfigurations.remove(unitName);
             }
         }
 
@@ -153,7 +162,7 @@ public class EntityManagerSourceImpl imp
 
     private void configureRemaining(List<TapestryPersistenceUnitInfo> 
persistenceUnitInfos, Map<String, PersistenceUnitConfigurer> 
remainingConfigurations)
     {
-        for(Entry<String, PersistenceUnitConfigurer> entry: 
remainingConfigurations.entrySet())
+        for (Entry<String, PersistenceUnitConfigurer> entry : 
remainingConfigurations.entrySet())
         {
             final PersistenceUnitInfoImpl info = new 
PersistenceUnitInfoImpl(entry.getKey());
 
@@ -220,7 +229,7 @@ public class EntityManagerSourceImpl imp
         return 
getEntityManagerFactory(persistenceUnitName).createEntityManager();
     }
 
-    public void registryDidShutdown()
+    private void registryDidShutdown()
     {
         final Set<Entry<String, EntityManagerFactory>> entrySet = 
entityManagerFactories.entrySet();
 
@@ -230,8 +239,7 @@ public class EntityManagerSourceImpl imp
             try
             {
                 emf.close();
-            }
-            catch (final Exception e)
+            } catch (final Exception e)
             {
                 logger.error(String.format(
                         "Failed to close EntityManagerFactory for persistence 
unit '%s'",
@@ -245,7 +253,7 @@ public class EntityManagerSourceImpl imp
 
     public List<PersistenceUnitInfo> getPersistenceUnitInfos()
     {
-        return Collections.<PersistenceUnitInfo> 
unmodifiableList(persistenceUnitInfos);
+        return 
Collections.<PersistenceUnitInfo>unmodifiableList(persistenceUnitInfos);
     }
 
 }

Modified: 
tapestry/tapestry5/trunk/tapestry-jpa/src/main/java/org/apache/tapestry5/jpa/JpaModule.java
URL: 
http://svn.apache.org/viewvc/tapestry/tapestry5/trunk/tapestry-jpa/src/main/java/org/apache/tapestry5/jpa/JpaModule.java?rev=1183527&r1=1183526&r2=1183527&view=diff
==============================================================================
--- 
tapestry/tapestry5/trunk/tapestry-jpa/src/main/java/org/apache/tapestry5/jpa/JpaModule.java
 (original)
+++ 
tapestry/tapestry5/trunk/tapestry-jpa/src/main/java/org/apache/tapestry5/jpa/JpaModule.java
 Fri Oct 14 22:03:31 2011
@@ -43,26 +43,7 @@ public class JpaModule
     {
         binder.bind(JpaTransactionAdvisor.class, 
JpaTransactionAdvisorImpl.class);
         binder.bind(PersistenceUnitConfigurer.class, 
PackageNamePersistenceUnitConfigurer.class).withSimpleId();
-    }
-
-    public static EntityManagerSource buildEntityManagerSource(final Logger 
logger,
-
-                                                               
@Symbol(JpaSymbols.PERSISTENCE_DESCRIPTOR)
-                                                               Resource 
persistenceDescriptor,
-
-                                                               @Local
-                                                               
PersistenceUnitConfigurer persistenceUnitConfigurer,
-
-                                                               final 
Map<String, PersistenceUnitConfigurer> configuration,
-
-                                                               final 
RegistryShutdownHub hub)
-    {
-        final EntityManagerSourceImpl ems = new 
EntityManagerSourceImpl(logger, persistenceDescriptor,
-                persistenceUnitConfigurer, configuration);
-
-        hub.addRegistryShutdownListener(ems);
-
-        return ems;
+        binder.bind(EntityManagerSource.class, EntityManagerSourceImpl.class);
     }
 
     public static JpaEntityPackageManager buildJpaEntityPackageManager(final 
Collection<String> packageNames)

Modified: 
tapestry/tapestry5/trunk/tapestry-spring/src/main/java/org/apache/tapestry5/internal/spring/SpringModuleDef.java
URL: 
http://svn.apache.org/viewvc/tapestry/tapestry5/trunk/tapestry-spring/src/main/java/org/apache/tapestry5/internal/spring/SpringModuleDef.java?rev=1183527&r1=1183526&r2=1183527&view=diff
==============================================================================
--- 
tapestry/tapestry5/trunk/tapestry-spring/src/main/java/org/apache/tapestry5/internal/spring/SpringModuleDef.java
 (original)
+++ 
tapestry/tapestry5/trunk/tapestry-spring/src/main/java/org/apache/tapestry5/internal/spring/SpringModuleDef.java
 Fri Oct 14 22:03:31 2011
@@ -1,4 +1,4 @@
-// Copyright 2007, 2008, 2009, 2010 The Apache Software Foundation
+// Copyright 2007, 2008, 2009, 2010, 2011 The Apache Software Foundation
 //
 // Licensed under the Apache License, Version 2.0 (the "License");
 // you may not use this file except in compliance with the License.
@@ -167,9 +167,9 @@ public class SpringModuleDef implements 
     {
         final CustomizingContextLoader loader = new 
CustomizingContextLoader(customizer);
 
-        final RegistryShutdownListener shutdownListener = new 
RegistryShutdownListener()
+        final Runnable shutdownListener = new Runnable()
         {
-            public void registryDidShutdown()
+            public void run()
             {
                 loader.closeWebApplicationContext(servletContext);
             }

Modified: 
tapestry/tapestry5/trunk/tapestry-upload/src/main/java/org/apache/tapestry5/upload/services/UploadModule.java
URL: 
http://svn.apache.org/viewvc/tapestry/tapestry5/trunk/tapestry-upload/src/main/java/org/apache/tapestry5/upload/services/UploadModule.java?rev=1183527&r1=1183526&r2=1183527&view=diff
==============================================================================
--- 
tapestry/tapestry5/trunk/tapestry-upload/src/main/java/org/apache/tapestry5/upload/services/UploadModule.java
 (original)
+++ 
tapestry/tapestry5/trunk/tapestry-upload/src/main/java/org/apache/tapestry5/upload/services/UploadModule.java
 Fri Oct 14 22:03:31 2011
@@ -65,9 +65,9 @@ public class UploadModule
 
         if (needToAddShutdownListener.getAndSet(false))
         {
-            shutdownHub.addRegistryShutdownListener(new 
RegistryShutdownListener()
+            shutdownHub.addRegistryShutdownListener(new Runnable()
             {
-                public void registryDidShutdown()
+                public void run()
                 {
                     FileCleaner.exitWhenFinished();
                 }


Reply via email to