Author: norman
Date: Wed May 26 05:54:56 2010
New Revision: 948330
URL: http://svn.apache.org/viewvc?rev=948330&view=rev
Log:
Fix broken RemoteDelivery, which was unable to send messages to external
addresses
Modified:
james/server/trunk/spoolmanager/src/main/java/org/apache/james/transport/mailets/AbstractRemoteDelivery.java
Modified:
james/server/trunk/spoolmanager/src/main/java/org/apache/james/transport/mailets/AbstractRemoteDelivery.java
URL:
http://svn.apache.org/viewvc/james/server/trunk/spoolmanager/src/main/java/org/apache/james/transport/mailets/AbstractRemoteDelivery.java?rev=948330&r1=948329&r2=948330&view=diff
==============================================================================
---
james/server/trunk/spoolmanager/src/main/java/org/apache/james/transport/mailets/AbstractRemoteDelivery.java
(original)
+++
james/server/trunk/spoolmanager/src/main/java/org/apache/james/transport/mailets/AbstractRemoteDelivery.java
Wed May 26 05:54:56 2010
@@ -1553,12 +1553,12 @@ public abstract class AbstractRemoteDeli
@Override
public void configure() throws Exception {
from(getOutgoingQueueEndpoint(outgoingQueue)).inOnly().transacted()
-
- .process(new
DeliveryProcessor()).choice().when(header(JamesCamelConstants.JAMES_RETRY_DELIVERY).isNotNull()).to(getOutgoingRetryQueueEndpoint(outgoingRetryQueue)).otherwise().process(disposeProcessor).stop().end();
+ .beanRef("mailEnricher")
+ .process(new
DeliveryProcessor()).choice().when(header(JamesCamelConstants.JAMES_RETRY_DELIVERY).isNotNull()).to(getOutgoingRetryQueueEndpoint(outgoingRetryQueue)).otherwise().beanRef("mailClaimCheck").process(disposeProcessor).stop().end();
fromF("pollingjms:queue?delay=30000&consumer.endpointUri=%s",
getOutgoingRetryQueueEndpoint(outgoingRetryQueue)).inOnly().transacted()
-
- .process(new
DeliveryProcessor()).choice().when(header(JamesCamelConstants.JAMES_RETRY_DELIVERY).isNotNull()).toF(getOutgoingRetryQueueEndpoint(outgoingRetryQueue)).otherwise().process(disposeProcessor).stop().end();
+ .beanRef("mailEnricher")
+ .process(new
DeliveryProcessor()).choice().when(header(JamesCamelConstants.JAMES_RETRY_DELIVERY).isNotNull()).beanRef("mailClaimCheck").toF(getOutgoingRetryQueueEndpoint(outgoingRetryQueue)).otherwise().process(disposeProcessor).stop().end();
}
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
