package push;import members.Members;import java.util.Vector;import java.util.StringTokenizer;/** * Handling of user selected push services * * @version 1.0 * @since 1.0 * @see Runnable */public final class PushService implements Runnable {    private final PushInitiator pusher;    private final String serviceContextPath;    /**     * interval in hours between Push message submissions     */    private final int interval;    private final String addressType;    public static final String SI_CONTENT_TYPE = "text/vnd.wap.si";    /**     * Creates a new <code>PushService</code> instance.     *     * @param pusher a <code>PushInitiator</code> value     * @param serviceContextPath a <code>String</code> value     * @param interval an <code>int</code> value; in hours     */    public PushService(PushInitiator pusher, String serviceContextPath, String addressType, int interval) {	this.pusher = pusher;	this.serviceContextPath = serviceContextPath;	this.interval = interval; 	this.addressType = addressType;    }    /**     * A push service checker thread sends push messages related to ordered services     */    public void run() {	while(true){	    try {		Vector users = User.getUsersOnline();		for(int i=0; i<users.size(); i++) {		    User user = (User)users.get(i);		    String name = user.getName();		    String pushServices = user.getPushServices();		    /* Check if the user has selected push services. If so, then generate 		       and send (if not yet sent within a time interval) a push message! */		    if (pushServices != null){			StringTokenizer st = new StringTokenizer(pushServices, ";");			while (st.hasMoreTokens()){			    int serviceId = Integer.parseInt(st.nextToken());			    Object pushService = Members.getPushService(serviceId);			    String serviceName =  ((String[])pushService)[0];			    String serviceUrl =  ((String[])pushService)[1];			    Object serviceObject = user.getProperty(serviceName); 			    if(serviceObject != null) {				if((System.currentTimeMillis() - ((Long)serviceObject).longValue()) > 				   interval*1000*60*60)				    /* If there are more hours than specified by the interval variable 				       from the previous submission, the service message is ready to				       be sent again.*/				    serviceObject = null;			    }			    if (serviceObject == null) {				String url = serviceContextPath + serviceUrl;				String message = PushInitiator.createSiMessage(url, null, null, null,									       null, serviceName);				String address = user.getAddress(addressType);				System.out.println(message);				System.out.println("client Address = " + address);				if(address != null && !address.trim().equals("")) {				    try {				   					pusher.sendPushMessage(address, addressType, message, SI_CONTENT_TYPE);					user.setProperty(serviceName, new Long(System.currentTimeMillis()));				    }				    catch(Exception ee) {					System.err.println("Error in sending push message!");				    }				}			    }			}		    }		}	    }	    catch(Exception e) { e.printStackTrace(); }	    try {		Thread.sleep(10000); // 10 s	    } catch(InterruptedException e){}	}    }}