Author: amilas
Date: Wed May 16 11:17:05 2007
New Revision: 538674
URL: http://svn.apache.org/viewvc?view=rev&rev=538674
Log:
Synchronizing the receiver.
Modified:
webservices/axis2/branches/java/1_2/modules/kernel/src/org/apache/axis2/transport/mail/SimpleMailListener.java
Modified:
webservices/axis2/branches/java/1_2/modules/kernel/src/org/apache/axis2/transport/mail/SimpleMailListener.java
URL:
http://svn.apache.org/viewvc/webservices/axis2/branches/java/1_2/modules/kernel/src/org/apache/axis2/transport/mail/SimpleMailListener.java?view=diff&rev=538674&r1=538673&r2=538674
==============================================================================
---
webservices/axis2/branches/java/1_2/modules/kernel/src/org/apache/axis2/transport/mail/SimpleMailListener.java
(original)
+++
webservices/axis2/branches/java/1_2/modules/kernel/src/org/apache/axis2/transport/mail/SimpleMailListener.java
Wed May 16 11:17:05 2007
@@ -280,31 +280,32 @@
while (running) {
log.info("Info started polling");
try {
- receiver.connect();
+ synchronized (receiver) {
+ receiver.connect();
- Message[] msgs = receiver.receiveMessages();
+ Message[] msgs = receiver.receiveMessages();
- if ((msgs != null) && (msgs.length > 0)) {
- log.info(msgs.length + " Message(s) Found");
+ if ((msgs != null) && (msgs.length > 0)) {
+ log.info(msgs.length + " Message(s) Found");
- for (int i = 0; i < msgs.length; i++) {
- MimeMessage msg = (MimeMessage) msgs[i];
- try {
- MessageContext mc =
createMessageContextToMailWorker(msg);
- if (mc != null) {
- messageQueue.add(mc);
+ for (int i = 0; i < msgs.length; i++) {
+ MimeMessage msg = (MimeMessage) msgs[i];
+ try {
+ MessageContext mc =
createMessageContextToMailWorker(msg);
+ if (mc != null) {
+ messageQueue.add(mc);
+ }
+ } catch (Exception e) {
+ log.error("Error in SimpleMailListener -
processing mail", e);
+ } finally {
+ // delete mail in any case
+ msg.setFlag(Flags.Flag.DELETED, true);
}
- } catch (Exception e) {
- e.printStackTrace();
- log.error("Error in SimpleMailListener -
processing mail",e);
- } finally {
- // delete mail in any case
- msg.setFlag(Flags.Flag.DELETED, true);
}
}
- }
- receiver.disconnect();
+ receiver.disconnect();
+ }
} catch (Exception e) {
log.error("Error in SimpleMailListener", e);
---------------------------------------------------------------------
To unsubscribe, e-mail: [EMAIL PROTECTED]
For additional commands, e-mail: [EMAIL PROTECTED]
