[portal-commits] JBoss Portal SVN: r6075 - trunk/core/src/main/org/jboss/portal/core/impl/mail.
Author: julien(a)jboss.com
Date: 2007-01-23 08:12:46 -0500 (Tue, 23 Jan 2007)
New Revision: 6075
Modified:
trunk/core/src/main/org/jboss/portal/core/impl/mail/MailModuleImpl.java
Log:
use synchronized long in MailModuleImpl instead of int for the serial id
Modified: trunk/core/src/main/org/jboss/portal/core/impl/mail/MailModuleImpl.java
===================================================================
--- trunk/core/src/main/org/jboss/portal/core/impl/mail/MailModuleImpl.java 2007-01-23
13:00:22 UTC (rev 6074)
+++ trunk/core/src/main/org/jboss/portal/core/impl/mail/MailModuleImpl.java 2007-01-23
13:12:46 UTC (rev 6075)
@@ -26,6 +26,7 @@
import EDU.oswego.cs.dl.util.concurrent.Channel;
import EDU.oswego.cs.dl.util.concurrent.LinkedQueue;
import EDU.oswego.cs.dl.util.concurrent.QueuedExecutor;
+import EDU.oswego.cs.dl.util.concurrent.SynchronizedLong;
import org.apache.log4j.Logger;
import org.jboss.logging.util.LoggerStream;
import org.jboss.portal.core.modules.AbstractModule;
@@ -97,7 +98,7 @@
private LoggerStream logs;
/** A serial id used to track messages locally. */
- private int currentSerialId = 0;
+ private final SynchronizedLong currentSerialId = new SynchronizedLong(0);
public int getSMTPConnectionTimeout()
{
@@ -119,9 +120,9 @@
this.SMTPTimeout = SMTPTimeout;
}
- public int getCurrentSerialId()
+ public long getCurrentSerialId()
{
- return currentSerialId;
+ return currentSerialId.get();
}
public String getGateway()
@@ -297,7 +298,7 @@
}
}
- public boolean deliver(int serialId,
+ public boolean deliver(long serialId,
String from,
String to,
String subject,
@@ -323,7 +324,7 @@
return delivered;
}
- private boolean deliver(int serialId,
+ private boolean deliver(long serialId,
String host,
String from,
String to,
@@ -407,7 +408,7 @@
private class MyMessage
implements Runnable
{
- public final int serialId;
+ public final long serialId;
public final String from;
@@ -422,7 +423,7 @@
String subject,
String body)
{
- this.serialId = currentSerialId++;
+ this.serialId = currentSerialId.increment();
this.from = from;
this.to = to;
this.subject = subject;