You are viewing a plain text version of this content. The canonical link for it is here.
Posted to server-dev@james.apache.org by no...@apache.org on 2010/04/02 19:58:03 UTC
svn commit: r930337 [3/3] - in
/james/server/trunk/spoolmanager/src/main/java/org/apache/james/transport:
camel/ mailets/
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