2009-11-03 20:53:26 +08:00
|
|
|
"""
|
|
|
|
Email backend that writes messages to console instead of sending them.
|
|
|
|
"""
|
|
|
|
import sys
|
|
|
|
import threading
|
|
|
|
|
|
|
|
from django.core.mail.backends.base import BaseEmailBackend
|
|
|
|
|
|
|
|
class EmailBackend(BaseEmailBackend):
|
|
|
|
def __init__(self, *args, **kwargs):
|
|
|
|
self.stream = kwargs.pop('stream', sys.stdout)
|
|
|
|
self._lock = threading.RLock()
|
|
|
|
super(EmailBackend, self).__init__(*args, **kwargs)
|
|
|
|
|
|
|
|
def send_messages(self, email_messages):
|
|
|
|
"""Write all messages to the stream in a thread-safe way."""
|
|
|
|
if not email_messages:
|
|
|
|
return
|
2012-06-23 23:11:15 +08:00
|
|
|
with self._lock:
|
|
|
|
try:
|
|
|
|
stream_created = self.open()
|
|
|
|
for message in email_messages:
|
|
|
|
self.stream.write('%s\n' % message.message().as_string())
|
2012-09-08 03:06:23 +08:00
|
|
|
self.stream.write('-' * 79)
|
2012-06-23 23:11:15 +08:00
|
|
|
self.stream.write('\n')
|
|
|
|
self.stream.flush() # flush after each message
|
|
|
|
if stream_created:
|
|
|
|
self.close()
|
|
|
|
except:
|
|
|
|
if not self.fail_silently:
|
|
|
|
raise
|
2009-11-03 20:53:26 +08:00
|
|
|
return len(email_messages)
|