Modified: james/server/trunk/spoolmanager/src/main/java/org/apache/james/transport/mailets/ActiveMQRemoteDelivery.java URL: http://svn.apache.org/viewvc/james/server/trunk/spoolmanager/src/main/java/org/apache/james/transport/mailets/ActiveMQRemoteDelivery.java?rev=930337&r1=930336&r2=930337&view=diff ============================================================================== --- james/server/trunk/spoolmanager/src/main/java/org/apache/james/transport/mailets/ActiveMQRemoteDelivery.java (original) +++ james/server/trunk/spoolmanager/src/main/java/org/apache/james/transport/mailets/ActiveMQRemoteDelivery.java Fri Apr 2 17:58:03 2010 @@ -19,21 +19,22 @@ package org.apache.james.transport.mailets; /** - * RemoteDelivery implementation which use ActiveMQ for the outgoing spooling / queue + * RemoteDelivery implementation which use ActiveMQ for the outgoing spooling / + * queue + * * - * */ -public class ActiveMQRemoteDelivery extends AbstractRemoteDelivery{ +public class ActiveMQRemoteDelivery extends AbstractRemoteDelivery { - @Override - protected String getOutgoingQueueEndpoint(String outgoingQueue) { - return "activemq:queue:"+ outgoingQueue; - } + @Override + protected String getOutgoingQueueEndpoint(String outgoingQueue) { + return "activemq:queue:" + outgoingQueue; + } - @Override - protected String getOutgoingRetryQueueEndpoint(String outgoingRetryQueue) { - return "activemq:queue:"+ outgoingRetryQueue; + @Override + protected String getOutgoingRetryQueueEndpoint(String outgoingRetryQueue) { + return "activemq:queue:" + outgoingRetryQueue; - } + } }
Modified: james/server/trunk/spoolmanager/src/main/java/org/apache/james/transport/mailets/JMSRemoteDelivery.java URL: http://svn.apache.org/viewvc/james/server/trunk/spoolmanager/src/main/java/org/apache/james/transport/mailets/JMSRemoteDelivery.java?rev=930337&r1=930336&r2=930337&view=diff ============================================================================== --- james/server/trunk/spoolmanager/src/main/java/org/apache/james/transport/mailets/JMSRemoteDelivery.java (original) +++ james/server/trunk/spoolmanager/src/main/java/org/apache/james/transport/mailets/JMSRemoteDelivery.java Fri Apr 2 17:58:03 2010 @@ -19,23 +19,24 @@ package org.apache.james.transport.mailets; /** - * RemoteDelivery implementation which use JMS for the outgoing spooling / queue. + * RemoteDelivery implementation which use JMS for the outgoing spooling / + * queue. * * If you use ActiveMQ you should use {...@link ActiveMQRemoteDelivery} * - * + * */ -public class JMSRemoteDelivery extends AbstractRemoteDelivery{ +public class JMSRemoteDelivery extends AbstractRemoteDelivery { - @Override - protected String getOutgoingQueueEndpoint(String outgoingQueue) { - return "jms:queue:"+ outgoingQueue; - } + @Override + protected String getOutgoingQueueEndpoint(String outgoingQueue) { + return "jms:queue:" + outgoingQueue; + } - @Override - protected String getOutgoingRetryQueueEndpoint(String outgoingRetryQueue) { - return "jms:queue:"+ outgoingRetryQueue; + @Override + protected String getOutgoingRetryQueueEndpoint(String outgoingRetryQueue) { + return "jms:queue:" + outgoingRetryQueue; - } + } } Modified: james/server/trunk/spoolmanager/src/main/java/org/apache/james/transport/mailets/ToMultiRepository.java URL: http://svn.apache.org/viewvc/james/server/trunk/spoolmanager/src/main/java/org/apache/james/transport/mailets/ToMultiRepository.java?rev=930337&r1=930336&r2=930337&view=diff ============================================================================== --- james/server/trunk/spoolmanager/src/main/java/org/apache/james/transport/mailets/ToMultiRepository.java (original) +++ james/server/trunk/spoolmanager/src/main/java/org/apache/james/transport/mailets/ToMultiRepository.java Fri Apr 2 17:58:03 2010 @@ -280,34 +280,33 @@ public class ToMultiRepository extends G /** * Get the user inbox: if the repositoryUrl is null then get the userinbox - * from the mailserver, otherwise lookup the store with the given + * from the mailserver, otherwise lookup the store with the given * repositoryurl/type - * + * * @param userName */ private MailRepository getRepository(String userName) { - if (SELECTOR_LOCALPART.equals(repositorySelector)) { - // find the username for delivery to that user - localname, ignore - // the rest - String[] addressParts = userName.split("@"); - userName = addressParts[0]; - } + if (SELECTOR_LOCALPART.equals(repositorySelector)) { + // find the username for delivery to that user - localname, ignore + // the rest + String[] addressParts = userName.split("@"); + userName = addressParts[0]; + } - StringBuffer destinationBuffer = new StringBuffer(192).append( - repositoryUrl).append(userName).append("/"); - String destination = destinationBuffer.toString(); - DefaultConfigurationBuilder mboxConf = new DefaultConfigurationBuilder(); - mboxConf.addProperty("[...@destinationurl]", destination); - mboxConf.addProperty("[...@type]", repositoryType); - MailRepository userInbox; - try { - userInbox = (MailRepository) store.select(mboxConf); - } catch (Exception e) { - log("Cannot open repository " + e); - userInbox = null; - } + StringBuffer destinationBuffer = new StringBuffer(192).append(repositoryUrl).append(userName).append("/"); + String destination = destinationBuffer.toString(); + DefaultConfigurationBuilder mboxConf = new DefaultConfigurationBuilder(); + mboxConf.addProperty("[...@destinationurl]", destination); + mboxConf.addProperty("[...@type]", repositoryType); + MailRepository userInbox; + try { + userInbox = (MailRepository) store.select(mboxConf); + } catch (Exception e) { + log("Cannot open repository " + e); + userInbox = null; + } - return userInbox; - } + return userInbox; + } } --------------------------------------------------------------------- To unsubscribe, e-mail: server-dev-unsubscr...@james.apache.org For additional commands, e-mail: server-dev-h...@james.apache.org
