james-server-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From nor...@apache.org
Subject svn commit: r930337 [3/3] - in /james/server/trunk/spoolmanager/src/main/java/org/apache/james/transport: camel/ mailets/
Date Fri, 02 Apr 2010 17:58:03 GMT
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-unsubscribe@james.apache.org
For additional commands, e-mail: server-dev-help@james.apache.org


Mime
View raw message