Java Message Service
by Eric J. Bruno

Listing One

package emaildemo;
import javax.jms.*;
import javax.naming.*;

public class EmailSender 
{
    private Connection connection = null;
    private Session session = null;
    private MessageProducer prod = null;

    public EmailSender()
    {
        try {
            InitialContext jndi = new InitialContext();
           // Lookup a JMS connection factory
           ConnectionFactory conFactory =
                (ConnectionFactory)jndi.lookup("ConnectionFactory");
            // Create a JMS connection
            connection = conFactory.createConnection("","");
            // Create a JMS session object
            session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
            // Get the JMS queue that represents the simulated inbox
           Destination inbox = (Destination)jndi.lookup("Inbox");
           if ( inbox == null )
                inbox = session.createQueue("Inbox");
            // Create a producer to place messages into the inbox
            prod = session.createProducer(inbox);
            // The Connection must be started for messages to fly
            connection.start();
        }
        catch ( Exception e ) {
            e.printStackTrace();
        }
    }
    public void sendEmail(String subject, String body) throws Exception
    { ... }
    public static void main(String[] args) 
    { ... }
}



1


