org.turro.sendable.Sendables Class Reference

Static Public Member Functions
static void	send (IConstructor constructor)
static Collection< Sendable >	getSendables ()
static Sendable	getSendable (String entityPath)
static Collection< SendableAssistant >	getAssistants (String entityPath, boolean all)
static void	cleanOrphans ()
static void	delete (String entityPath)
static void	delivered (String entityPath, String contactId)
static void	sent (String entityPath)

Detailed Description

Author

Lluis Turró Cutiller lluis.nosp@m.@tur.nosp@m.ro.or.nosp@m.g

Definition at line 38 of file Sendables.java.

Member Function Documentation

cleanOrphans()

static void org.turro.sendable.Sendables.cleanOrphans ( )

static

Definition at line 88 of file Sendables.java.

                                    {
    Dao dao = new ElephantPU();
    WhereClause wc = new WhereClause();
    wc.addClause("delete from SendableAssistant");
    wc.addClause("where not exists (");
    wc.addClause("select s from Sendable s");
    wc.addClause("where s.entityPath = entityPath");
    wc.addClause(")");
    dao.executeUpdate(wc);
  }

Here is the call graph for this function:

Here is the caller graph for this function:

delete()

static void org.turro.sendable.Sendables.delete ( String  entityPath )

static

Definition at line 99 of file Sendables.java.

                                               {
    Dao dao = new ElephantPU();
    WhereClause wc = new WhereClause();
    wc.addClause("delete from SendableAssistant");
    wc.addClause("where entityPath = :path");
    wc.addNamedValue("path", entityPath);
    dao.executeUpdate(wc);
    wc = new WhereClause();
    wc.addClause("delete from Sendable");
    wc.addClause("where entityPath = :path");
    wc.addNamedValue("path", entityPath);
    dao.executeUpdate(wc);
  }

Here is the call graph for this function:

Here is the caller graph for this function:

delivered()

static void org.turro.sendable.Sendables.delivered ( String  entityPath, String  contactId  )

static

Definition at line 113 of file Sendables.java.

                                                                    {
    Dao dao = new ElephantPU();
    WhereClause wc = new WhereClause();
    wc.addClause("update SendableAssistant");
    wc.addClause("set delivered = TRUE");
    wc.addClause("where entityPath = :path");
    wc.addNamedValue("path", entityPath);
    wc.addClause("and contactId = :contact");
    wc.addNamedValue("contact", contactId);
    dao.executeUpdate(wc);
  }

Here is the call graph for this function:

Here is the caller graph for this function:

getAssistants()

static Collection<SendableAssistant> org.turro.sendable.Sendables.getAssistants ( String  entityPath, boolean  all  )

static

Definition at line 76 of file Sendables.java.

                                                                                            {
    Dao dao = new ElephantPU();
    WhereClause wc = new WhereClause();
    wc.addClause("select sa from SendableAssistant sa");
    wc.addClause("where sa.entityPath = :path");
    wc.addNamedValue("path", entityPath);
    if(!all) {
      wc.addClause("and sa.delivered = FALSE");
    }
    return dao.getResultList(wc);
  }

Here is the call graph for this function:

Here is the caller graph for this function:

getSendable()

static Sendable org.turro.sendable.Sendables.getSendable ( String  entityPath )

static

Definition at line 67 of file Sendables.java.

                                                        {
    Dao dao = new ElephantPU();
    WhereClause wc = new WhereClause();
    wc.addClause("select s from Sendable s");
    wc.addClause("where s.entityPath = :path");
    wc.addNamedValue("path", entityPath);
    return (Sendable) dao.getSingleResultOrNull(wc);
  }

Here is the call graph for this function:

getSendables()

static Collection<Sendable> org.turro.sendable.Sendables.getSendables ( )

static

Definition at line 57 of file Sendables.java.

                                                    {
    Dao dao = new ElephantPU();
    WhereClause wc = new WhereClause();
    wc.addClause("select s from Sendable s");
    wc.addClause("where s.sent = FALSE");
    wc.addClause("and s.schedule < :now");
    wc.addNamedValue("now", new Date());
    return dao.getResultList(wc);
  }

Here is the call graph for this function:

Here is the caller graph for this function:

send()

static void org.turro.sendable.Sendables.send ( IConstructor  constructor )

static

Definition at line 40 of file Sendables.java.

                                                    {
    boolean lockAcquired = SENDABLE_LOCK.tryLock();
    if(lockAcquired) {
      try {
        for(Sendable sendable : getSendables()) {
          IElephantEntity iee = Entities.getController(sendable.getEntityPath());
          IElephantSendable is = iee.getSendable();
          if(is != null) {
            is.send(constructor);
          }
        }
      } finally {
        SENDABLE_LOCK.unlock();
      }
    }
  }

Here is the call graph for this function:

Here is the caller graph for this function:

sent()

static void org.turro.sendable.Sendables.sent ( String  entityPath )

static

Definition at line 125 of file Sendables.java.

                                             {
    Dao dao = new ElephantPU();
    WhereClause wc = new WhereClause();
    wc.addClause("update Sendable");
    wc.addClause("set sent = TRUE");
    wc.addClause("where entityPath = :path");
    wc.addNamedValue("path", entityPath);
    dao.executeUpdate(wc);
  }

Here is the call graph for this function:

---

The documentation for this class was generated from the following file:

• Sendables.java