ca.bc.gov.open.cpf.api.worker

Class WorkerMessageHandler

java.lang.Object

ca.bc.gov.open.cpf.api.worker.WorkerMessageHandler

All Implemented Interfaces:

ModuleEventListener, com.revolsys.io.BaseCloseable, Closeable, AutoCloseable, EventListener

public class WorkerMessageHandler
extends Object
implements ModuleEventListener, com.revolsys.io.BaseCloseable

Constructor Summary

Constructors

Constructor and Description
WorkerMessageHandler(WorkerScheduler scheduler)

Method Summary

Modifier and Type	Method and Description
void	close()
void	connect()
BusinessApplicationRegistry	getBusinessApplicationRegistry()
Set<String>	getLoadedModuleNames()
com.revolsys.websocket.json.JsonAsyncSender	getMessageSender()
void	moduleChanged(ModuleEvent event)
protected void	moduleStart(Map<String,Object> message)
protected void	moduleStop(Map<String,Object> message)
protected Map<String,Object>	newModuleMessage(Module module, String action)
protected Map<String,Object>	newModuleMessage(String moduleName, long moduleTime, String action)
void	onClose(javax.websocket.Session session)
void	onMessage(Map<String,Object> message)
void	onOpen(javax.websocket.Session session)
void	sendMessage(Map<String,Object> message)
void	setModuleNames(List<String> moduleNames)
void	startApplications(Module module)
void	unloadModule(ClassLoaderModule module)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

WorkerMessageHandler

public WorkerMessageHandler(WorkerScheduler scheduler)

Method Detail

close

public void close()

Specified by:

close in interface com.revolsys.io.BaseCloseable

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

connect

public void connect()

getBusinessApplicationRegistry

public BusinessApplicationRegistry getBusinessApplicationRegistry()

getLoadedModuleNames

public Set<String> getLoadedModuleNames()

getMessageSender

public com.revolsys.websocket.json.JsonAsyncSender getMessageSender()

moduleChanged

public void moduleChanged(ModuleEvent event)

Specified by:

moduleChanged in interface ModuleEventListener

moduleStart

protected void moduleStart(Map<String,Object> message)

moduleStop

protected void moduleStop(Map<String,Object> message)

newModuleMessage

protected Map<String,Object> newModuleMessage(Module module,
                                              String action)

newModuleMessage

protected Map<String,Object> newModuleMessage(String moduleName,
                                              long moduleTime,
                                              String action)

onClose

public void onClose(javax.websocket.Session session)

onMessage

public void onMessage(Map<String,Object> message)

onOpen

public void onOpen(javax.websocket.Session session)

sendMessage

public void sendMessage(Map<String,Object> message)

setModuleNames

public void setModuleNames(List<String> moduleNames)

startApplications

public void startApplications(Module module)

unloadModule

public void unloadModule(ClassLoaderModule module)