--- projects/cms/source/server/uk/org/iscream/cms/server/clientinterface/CorbaControlHandlerServant.java 2001/02/21 19:11:28 1.5 +++ projects/cms/source/server/uk/org/iscream/cms/server/clientinterface/CorbaControlHandlerServant.java 2001/02/28 19:04:00 1.6 @@ -15,7 +15,7 @@ import uk.ac.ukc.iscream.client.*; * !!! Need a way to "shutdown" this class !!! * * @author $Author: tdb $ - * @version $Id: CorbaControlHandlerServant.java,v 1.5 2001/02/21 19:11:28 tdb Exp $ + * @version $Id: CorbaControlHandlerServant.java,v 1.6 2001/02/28 19:04:00 tdb Exp $ */ class CorbaControlHandlerServant extends CorbaControlHandlerPOA { @@ -24,7 +24,7 @@ class CorbaControlHandlerServant extends CorbaControlH /** * The current CVS revision of this class */ - public final String REVISION = "$Revision: 1.5 $"; + public final String REVISION = "$Revision: 1.6 $"; //---STATIC METHODS--- @@ -36,12 +36,14 @@ class CorbaControlHandlerServant extends CorbaControlH * @param packetSorter A reference to the PacketSorter in the component * @param client A reference to the "servant" part of the connecting client. * @param queueMonitorInterval The interval at which to monitor our Queue. + * @param clientname A name to identify the client. */ - public CorbaControlHandlerServant(PacketSorter packetSorter, Client client, int queueMonitorInterval) { + public CorbaControlHandlerServant(PacketSorter packetSorter, Client client, int queueMonitorInterval, String clientname) { _packetSorter = packetSorter; _queueMonitorInterval = queueMonitorInterval; _hostList = ""; _client = client; + _clientname = clientname; _dataHandler = null; _logger.write(toString(), Logger.SYSINIT, "created"); } @@ -60,7 +62,7 @@ class CorbaControlHandlerServant extends CorbaControlH // register the Queue _packetSorter.register(dh.getQueue(), _hostList); // startup a monitor on the DataHandler's queue, every minute - String queueName = _name + " CorbaHandler"; + String queueName = _name + " CorbaHandler:"+_clientname; dh.getQueue().startMonitor(_queueMonitorInterval*1000, _packetSorter.getQueue(), queueName); // start the DataHandler running dh.start(); @@ -173,6 +175,11 @@ class CorbaControlHandlerServant extends CorbaControlH * The interval at which to monitor our Queue */ private int _queueMonitorInterval; + + /** + * A name to identify the client + */ + private String _clientname; //---STATIC ATTRIBUTES---