Author: thomas.heute(a)jboss.com Date: 2008-10-27 06:47:05 -0400 (Mon, 27 Oct 2008) New Revision: 12174 Modified: modules/cms/tags/JBP_CMS_1_2_1/cms-jackrabbit/src/main/java/org/jboss/portal/cms/CommandFactory.java modules/cms/tags/JBP_CMS_1_2_1/cms-jackrabbit/src/main/java/org/jboss/portal/cms/impl/jcr/JCRCommandFactory.java modules/cms/tags/JBP_CMS_1_2_1/cms-jackrabbit/src/main/java/org/jboss/portal/cms/impl/jcr/command/AsyncStoreArchiveCommand.java modules/cms/tags/JBP_CMS_1_2_1/cms-jackrabbit/src/main/java/org/jboss/portal/cms/impl/jcr/command/StoreArchiveCommand.java Log: JBPORTAL-2212 - Uploading an archive fails on the slave node Modified: modules/cms/tags/JBP_CMS_1_2_1/cms-jackrabbit/src/main/java/org/jboss/portal/cms/CommandFactory.java =================================================================== --- modules/cms/tags/JBP_CMS_1_2_1/cms-jackrabbit/src/main/java/org/jboss/portal/cms/CommandFactory.java 2008-10-27 10:36:56 UTC (rev 12173) +++ modules/cms/tags/JBP_CMS_1_2_1/cms-jackrabbit/src/main/java/org/jboss/portal/cms/CommandFactory.java 2008-10-27 10:47:05 UTC (rev 12174) @@ -25,10 +25,8 @@ import org.jboss.portal.cms.model.Content; import org.jboss.portal.cms.model.File; import org.jboss.portal.cms.model.Folder; -import org.jboss.portal.cms.CMS; import org.jboss.portal.search.impl.jcr.JCRQuery; -import java.io.InputStream; import java.util.List; import java.util.Locale; @@ -74,9 +72,9 @@ Command createContentCreateNewVersionCommand(List contents, boolean bMakeLive); - Command createStoreArchiveCommand(String sRootPath, InputStream is, String sLanguage); + Command createStoreArchiveCommand(String sRootPath, byte[] archiveBytes, String sLanguage); - Command createAsyncStoreArchiveCommand(CMS cms, String sRootPath, InputStream is, String sLanguage); + Command createAsyncStoreArchiveCommand(String sRootPath, byte[] archiveBytes, String sLanguage); Command createItemExistsCommand(String sPath); Modified: modules/cms/tags/JBP_CMS_1_2_1/cms-jackrabbit/src/main/java/org/jboss/portal/cms/impl/jcr/JCRCommandFactory.java =================================================================== --- modules/cms/tags/JBP_CMS_1_2_1/cms-jackrabbit/src/main/java/org/jboss/portal/cms/impl/jcr/JCRCommandFactory.java 2008-10-27 10:36:56 UTC (rev 12173) +++ modules/cms/tags/JBP_CMS_1_2_1/cms-jackrabbit/src/main/java/org/jboss/portal/cms/impl/jcr/JCRCommandFactory.java 2008-10-27 10:47:05 UTC (rev 12174) @@ -51,12 +51,10 @@ import org.jboss.portal.cms.model.Content; import org.jboss.portal.cms.model.File; import org.jboss.portal.cms.model.Folder; -import org.jboss.portal.cms.CMS; import org.jboss.portal.search.impl.jcr.JCRQuery; import org.jboss.portal.cms.impl.jcr.command.AsyncStoreArchiveCommand; -import java.io.InputStream; import java.util.List; import java.util.Locale; @@ -155,14 +153,14 @@ return new ContentCreateNewVersionCommand(contents, bMakeLive); } - public Command createStoreArchiveCommand(String sRootPath, InputStream is, String sLanguage) + public Command createStoreArchiveCommand(String sRootPath, byte[] archiveBytes, String sLanguage) { - return new StoreArchiveCommand(sRootPath, is, sLanguage); + return new StoreArchiveCommand(sRootPath, archiveBytes, sLanguage); } - public Command createAsyncStoreArchiveCommand(CMS cms, String sRootPath, InputStream is, String sLanguage) + public Command createAsyncStoreArchiveCommand(String sRootPath, byte[] archiveBytes, String sLanguage) { - return new AsyncStoreArchiveCommand(cms,sRootPath, is, sLanguage); + return new AsyncStoreArchiveCommand(sRootPath, archiveBytes, sLanguage); } public Command createItemExistsCommand(String sPath) Modified: modules/cms/tags/JBP_CMS_1_2_1/cms-jackrabbit/src/main/java/org/jboss/portal/cms/impl/jcr/command/AsyncStoreArchiveCommand.java =================================================================== --- modules/cms/tags/JBP_CMS_1_2_1/cms-jackrabbit/src/main/java/org/jboss/portal/cms/impl/jcr/command/AsyncStoreArchiveCommand.java 2008-10-27 10:36:56 UTC (rev 12173) +++ modules/cms/tags/JBP_CMS_1_2_1/cms-jackrabbit/src/main/java/org/jboss/portal/cms/impl/jcr/command/AsyncStoreArchiveCommand.java 2008-10-27 10:47:05 UTC (rev 12174) @@ -22,18 +22,20 @@ ******************************************************************************/ package org.jboss.portal.cms.impl.jcr.command; +import javax.management.MBeanServer; +import javax.management.ObjectName; + import org.apache.log4j.Logger; +import org.jboss.mx.util.MBeanProxy; +import org.jboss.mx.util.MBeanServerLocator; import org.jboss.portal.cms.impl.jcr.JCRCMS; import org.jboss.portal.cms.impl.jcr.JCRCommand; import org.jboss.portal.cms.impl.jcr.JCRCommandContext; +import org.jboss.portal.cms.CMS; import org.jboss.portal.cms.CMSException; -import java.io.InputStream; - -import org.jboss.portal.cms.CMS; - /** * Saves an uploaded archive to the repo. * @@ -47,9 +49,8 @@ private static Logger log = Logger.getLogger(AsyncStoreArchiveCommand.class); String msRootPath; - InputStream mIS; + byte[] archiveBytes; String msLanguage; - CMS cms = null; private Object user = null; private Object approvePublishWorkflow = null; @@ -60,12 +61,11 @@ * @param is * @param sLanguage */ - public AsyncStoreArchiveCommand(CMS cms, String sRootPath, InputStream is, String sLanguage) + public AsyncStoreArchiveCommand(String sRootPath, byte[] archiveBytes, String sLanguage) { this.msRootPath = sRootPath; - this.mIS = is; + this.archiveBytes = archiveBytes; this.msLanguage = sLanguage; - this.cms = cms; } /** @@ -111,7 +111,9 @@ JCRCMS.turnOnWorkflow(); } - JCRCommand storeArchiveCommand = (JCRCommand)cms.getCommandFactory().createStoreArchiveCommand(msRootPath, mIS, msLanguage); + CMS cms = this.findCMSService(); + JCRCommand storeArchiveCommand = (JCRCommand)cms.getCommandFactory(). + createStoreArchiveCommand(msRootPath, archiveBytes, msLanguage); cms.execute(storeArchiveCommand); log.info("Async Processing finished.................."); @@ -123,5 +125,12 @@ log.error("-----------------------------------------------------------------------------"); } } + + //Find the CMS Service for the Asynchronous processing + private CMS findCMSService() throws Exception + { + MBeanServer mbeanServer = MBeanServerLocator.locateJBoss(); + return (CMS)MBeanProxy.get(CMS.class, new ObjectName("portal:service=CMS"), mbeanServer); + } } } \ No newline at end of file Modified: modules/cms/tags/JBP_CMS_1_2_1/cms-jackrabbit/src/main/java/org/jboss/portal/cms/impl/jcr/command/StoreArchiveCommand.java =================================================================== --- modules/cms/tags/JBP_CMS_1_2_1/cms-jackrabbit/src/main/java/org/jboss/portal/cms/impl/jcr/command/StoreArchiveCommand.java 2008-10-27 10:36:56 UTC (rev 12173) +++ modules/cms/tags/JBP_CMS_1_2_1/cms-jackrabbit/src/main/java/org/jboss/portal/cms/impl/jcr/command/StoreArchiveCommand.java 2008-10-27 10:47:05 UTC (rev 12174) @@ -57,7 +57,7 @@ private static Logger log = Logger.getLogger(StoreArchiveCommand.class); String msRootPath; - InputStream mIS; + byte[] archiveBytes; String msLanguage; /** @@ -65,10 +65,10 @@ * @param is * @param sLanguage */ - public StoreArchiveCommand(String sRootPath, InputStream is, String sLanguage) + public StoreArchiveCommand(String sRootPath, byte[] archiveBytes, String sLanguage) { this.msRootPath = sRootPath; - this.mIS = is; + this.archiveBytes = archiveBytes; this.msLanguage = sLanguage; } @@ -271,13 +271,8 @@ FileOutputStream fos = new FileOutputStream(zipFile.getCanonicalPath()); try { - int count; - byte[] data = new byte[1024]; - while ((count = this.mIS.read(data, 0, 1024)) != -1) - { - fos.write(data, 0, count); - fos.flush(); - } + fos.write(this.archiveBytes); + fos.close(); } finally {