From 28b3a604130f296090c03e94aa2c90e0d52a56d9 Mon Sep 17 00:00:00 2001 From: Ezequiel Valencia Date: Fri, 17 Jan 2025 09:14:30 -0500 Subject: [PATCH] Async Message Manager Interface --- .../server/AsyncMessageManagerInterface.java | 14 ++++++++++++++ .../vcell/client/server/AsynchMessageManager.java | 2 +- .../java/cbit/vcell/server/SessionManager.java | 3 ++- 3 files changed, 17 insertions(+), 2 deletions(-) create mode 100644 vcell-core/src/main/java/cbit/vcell/client/server/AsyncMessageManagerInterface.java diff --git a/vcell-core/src/main/java/cbit/vcell/client/server/AsyncMessageManagerInterface.java b/vcell-core/src/main/java/cbit/vcell/client/server/AsyncMessageManagerInterface.java new file mode 100644 index 0000000000..a322d30e3b --- /dev/null +++ b/vcell-core/src/main/java/cbit/vcell/client/server/AsyncMessageManagerInterface.java @@ -0,0 +1,14 @@ +package cbit.vcell.client.server; + +import cbit.rmi.event.*; +import org.vcell.util.DataAccessException; + +public interface AsyncMessageManagerInterface extends SimStatusListener, DataAccessException.Listener,DataJobListenerHolder { + void addVCellMessageEventListener(VCellMessageEventListener listener); + void removeDataJobListener(DataJobListener listener); + void removeExportListener(ExportListener listener); + void removeSimStatusListener(SimStatusListener listener); + void removeSimulationJobStatusListener(SimulationJobStatusListener listener); + void removeVCellMessageEventListener(VCellMessageEventListener listener); + void simStatusChanged(SimStatusEvent simStatusEvent); +} diff --git a/vcell-core/src/main/java/cbit/vcell/client/server/AsynchMessageManager.java b/vcell-core/src/main/java/cbit/vcell/client/server/AsynchMessageManager.java index a7931d8085..463fd94919 100644 --- a/vcell-core/src/main/java/cbit/vcell/client/server/AsynchMessageManager.java +++ b/vcell-core/src/main/java/cbit/vcell/client/server/AsynchMessageManager.java @@ -48,7 +48,7 @@ * {@link AsynchMessageManager} also listens to {@link ClientJobManager} if user stops the simulation, then it will notify TopLevelWindowManager * to update the status. */ -public class AsynchMessageManager implements SimStatusListener, DataAccessException.Listener,DataJobListenerHolder { +public class AsynchMessageManager implements AsyncMessageManagerInterface { private static final long BASE_POLL_SECONDS = 3; private static final long ATTEMPT_POLL_SECONDS = 3; private static Logger lg = LogManager.getLogger(AsynchMessageManager.class); diff --git a/vcell-core/src/main/java/cbit/vcell/server/SessionManager.java b/vcell-core/src/main/java/cbit/vcell/server/SessionManager.java index 9110808bb4..b2a296f48b 100644 --- a/vcell-core/src/main/java/cbit/vcell/server/SessionManager.java +++ b/vcell-core/src/main/java/cbit/vcell/server/SessionManager.java @@ -10,6 +10,7 @@ package cbit.vcell.server; +import cbit.vcell.client.server.AsyncMessageManagerInterface; import org.vcell.util.DataAccessException; import org.vcell.util.document.User; @@ -43,5 +44,5 @@ public interface SessionManager { SimulationController getSimulationController() throws DataAccessException; -AsynchMessageManager getAsynchMessageManager(); +AsyncMessageManagerInterface getAsynchMessageManager(); }