Examples of MailQueue


Examples of net.suberic.pooka.MailQueue

  private static int FOLDER_LAST = 5;

  public MainPanel(JFrame frame) {
    session = Pooka.getDefaultSession();

    mailQueue = new MailQueue(Pooka.getDefaultSession());

  }
View Full Code Here

Examples of org.apache.james.queue.api.MailQueue

     *
     * (non-Javadoc)
     * @see org.apache.james.queue.activemq.MailQueueFactory#getQueue(java.lang.String)
     */
    public synchronized final MailQueue getQueue(String name) {
        MailQueue queue = queues.get(name);
        if (queue == null) {
            queue = createMailQueue(name);
            queues.put(name, queue);
        }

View Full Code Here

Examples of org.apache.james.queue.api.MailQueue

public class MockMailQueueFactory implements MailQueueFactory{
    private final Map<String, MailQueue> queues = new HashMap<String, MailQueue>();

    public synchronized MailQueue getQueue(String name) {
        MailQueue queue = queues.get(name);
        if (queue == null) {
            queue = new MockMailQueue();
            queues.put(name, queue);
        }
View Full Code Here

Examples of org.apache.james.queue.api.MailQueue

            /*
      The scheduler service that is used to trigger fetch tasks.
     */
            ScheduledExecutorService scheduler = new JMXEnabledScheduledThreadPoolExecutor(numThreads, jmxPath, "scheduler");
            MailQueue queue = queueFactory.getQueue(MailQueueFactory.SPOOL);

            List<HierarchicalConfiguration> fetchConfs = conf.configurationsAt("fetch");
            for (HierarchicalConfiguration fetchConf : fetchConfs) {
                // read configuration
                Long interval = fetchConf.getLong("interval");
View Full Code Here

Examples of org.apache.james.queue.api.MailQueue

    }

    @Override
    public synchronized final MailQueue getQueue(String name) {
       
        MailQueue queue = queues.get(name);

        if (queue == null) {
            queue = createMailQueue(name);
            if (useJMX) {
                registerMBean(name, queue);
View Full Code Here

Examples of org.apache.james.queue.api.MailQueue

    private final Map<String, MailQueue> queues = new HashMap<String, MailQueue>();

    @Override
    public synchronized MailQueue getQueue(String name) {
        MailQueue queue = queues.get(name);
        if (queue == null) {
            queue = new MockMailQueue();
            queues.put(name, queue);
        }
View Full Code Here

Examples of org.apache.james.queue.api.MailQueue

        this.sync = sync;
    }

    @Override
    public MailQueue getQueue(String name) {
        MailQueue queue = queues.get(name);
        if (queue == null) {
            synchronized (queues) {
                try {
                    queue = new FileMailQueue(fs.getFile("file://var/store/queue"), name, sync, log);
                    queues.put(name, queue);
View Full Code Here

Examples of org.jresearch.gossip.mail.MailQueue

                    Object[] messArgs = new Object[] { newuser.getName(),
                            profile.getPassword(), siteUrl.toString(),
                            config.get(IConst.CONFIG.SITE_NAME) };

                    MailQueue queue = (MailQueue) session.getServletContext()
                            .getAttribute(IConst.CONTEXT.MAIL_QUEUE);
                    queue.push(new MailMessage(messages.getMessage(
                            "mails.NEW_ACCOUNT", messArgs), messages
                            .getMessage("mails.NEW_USER_SUBJ", config
                                    .get(IConst.CONFIG.SITE_NAME)), config
                            .get(IConst.CONFIG.ADMINMAIL), messages
                            .getMessage("mails.FORUM_ADMIN"), newuser.getInfo()
View Full Code Here

Examples of org.jresearch.gossip.mail.MailQueue

                 */
                Object[] messArgs = new Object[] { "", siteUrl.toString(),
                        forward.toString(), tSubj, mess,
                        HtmlCodec.encode(messageForm.getName()),
                        config.get(IConst.CONFIG.SITE_NAME) };
                MailQueue queue = (MailQueue) session.getServletContext()
                        .getAttribute(IConst.CONTEXT.MAIL_QUEUE);

                Iterator it = subscrbe.iterator();
                BanGuard guard = BanGuard.getInstance();
                while (it.hasNext()) {
                    Subscriber s = (Subscriber) it.next();
                    if (!guard.checkBan(s.getEmail(), BanType.EMAIL)) {
                        messArgs[0] = HtmlCodec.encode(s.getName());

                        queue.push(new MailMessage(messages.getMessage(
                                "mails.NEW_MESSAGE", messArgs), messages
                                .getMessage("mails.NEW_MESSAGE_SUBJ"), config
                                .get(IConst.CONFIG.ADMINMAIL), messages
                                .getMessage("mails.FORUM_ADMIN"), s.getEmail(),
                                s.getName()));
View Full Code Here

Examples of org.jresearch.gossip.mail.MailQueue

                        updateduser.getName(), updateduser.getPassword(),
                        siteUrl.toString(),
                        Configurator.getInstance().get(IConst.CONFIG.SITE_NAME)
                    };

                MailQueue queue = (MailQueue) session.getServletContext()
                                                     .getAttribute(IConst.CONTEXT.MAIL_QUEUE);
                queue.push(new MailMessage(messages.getMessage(
                            "mails.NEW_PASSWORD", messArgs),
                        messages.getMessage("global.FORGOTPASS"),
                        Configurator.getInstance().get(IConst.CONFIG.ADMINMAIL),
                        messages.getMessage("mails.FORUM_ADMIN"),
                        updateduser.getInfo().getEmail(), updateduser.getName()));
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.