Inheritance diagram for org.turro.push.sender.PushPoolSender:

Collaboration diagram for org.turro.push.sender.PushPoolSender:

Public Member Functions
	PushPoolSender (AssistantSet assistants, String payload)

void	send (Consumer onFinish)

void	run ()

Detailed Description

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

Definition at line 33 of file PushPoolSender.java.

Constructor & Destructor Documentation

◆ PushPoolSender()

org.turro.push.sender.PushPoolSender.PushPoolSender	(	AssistantSet	assistants,
		String	payload
	)

Definition at line 39 of file PushPoolSender.java.

                                                                  {
     this.assistants = assistants;
     this.payload = payload;
   }

Member Function Documentation

◆ run()

void org.turro.push.sender.PushPoolSender.run ( )

Definition at line 54 of file PushPoolSender.java.

                     {
     //int i = 1, count = assistants.size();
     for (Assistant assistant : assistants) {
       if(assistant.hasContact()) UserPushSubscription.pushMessage(assistant.contact.getId(), payload);
       Logger.getLogger(PushPoolSender.class.getName()).log(Level.INFO, "Pushed message to {0}. Payload: {1}",
           new Object[]{assistant.name, payload});
       //if(count > 20 && ++i < count) Thread.sleep(100); // sleep only when using thread
     }
     if(onFinish != null) {
       try {
         onFinish.accept(null);
       } catch (Exception ex) {
         Logger.getLogger(PushPoolSender.class.getName()).log(Level.SEVERE, ElephantContext.logMsg(null), ex);
       }
     }
   }

Here is the call graph for this function:

Here is the caller graph for this function:

◆ send()

void org.turro.push.sender.PushPoolSender.send ( Consumer onFinish )

Definition at line 44 of file PushPoolSender.java.

                                       {
     this.onFinish = onFinish;
     if(assistants.size() > 20) {
       new Thread(this).start();
     } else {
       run();
     }
   }