Package 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	Description
WorkerMessageHandler(WorkerScheduler scheduler)

Method Summary

Modifier and Type	Method	Description
void	close()
void	connect()
BusinessApplicationRegistry	getBusinessApplicationRegistry()
Set<String>	getLoadedModuleNames()
com.revolsys.websocket.json.JsonAsyncSender	getMessageSender()
boolean	isRunning()
void	moduleChanged(ModuleEvent event)
protected void	moduleStart(com.revolsys.collection.map.MapEx message)
protected void	moduleStop(com.revolsys.collection.map.MapEx message)
protected com.revolsys.collection.map.MapEx	newModuleMessage(Module module, String action)
protected com.revolsys.collection.map.MapEx	newModuleMessage(String moduleName, long moduleTime, String action)
void	onClose(javax.websocket.Session session)
void	onError(javax.websocket.Session session, Throwable e)
void	onMessage(com.revolsys.collection.map.MapEx message)
void	onOpen(javax.websocket.Session session)
void	sendMessage(com.revolsys.collection.map.MapEx 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

Methods inherited from interface com.revolsys.io.BaseCloseable

wrap

Constructor Detail

WorkerMessageHandler

public WorkerMessageHandler(WorkerScheduler scheduler)

Method Detail

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface com.revolsys.io.BaseCloseable

Specified by:

close in interface Closeable

connect

public void connect()

getBusinessApplicationRegistry

public BusinessApplicationRegistry getBusinessApplicationRegistry()

getLoadedModuleNames

public Set<String> getLoadedModuleNames()

getMessageSender

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

isRunning

public boolean isRunning()

moduleChanged

public void moduleChanged(ModuleEvent event)

Specified by:

moduleChanged in interface ModuleEventListener

moduleStart

protected void moduleStart(com.revolsys.collection.map.MapEx message)

moduleStop

protected void moduleStop(com.revolsys.collection.map.MapEx message)

newModuleMessage

protected com.revolsys.collection.map.MapEx newModuleMessage(Module module,
                                                             String action)

newModuleMessage

protected com.revolsys.collection.map.MapEx newModuleMessage(String moduleName,
                                                             long moduleTime,
                                                             String action)

onClose

public void onClose(javax.websocket.Session session)

onError

public void onError(javax.websocket.Session session,
                    Throwable e)

onMessage

public void onMessage(com.revolsys.collection.map.MapEx message)

onOpen

public void onOpen(javax.websocket.Session session)

sendMessage

public void sendMessage(com.revolsys.collection.map.MapEx message)

setModuleNames

public void setModuleNames(List<String> moduleNames)

startApplications

public void startApplications(Module module)

unloadModule

public void unloadModule(ClassLoaderModule module)