Package com.sun.messaging.jmq.jmsserver.persist

Examples of com.sun.messaging.jmq.jmsserver.persist.HABrokerInfo

655
656
657
658
659
660
661
662
663
664
665
666
667
668
                    if ( dao.isBeingTakenOver( conn, brokerID ) ) {
                        BrokerException be = new StoreBeingTakenOverException(
                            br.getKString( BrokerResources.E_STORE_BEING_TAKEN_OVER ) );

                        try {
                            HABrokerInfo bkrInfo = dao.getBrokerInfo( conn, brokerID );
                            logger.log( Logger.ERROR, br.getKString(
                                BrokerResources.X_INTERNAL_EXCEPTION,
                                bkrInfo.toString() ), be );
                        } catch (Throwable t) { /* Ignore error */ }

                        throw be;
                    }
                }
View Full Code Here
1161
1162
1163
1164
1165
1166
1167
1168
1169
1170
1171
1172
1173
1174
       * @return the broker id of the takeover broker (or null if there is not
       *      a takeover broker).
       */
        public synchronized String getTakeoverBroker() throws BrokerException
        {
            HABrokerInfo bkrInfo = Globals.getStore().getBrokerInfo(brokerid);
            if (bkrInfo == null) {
                logger.log(Logger.ERROR,
                    BrokerResources.E_BROKERINFO_NOT_FOUND_IN_STORE, brokerid);
                return null;
            }
            takeoverBroker = bkrInfo.getTakeoverBrokerID();
            return takeoverBroker;
        }
View Full Code Here
1519
1520
1521
1522
1523
1524
1525
1526
1527
1528
1529
1530
1531
            Iterator itr = map.entrySet().iterator();

            while (itr.hasNext()) {
                Map.Entry entry = (Map.Entry)itr.next();
                String key = (String)entry.getKey();
                HABrokerInfo bi = (HABrokerInfo)entry.getValue();
                HAClusteredBroker cb =  new HAClusteredBrokerImpl(
                       bi.getId(), bi);
                put(key,cb);
                brokerChanged(ClusterReason.ADDED, cb.getBrokerName(),
                     null, cb, cb.getBrokerSessionUID(), null);
            }
        }
View Full Code Here
1567
1568
1569
1570
1571
1572
1573
1574
1575
1576
1577
1578
1579
1580
1581
            Iterator itr = map.entrySet().iterator();
            while (itr.hasNext()) {
                Map.Entry entry = (Map.Entry)itr.next();
                String key = (String)entry.getKey();
                HABrokerInfo bi = (HABrokerInfo)entry.getValue();
                HAClusteredBrokerImpl impl = (HAClusteredBrokerImpl)get(key);
                if (impl == null) {
                    HAClusteredBroker cb =
                        new HAClusteredBrokerImpl(bi.getId(), bi);
                    put(key,cb);
                    brokerChanged(ClusterReason.ADDED, cb.getBrokerName(),
                         null, cb, cb.getBrokerSessionUID(), null);
                } else { // update
                    // already exists
View Full Code Here
1625
1626
1627
1628
1629
1630
1631
1632
1633
1634
1635
        public Object get(Object key, boolean update) {
            // always check against the backing store
            Object o = super.get(key);
            if (o == null || update) {
                try {
                    HABrokerInfo m= Globals.getStore().getBrokerInfo((String)key);
                    if (m != null && o == null) {
                         HAClusteredBroker cb =  new HAClusteredBrokerImpl(
                           (String)key, m);
                         put(key,cb);
                         brokerChanged(ClusterReason.ADDED, cb.getBrokerName(),
View Full Code Here
TOP

Related Classes of com.sun.messaging.jmq.jmsserver.persist.HABrokerInfo

  • com.sun.messaging.jmq.jmsserver.cluster.ha.HAClusterManagerImpl$HAClusteredBrokerImpl
  • com.sun.messaging.jmq.jmsserver.cluster.ha.HAClusterManagerImpl$HAMap
  • com.sun.messaging.jmq.jmsserver.persist.jdbc.BrokerDAOImpl
  • com.sun.messaging.jmq.jmsserver.persist.jdbc.ConsumerStateDAOImpl
  • com.sun.messaging.jmq.jmsserver.persist.jdbc.DBManager
  • com.sun.messaging.jmq.jmsserver.persist.jdbc.DBTool
  • com.sun.messaging.jmq.jmsserver.persist.jdbc.MessageDAOImpl
  • com.sun.messaging.jmq.jmsserver.persist.jdbc.TransactionDAOImpl
  • com.sun.messaging.jmq.jmsserver.persist.jdbc.UpgradeHAStore
  • com.sun.messaging.jmq.jmsserver.persist.jdbc.Util
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.