org.jboss.resource.adapter.mail.inflow: public class: MailActivation

org.jboss.resource.adapter.mail.inflow
public class: MailActivation [javadoc | source]

java.lang.Object
   org.jboss.resource.adapter.mail.inflow.MailActivation

All Implemented Interfaces:
javax.resource.spi.work.Work, Comparable

The MailActivation encapsulates a MailResourceAdapter#endpointActivation javax.resource.spi.ResourceAdapter#endpointActivation(MessageEndpointFactory,javax.resource.spi.ActivationSpec)

author: Scott.Stark - @jboss.org

version: $ - Revision: 71554 $

Field Summary
public static final Method	ON_MESSAGE	The MailListener.onMessage method
protected MailResourceAdapter	ra	The resource adapter
protected MailActivationSpec	spec	The activation spec for the mail folder
protected MessageEndpointFactory	endpointFactory	The message endpoint factory

Constructor:
public MailActivation(MailResourceAdapter ra, MessageEndpointFactory endpointFactory, MailActivationSpec spec) { this.ra = ra; this.endpointFactory = endpointFactory; this.spec = spec; this.trace = log.isTraceEnabled(); }

Constructor:

 public MailActivation(MailResourceAdapter ra,
    MessageEndpointFactory endpointFactory,
    MailActivationSpec spec) {
      this.ra = ra;
      this.endpointFactory = endpointFactory;
      this.spec = spec;
      this.trace = log.isTraceEnabled();
}

Method from org.jboss.resource.adapter.mail.inflow.MailActivation Summary:
compareTo, getNextNewMsgCheckTime, isReleased, release, run, updateNextNewMsgCheckTime

Methods from java.lang.Object:
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method from org.jboss.resource.adapter.mail.inflow.MailActivation Detail:
public int compareTo(Object obj) { MailActivation ma = (MailActivation) obj; long compareTo = nextNewMsgCheckTime - ma.getNextNewMsgCheckTime(); return (int) compareTo; }
public long getNextNewMsgCheckTime() { return nextNewMsgCheckTime; }
public boolean isReleased() { return released; }
public void release() { released = true; if( trace ) log.trace("released"); }
public void run() { released = false; if( trace ) log.trace("Begin new msgs check"); try { MailFolder mailFolder = MailFolder.getInstance(spec); mailFolder.open(); while(mailFolder.hasNext()) { Message msg = (Message) mailFolder.next(); deliverMsg(msg); } mailFolder.close(); } catch (Exception e) { log.error("Failed to execute folder check, spec="+spec); } if( trace ) log.trace("End new msgs check"); }
public void updateNextNewMsgCheckTime(long now) { nextNewMsgCheckTime = now + spec.getPollingInterval(); }