Outjected

Session session = (Session) entityManager.getDelegate(); Criteria criteria = session.createCriteria(Task.class); criteria.add(Restrictions.eq("assignee", myUser)); criteria.add(Restrictions.isNull("dateClosed")); List<Task> tasks = criteria.list();

CriteriaBuilder cb = em.getCriteriaBuilder(); CriteriaQuery<Task> cq = cb.createQuery(Task.class); Root<Task> root = cq.from(Task.class); List<Predicate> predicates = new ArrayList<>(); predicates.add(cb.equal(root.get(Task_.assignee), myUser)); predicates.add(cb.isNull(root.get(Task_.dateClosed)); cq.where(predicates.toArray(new Predicate[predicates.size()])); List<Task> tasks = em.createQuery(cq).getResultList();

<VirtualHost *:80> ServerName foo.outjected.com Redirect / https://foo.outjected.com </VirtualHost> <VirtualHost *:443> SSLEngine on SSLCertificateFile /etc/apache2/ssl/foo.outjected.com.pem ServerName foo.outjected.com ProxyRequests Off ProxyPreserveHost On ProxyPassReverseCookiePath / / ProxyPass /errors/ ! ProxyPass / ajp://localhost:8009/ ProxyPassReverse / ajp://localhost:8009/ ErrorDocument 503 /errors/503.html DocumentRoot /var/www/foo.outjected.com ErrorLog /var/log/apache2/foo.outjected.com_errors.log </VirtualHost>

<?xml version="1.0"?> <!DOCTYPE jboss-web PUBLIC "-//JBoss//DTD Web Application 5.0//EN" "http://www.jboss.org/j2ee/dtd/jboss-web_5_0.dtd"> <jboss-web> <context-root>/</context-root> <virtual-host>foo</virtual-host> </jboss-web>

@ConversationScoped @Named public class CarPricerManager implements Serializable { private static final long serialVersionUID = 1L; @Inject @Active private PriceBook activePriceBook; private CarPricer carPricer; public CarPricer getCarPricer() { if(carPricer == null) { carPricer = new CarPricer(); carPricer.setPriceBook(activePriceBook); } return carPricer; } } public class PriceBooks { @Produces @RequestScoped @Active public PriceBook findActivePriceBook() { return em.createQuery(.....).getSingleResult(); } @Produces @RequestScoped @Named public List<PriceBook> priceBooks() { return em.createQuery(.....).getResultList(); } }

<h:selectOneMenu value="\#{carPricerManager.carPricer.priceBook}" required="true" converter="PriceBookConverter"> <f:selectItem itemLabel="Choose" /> <f:selectItems value="\#{priceBooks}" var="_apb" itemLabel="\#{_apb.name}" /> </h:selectOneMenu>

@RequestScoped public class PriceBooks { private PriceBook activeBook; private List<PriceBook> books; @Produces @Active public PriceBook findActivePriceBook() { if (activeBook == null) activeBook = em.createQuery(.....).getSingleResult(); return activeBook; } @Produces @Named public List<PriceBook> priceBooks() { if (books == null) { books = em.createQuery(.....).getResultList(); return books; } }

import java.util.Properties; import javax.mail.Folder; import javax.mail.Message; import javax.mail.Session; import javax.mail.Store; import javax.mail.URLName; import org.jboss.seam.mail.core.EmailMessage; import org.jboss.seam.mail.util.MessageConverter; import com.sun.mail.pop3.POP3SSLStore; public class Popper { public static void main(String[] args) throws Exception { String SSL_FACTORY = "javax.net.ssl.SSLSocketFactory"; Properties pop3Props = new Properties(); pop3Props.setProperty("mail.pop3.socketFactory.class", SSL_FACTORY); pop3Props.setProperty("mail.pop3.socketFactory.fallback", "false"); pop3Props.setProperty("mail.pop3.port", "995"); pop3Props.setProperty("mail.pop3.socketFactory.port", "995"); URLName url = new URLName("pop3", "pop.example.com", 995, "", "foo@example.com", "mypass"); Session session = Session.getInstance(pop3Props, null); Store store = new POP3SSLStore(session, url); store.connect(); Folder inbox = store.getFolder("INBOX"); inbox.open(Folder.READ_ONLY); Message[] messages = inbox.getMessages(); if (messages.length == 0) { System.out.println("No Messages Found"); } List<EmailMessage> emailMessages = new ArrayList<EmailMessage>(); for (Message m : messages) { emailMessages.add(MessageConverter.convert(m)); } inbox.close(false); store.close(); } }

public class MailTransporterImpl implements MailTransporter { private Session session; public MailTransporterImpl(Session session) { this.session = session; } public EmailMessage send(EmailMessage emailMessage) { MailUtility.send(emailMessage, session); return emailMessage; } }

public class MailQueueTransporter implements Serializable, MailTransporter { private static final long serialVersionUID = 1L; @Inject @QueuedEmail private Event<MimeMessage> queueEvent; @Inject @ExtensionManaged private Instance<Session> session; @Override public EmailMessage send(EmailMessage emailMessage) { MimeMessage msg = MailUtility.createMimeMessage(emailMessage, session.get()); queueEvent.fire(msg); return emailMessage; } }

public class MailQueueReceiver { @Inject private Logger log; public static final String mailQueueFolder = "/var/data/mailQueue/"; public void receiveMessage(@Observes @QueuedEmail MimeMessage msg) { log.debugf("Writing queued message to disk"); OutputStream os; try { os = Files.newOutputStreamSupplier( new File(mailQueueFolder + UUID.randomUUID())).getOutput(); msg.writeTo(os); os.close(); } catch (IOException e) { throw new SendFailedException("Failed to Write Message to Queue", e); } catch (MessagingException e) { throw new SendFailedException(e); } } }

@Singleton
    public class MailQueueSender {
    
        @Inject
        private Logger log;
    
        @Inject
        @ExtensionManaged
        private Session session;
    
        private String mailQueueFolder;
    
        @PostConstruct
        public void postConstruct() {
            mailQueueFolder = MailQueueReceiver.mailQueueFolder;
            File queueFolder = new File(mailQueueFolder);
            session.getProperties().put("mail.smtp.connectiontimeout", 15000);
            session.getProperties().put("mail.smtp.timeout", 15000);
            log.infof("Initialized Mail Queue with %s messages in queue", queueFolder.listFiles().length);
        }
    
        @Schedule(second = "15,45", minute = "*", hour = "*", persistent = false)
        public void sendQueue() throws InterruptedException {
    
            File queueFolder = new File(mailQueueFolder);
            LinkedList<File> files = new LinkedList<File>(Arrays.asList(queueFolder.listFiles()));
    
            while (!files.isEmpty()) {
                File file = files.peek();
                InputStream is;
                try {
                    is = Files.newInputStreamSupplier(file).getInput();
                    RootMimeMessage msg = new RootMimeMessage(session, is);
                    msg.setMessageId(generateMessageId());
                    Transport.send(msg);
                    log.debug("Sent Mail Message: " + msg.getMessageID());
                    is.close();
                    files.pop();
                    file.delete();
                }
                catch (IOException e) {
                    throw new SendFailedException("Failed to read message from Disk: " + file.getName(), e);
                }
                catch (MessagingException e) {
                    throw new SendFailedException("Send Failed for Message: " + file.getName(), e);
                }
            }
        }
    
        private String generateMessageId() {
            String mailerDomainName = session.getProperty("mail.seam.domainName");
            if (mailerDomainName != null && mailerDomainName.length() > 0) {
                return UUID.randomUUID().toString() + "@" + mailerDomainName;
            }
            else {
                return UUID.randomUUID().toString() + "@" + MailUtility.getHostName();
            }
        }
    }

Embrace the JPA 2 Criteria API

A bit of history and a problem statement of sorts

JPA 2 Criteria API to the rescue.

It isn’t however all sunshine and lollipops

Just do it

JBoss AS7 with Apache + SSL

Why would you want to do this?

The Goal

Other details

Let’s do it.

Apache Prep

Setting up the JBoss Server

CDI and JSF aren't Best Friends Yet

Where I started banging my head into the table.

To the code!

Where it goes wrong.

Why it goes wrong.

How can we fix this?

A solutions that work now.

Seam Mail 3.1.1.Final Released

Obligatory Links and Compatibility

Whats new?

What does future look like?

How about an example?

Sending Queued Mail with Seam Mail

The Problem

The Knee-jerk Reaction

You Really Want

The Solution