使用 Lotus Sametime 在 Web 应用程序中实现通知

public void open( String serverName, String loginName, 
String password, String token) 
{
	try {
		this.session = new STSession(	"SessionManager " + 
System.identityHashCode(this));
		session.loadAllComponents();
		session.start();
		this.communityService = (CommunityService) 
session.getCompApi(
					CommunityService.COMP_NAME);
		communityService.addLoginListener(this);
		if (password != null) {
			communityService.loginByPassword(
					serverName, loginName, password);
		} else if (token != null) {
			communityService.loginByToken(
serverName, loginName, token);
		} else {
			communityService.loginAsAnon(
serverName, loginName);
		}
	} catch (DuplicateObjectException e) {
		e.printStackTrace();
	}
}
public void loggedOut(LoginEvent event) {
. . .
}
public void loggedIn(LoginEvent event) {
. . .
}

public class Receiver implements PostServiceListener {
	private PostService postService;
	public Receiver(STSession stSession) {
		postService = (PostService) 
session.getCompApi(PostService.COMP_NAME);
	postService.registerPostType(
SessionManager.SystemAlertEventType);
		postService.registerPostType(
			SessionManager.ServiceRequestEventType);
		postService.addPostServiceListener(this);
	}
	    
public void posted(PostEvent event) 
{
// Event received. Take necessary actions.
. . .
	}

public class Publisher implements PostListener {
	private final static long ResolutionTimeout = 10000L; // msec
	private final static long ResolutionPeriod = 250L; // msec 
	private STSession stSession;
	private PostService postService;
	private GroupResolver groupResolver;
	private RecipientResolver recipientResolver;
	private Vector recipientsInPerson; // STUser objects
	private Vector recipientGroups; // STGroup objects
	private Post message;
	public Publisher(STSession session) {
		stSession = session;
	postService = (PostService) 
stSession.getCompApi(PostService.COMP_NAME);
		postService.registerPostType(
SessionManager.SystemAlertEventType);
		postService.registerPostType(
SessionManager.ServiceRequestEventType);
		recipientsInPerson = new Vector(10);
		recipientGroups = new Vector(5);
		groupResolver = new GroupResolver();
		recipientResolver = new RecipientResolver();
	}
	public void publishEvent( int eventType, String title,
		String body, String recipients) 
{
		message = postService.createPost(eventType);
		message.addPostListener(this);
		message.setMessage(body);
		message.setTitle(title);
		StringTokenizer st = new StringTokenizer(recipients, "##");
		String[] recipient_list = new String[st.countTokens()];
		int i = 0;
		while (st.hasMoreTokens()) {
			recipient_list[i++] = st.nextToken();
		}
		recipientResolver.resolveRecipients(recipient_list);
		Enumeration e = recipientGroups.elements();
		while (e.hasMoreElements()) {
			STGroup stg = (STGroup) e.nextElement();
			groupResolver.resolveGroup(stg);
		}
		message.send();
		recipientsInPerson.removeAllElements();
		recipientGroups.removeAllElements();
	}
. . .
private class RecipientResolver implements ResolveListener{
. . .
private class GroupResolver implements GroupContentListener {
. . .

private class RecipientResolver implements ResolveListener {
	private Resolver resolver;
	private int waitFlag;
	private LookupService lookupService;
	public RecipientResolver() {
		lookupService = (LookupService) 
stSession.getCompApi(LookupService.COMP_NAME);
		resolver = lookupService.createResolver(
false, // Return all matches.
		false, // Non-exhaustive lookup.
		true, // Return resolved users.
	true); // Do return resolved groups.
		resolver.addResolveListener(this);
	}
	public void resolveRecipients(String[] recipients) {
		waitFlag = recipients.length;
		resolver.resolve(recipients);
		long totalSlept = 0;
		while (waitFlag > 0 && totalSlept < ResolutionTimeout) {
			try {
				Thread.sleep(ResolutionPeriod);
				totalSlept += ResolutionPeriod;
			} catch (InterruptedException ie) {
			} finally {
				waitFlag = 0;
			}
		}
	}
	public void resolved(ResolveEvent event) {
		STObject sto = (STObject) event.getResolved();
		addRecipient(sto);
		waitFlag--;
	}
	public void resolveConflict(ResolveEvent event) {
		// More than one match found 
		STObject[] recipients = (STObject[]) 
event.getResolvedList();
		for (int i = 0; i < recipients.length; i++) {
			addRecipient(recipients[i]);
		}
		waitFlag--;
	}
	public void resolveFailed(ResolveEvent event) {
		System.out.println("Resolve failed");
		waitFlag--;
	}
	public void addRecipient(STObject sto) 
	{
		if (sto.getClass().getName().endsWith("STUser")){
			STUser stu = (STUser) sto;
			if (!recipientsInPerson.contains(stu.getId())) 
			{
				message.addUser(stu);
				recipientsInPerson.addElement(stu.getId());
			}
		} else if (sto.getClass().getName().endsWith("STGroup")) {
			recipientGroups.addElement(sto);
		} else {
			System.out.println("Resolved unknown STObject:" + 
sto.getId());
		}
	}
}

private class GroupResolver implements GroupContentListener {
	private GroupContentGetter gcg;
	private int waitFlag;
	private LookupService lookupService;
	public GroupResolver() {
		lookupService = (LookupService) 
stSession.getCompApi(LookupService.COMP_NAME);
		gcg = lookupService.createGroupContentGetter();
		gcg.addGroupContentListener(this);
		waitFlag = 0;
	}
	public void resolveGroup(STGroup group) {
		waitFlag++;
		gcg.queryGroupContent(group);
		long totalSlept = 0;
		while (waitFlag > 0 && totalSlept < ResolutionTimeout) {
			try {
				Thread.sleep(ResolutionPeriod);
				totalSlept += ResolutionPeriod;
			} catch (InterruptedException ie) {
			} finally {
					waitFlag = 0;
			}
		}
	}
	public void queryGroupContentFailed(GroupContentEvent event) {
		System.out.println("Query Group Content failed");
		waitFlag--;
	}
	public void groupContentQueried(GroupContentEvent event) {
		STObject[] sto = event.getGroupContent();
		for (int idx = 0; idx < sto.length; idx++) {
			if (sto[idx].getClass().getName()
.endsWith("STUser")) {
				STUser stu = (STUser) sto[idx];
				if (!recipientsInPerson.contains(stu.getId())) {
					message.addUser(stu);
						recipientsInPerson.addElement(stu.getId());
				}
			} else if (sto.getClass().getName()
.endsWith("STGroup")) {
				STGroup stg = (STGroup) sto[idx];
				resolveGroup(stg);
			}
		}
		waitFlag--;
	}
}

		long totalSlept = 0;
		while (waitFlag > 0 && totalSlept < ResolutionTimeout) {
			try {
				Thread.sleep(ResolutionPeriod);
				totalSlept += ResolutionPeriod;
			} catch (InterruptedException ie) {
			} finally {
					waitFlag = 0;
			}
		}

public void posted(PostEvent event) {
	// Event received. Take necessary actions.
	Post message = event.getPost();
	String messageText = message.getMessage();
	String from = message.getSenderDetails().getDisplayName();
	String subject = message.getTitle();
	String messageType = new Integer(message.getType()).toString();
	message.respond(1, "OK"); // Return receipt
	// Call JavaScript event handler
	String arguments[] = {messageText, from, subject, messageType};
	AgentApplet.callJS("MessageReceived", arguments);
}

public void userResponded(PostEvent event) {
	// Add your reporting logic here
	System.out.println("Message delivered to:" + 
event.getPostedUser().getDisplayName());
}
public void sendToUserFailed(PostEvent event) {
	// Add your reporting logic here
	int reason = event.getReason();
	String recipient = event.getPostedUser().getDisplayName();
	switch (reason) {
		case STError.ST_USER_NOT_FOUND :
			System.out.println("User offline:" + recipient);
			break;
		case STError.ST_POST_TYPE_NOT_REGISTERED :
			System.out.println("User not subscribed:" + recipient);
			break;
		default :
			System.out.println(
				"Send failed:" + reason + " to user:" + recipient);
	}
}

<SCRIPT>
function publishEvent()
{
	var etype = document.AgentApplet
.getStSessionManager().ServiceRequestEventType;
	var rcps = document.inputform.recipients
.options[document.inputform.recipients.selectedIndex].value;
	var title = document.inputform.client.value + "@" 
			+ document.inputform.location.value 
			+ "; Phone:" +  document.inputform.phone.value;
	var body = document.inputform.problem.value;
	document.AgentApplet.getStSessionManager().getPublisher()
.publishEvent(etype, title, body, rcps);
}
</SCRIPT>

public class AgentApplet extends Applet {
	private SessionManager sametimeSession;
	private static Applet currentApplet;
	public void init() {
		currentApplet = this;
. . .
public static String callJS(String methodName, String[] args) {
	try {
		JSObject window = (JSObject) 
JSObject.getWindow(currentApplet);
			Object retVal = window.call(methodName, args);
			if (retVal == null)
				return null;
			if (retVal.toString() == "undefined")
				return null;
			else
				return retVal.toString();
		} catch (JSException jse) {
			System.err.println("Call to JScript::" 
+ methodName + " failed!");
			jse.printStackTrace();
		} catch (Throwable error) {
			System.err.println("Error in JScript:" 
+ error.getMessage());
		}
		return null;
	}