org.turro.message.MessageQueue Class Reference

Inheritance diagram for org.turro.message.MessageQueue:

Collaboration diagram for org.turro.message.MessageQueue:

Public Member Functions
String	getIntervalCall (IConstructor constructor)
	MessageQueue ()
Public Member Functions inherited from org.turro.elephant.direct.AbstractDirectContentCtrl
	AbstractDirectContentCtrl (String tmplRoot)
String	createFormAction ()
String	createPOST (String values)
String	getAjaxSubmitUrl (String containerId)
String	getAjaxUrl (String containerId, String values)
String	getAjaxUrl (String containerId, KeyValueMap values)
String	getAjaxEvalUrl (KeyValueMap values)
String	createRightNowURL (String values)
String	createRightNowURL (KeyValueMap values)
String	createLinkTo (String link, KeyValueMap values)
String	createURL ()
String	createURL (IConstructor constructor, String values)
String	createURL (IConstructor constructor, String values, int daysValid)
String	createURL (IConstructor constructor, String values, int daysValid, boolean withDomain)
String	createURL (IConstructor constructor, IContact recipe, String values, int daysValid, boolean withDomain)
String	createURL (IConstructor constructor, IContact recipe, KeyValueMap values, int daysValid, boolean withDomain)
void	setTemplate (String template)
void	render (IConstructor constructor)
String	parse (IConstructor constructor)
boolean	itsMe (String id)
boolean	myTurn (HttpServletRequest request)
void	execute (ServletContext context, HttpServletRequest request, HttpServletResponse response)
void	execute (IConstructor constructor)

Static Public Member Functions
static void	pushMessage (IContact contact, String msg)
static String	pollMessage (IContact contact)
static boolean	hasMessage (IContact contact)
static void	pushMessage (String idContact, String msg)
static String	pollMessage (String idContact)
static boolean	hasMessage (String idContact)
static void	pushGenerics (String idContact)
static BlockingQueue< String >	getQueue (IContact contact)
static BlockingQueue< String >	getQueue (String idContact)

Protected Member Functions
String	getIdentifier ()
void	prepareMarker (ElephantMarker marker)
void	prepareCleanMarker (ElephantMarker marker, KeyValueMap map)
void	doExecute (IConstructor constructor, KeyValueMap map)
Protected Member Functions inherited from org.turro.elephant.direct.AbstractDirectContentCtrl
String	getRedirContext (IConstructor constructor, boolean withDomain)
ElephantMarker	getMarker (IConstructor constructor)
ElephantMarker	getCleanMarkerFrom (IConstructor constructor)
void	addContainerId (ElephantMarker marker, boolean container)
String	getTmplRoot ()
String	getTemplate ()
void	writeMarkerToResponse (IConstructor constructor, KeyValueMap map)
void	writeMarkerToResponse (IConstructor constructor, KeyValueMap map, Map extra)
void	setNeedsUser (boolean needsUser)

Additional Inherited Members
Protected Attributes inherited from org.turro.elephant.direct.AbstractDirectContentCtrl
String	template = "full"

Detailed Description

Author

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

Definition at line 51 of file MessageQueue.java.

Constructor & Destructor Documentation

MessageQueue()

org.turro.message.MessageQueue.MessageQueue

(

)

Definition at line 125 of file MessageQueue.java.

                        {
    super("widgets/messages");
    setNeedsUser(true);
  }

Member Function Documentation

doExecute()

void org.turro.message.MessageQueue.doExecute ( IConstructor  constructor, KeyValueMap  map  )

protected

Reimplemented from org.turro.elephant.direct.AbstractDirectContentCtrl.

Definition at line 147 of file MessageQueue.java.

                                                                      {
    String type = map.get("type"),
           userId = map.get("userId");
    if("query".equals(type) && !Strings.isBlank(userId)) {
      Set<String> messages = new HashSet<>();
      while(hasMessage(userId)) {
        messages.add(pollMessage(userId));
      }
      if(!messages.isEmpty()) {
        HashMap extra = new HashMap();
        extra.put("messages", messages);
        writeMarkerToResponse(constructor, map, extra);
      }
    }
  }

getIdentifier()

String org.turro.message.MessageQueue.getIdentifier ( )

protected

Reimplemented from org.turro.elephant.direct.AbstractDirectContentCtrl.

Definition at line 131 of file MessageQueue.java.

                                   {
    return MessageQueue.class.getAnnotation(DirectContent.class).identifier();
  }

getIntervalCall()

String org.turro.message.MessageQueue.getIntervalCall

(

IConstructor

constructor

)

Definition at line 77 of file MessageQueue.java.

                                                          {
    IContact user = constructor.getUser();
    if(user != null) {
      KeyValueMap map = new KeyValueMap();
      map.put("userId", user.getId());
      map.put("type", "query");
      return getAjaxEvalUrl(map);
    } else {
      return null;
    }
  }

Here is the call graph for this function:

getQueue() [1/2]

static BlockingQueue<String> org.turro.message.MessageQueue.getQueue ( IContact  contact )

static

Definition at line 115 of file MessageQueue.java.

                                                                 {
    return getQueue(contact.getId());
  }

Here is the call graph for this function:

getQueue() [2/2]

static BlockingQueue<String> org.turro.message.MessageQueue.getQueue ( String  idContact )

static

Definition at line 119 of file MessageQueue.java.

                                                                 {
    return QUEUE_MAP.computeIfAbsent(idContact, k -> new LinkedBlockingQueue<String>());
  }

hasMessage() [1/2]

static boolean org.turro.message.MessageQueue.hasMessage ( IContact  contact )

static

Definition at line 61 of file MessageQueue.java.

                                                     {
    return !(getQueue(contact).isEmpty());
  }

hasMessage() [2/2]

static boolean org.turro.message.MessageQueue.hasMessage ( String  idContact )

static

Definition at line 73 of file MessageQueue.java.

                                                     {
    return !(getQueue(idContact).isEmpty());
  }

pollMessage() [1/2]

static String org.turro.message.MessageQueue.pollMessage ( IContact  contact )

static

Definition at line 57 of file MessageQueue.java.

                                                     {
    return getQueue(contact).poll();
  }

pollMessage() [2/2]

static String org.turro.message.MessageQueue.pollMessage ( String  idContact )

static

Definition at line 69 of file MessageQueue.java.

                                                     {
    return getQueue(idContact).poll();
  }

prepareCleanMarker()

void org.turro.message.MessageQueue.prepareCleanMarker ( ElephantMarker  marker, KeyValueMap  map  )

protected

Reimplemented from org.turro.elephant.direct.AbstractDirectContentCtrl.

Definition at line 141 of file MessageQueue.java.

                                                                            {
    setTemplate("toast");
    marker.putAll(map);
  }

Here is the call graph for this function:

prepareMarker()

void org.turro.message.MessageQueue.prepareMarker ( ElephantMarker  marker )

protected

Reimplemented from org.turro.elephant.direct.AbstractDirectContentCtrl.

Definition at line 136 of file MessageQueue.java.

                                                      {
    setTemplate("init");
  }

pushGenerics()

static void org.turro.message.MessageQueue.pushGenerics ( String  idContact )

static

Definition at line 93 of file MessageQueue.java.

                                                    {
    Path folder = Path.of(ElephantContext.getRealPath(GENERIC_MESSAGE_FOLDER));
    if(Files.exists(folder)) {
      PathMatcher matcher = FileSystems.getDefault().getPathMatcher("glob:**.txt");
      try (Stream<Path> entries = Files.list(folder).filter(p -> matcher.matches(p))) {
        entries.forEach(file -> {
          try {
            pushMessage(idContact, FileUtil.getContent(file.toFile()));
          } catch (IOException ex) {
            Logger.getLogger(MessageQueue.class.getName()).log(Level.SEVERE, ElephantContext.logMsg(null), ex);
          }
        });
      } catch (IOException ex) {
        Logger.getLogger(MessageQueue.class.getName()).log(Level.SEVERE, ElephantContext.logMsg(null), ex);
      }
    }
  }

Here is the call graph for this function:

pushMessage() [1/2]

static void org.turro.message.MessageQueue.pushMessage ( IContact  contact, String  msg  )

static

Definition at line 53 of file MessageQueue.java.

                                                               {
    getQueue(contact).add(msg);
  }

Here is the caller graph for this function:

pushMessage() [2/2]

static void org.turro.message.MessageQueue.pushMessage ( String  idContact, String  msg  )

static

Definition at line 65 of file MessageQueue.java.

                                                               {
    getQueue(idContact).add(msg);
  }

---

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

• MessageQueue.java