Ignore:
Timestamp:
09/27/13 17:50:41 (11 years ago)
Author:
stoda
Message:

Semaphores added and removed, ack error discovered and solutioned... Some tests added

Supervisor interface created and more things I'll do later...

TODO: supervisor!!

File:
1 edited

Legend:

Unmodified
Added
Removed
  • branches/supervisor/src/main/java/omq/common/broker/Broker.java

    r83 r91  
    4949        private boolean connectionClosed = false;
    5050        private Properties environment = null;
     51        private RemoteBrokerImpl remoteBrokerImpl;
    5152        private Map<String, RemoteObject> remoteObjs;
    5253        private Map<String, Object> proxies = new Hashtable<String, Object>();
     
    357358        }
    358359
     360        public void setSupervisor(String brokerSet, String brokerName) throws Exception {
     361                remoteBrokerImpl = new RemoteBrokerImpl();
     362                remoteBrokerImpl.startRemoteBroker(brokerSet, brokerName, this, getEnvironment());
     363        }
     364
    359365        public Properties getEnvironment() {
    360366                return environment;
     
    368374                return serializer;
    369375        }
     376
     377        public Map<String, RemoteObject> getRemoteObjs() {
     378                return remoteObjs;
     379        }
     380
    370381}
Note: See TracChangeset for help on using the changeset viewer.