Changeset 85
- Timestamp:
- 02/27/08 14:50:45 (9 months ago)
- Location:
- trunk/turbomail
- Files:
-
- 3 modified
-
managers/demand.py (modified) (3 diffs)
-
message.py (modified) (5 diffs)
-
providers/smtp.py (modified) (3 diffs)
Legend:
- Unmodified
- Added
- Removed
-
trunk/turbomail/managers/demand.py
r84 r85 11 11 from turbomail.api import Manager 12 12 from turbomail.exceptions import ProviderExhaustedException 13 from turbomail.control import interface as turbomail13 from turbomail.control import interface 14 14 15 15 import math, copy … … 38 38 self.finished = Event() 39 39 40 self.threads = turbomail.config.get("mail.demand.threads", 4) # Maximum number of threads to create.41 self.divisor = turbomail.config.get("mail.demand.divisor", 10) # Estimate the number of required threads by dividing the queue size by this.42 self.timeout = turbomail.config.get("mail.demand.timeout", 60)40 self.threads = interface.config.get("mail.demand.threads", 4) # Maximum number of threads to create. 41 self.divisor = interface.config.get("mail.demand.divisor", 10) # Estimate the number of required threads by dividing the queue size by this. 42 self.timeout = interface.config.get("mail.demand.timeout", 60) 43 43 44 44 log.info("Demand manager ready.") … … 86 86 def worker(self): 87 87 log.debug("Requesting new provider instance from.") 88 provider = turbomail.provider.new()88 provider = interface.provider.new() 89 89 if not provider: raise ManagerException, "Unable to allocate new provider." 90 90 -
trunk/turbomail/message.py
r84 r85 7 7 from turbomail import release 8 8 from turbomail.util import AddressList 9 from turbomail.control import interface as turbomail9 from turbomail.control import interface 10 10 import re, os, email 11 11 … … 63 63 64 64 def configget(name, key, default=None): 65 return kw.get(name, turbomail.config.get(key, default))65 return kw.get(name, interface.config.get(key, default)) 66 66 67 67 self.date = kw.get("date", formatdate(localtime=True)) … … 166 166 assert self.plain, "You must provide plain text content." 167 167 168 if not self._dirty and self._processed and not turbomail.config.get("mail.debug", False):168 if not self._dirty and self._processed and not interface.config.get("mail.debug", False): 169 169 return self._mime 170 170 … … 192 192 ] 193 193 194 if turbomail.config.get("mail.brand", True):194 if interface.config.get("mail.brand", True): 195 195 headers.extend([ 196 196 ('X-Mailer', "%s <%s>" % (release.name, release.url)), … … 198 198 ]) 199 199 200 if turbomail.config.get("mail.debug", False):200 if interface.config.get("mail.debug", False): 201 201 headers.append(('X-TurboMail-Message-GUID', self.id)) 202 202 203 if turbomail.provider:203 if interface.provider: 204 204 headers.extend([ 205 ('X-TurboMail-Provider', "%s <%s>" % ( turbomail.provider.name, turbomail.provider.url)),206 ('X-TurboMail-Provider-Version', turbomail.provider.version),205 ('X-TurboMail-Provider', "%s <%s>" % (interface.provider.name, interface.provider.url)), 206 ('X-TurboMail-Provider-Version', interface.provider.version), 207 207 ]) 208 208 209 if turbomail.manager:209 if interface.manager: 210 210 headers.extend([ 211 ('X-TurboMail-Manager', "%s <%s>" % ( turbomail.manager.name, turbomail.manager.url)),212 ('X-TurboMail-Manager-Version', turbomail.manager.version),211 ('X-TurboMail-Manager', "%s <%s>" % (interface.manager.name, interface.manager.url)), 212 ('X-TurboMail-Manager-Version', interface.manager.version), 213 213 ]) 214 214 -
trunk/turbomail/providers/smtp.py
r84 r85 11 11 from turbomail.api import ProviderFactory, Provider 12 12 from turbomail.exceptions import MailConfigurationError, ProviderExhaustedException 13 from turbomail.control import interface as turbomail13 from turbomail.control import interface 14 14 15 15 from smtplib import SMTP, SMTPRecipientsRefused, SMTPSenderRefused, SMTPServerDisconnected … … 27 27 log.debug("Being created.") 28 28 29 self.server = turbomail.config.get("mail.smtp.server", "localhost")30 self.user = turbomail.config.get("mail.smtp.user", None)31 self.password = turbomail.config.get("mail.smtp.password", None)32 self.tls = turbomail.config.get("mail.smtp.tls", None)33 self.debug = turbomail.config.get("mail.smtp.debug", False)34 self.count = turbomail.config.get("mail.smtp.count", 10) # The number of messages per connection.29 self.server = interface.config.get("mail.smtp.server", "localhost") 30 self.user = interface.config.get("mail.smtp.user", None) 31 self.password = interface.config.get("mail.smtp.password", None) 32 self.tls = interface.config.get("mail.smtp.tls", None) 33 self.debug = interface.config.get("mail.smtp.debug", False) 34 self.count = interface.config.get("mail.smtp.count", 10) # The number of messages per connection. 35 35 36 36 # Defaults to localhost -- if self.server is None: raise MailConfigurationError, "You must define mail.smtp.server in your configuration." … … 99 99 deliverylog.warning("%s DEFERRED %s" % (message.id, e.__class__.__name__)) 100 100 message.tries -= 1 101 turbomail.manager.deliver(message)101 interface.manager.deliver(message) 102 102 return 103 103 else:
