Java ReplicatedMap类代码示例

OStack程序员社区-中国程序员成长平台 › 门户 › 编程› Java›Java编程经验

原作者: [db:作者] 来自: [db:来源] 收藏邀请

本文整理汇总了Java中org.apache.catalina.tribes.tipis.ReplicatedMap类的典型用法代码示例。如果您正苦于以下问题：Java ReplicatedMap类的具体用法？Java ReplicatedMap怎么用？Java ReplicatedMap使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。

ReplicatedMap类属于org.apache.catalina.tribes.tipis包，在下文中一共展示了ReplicatedMap类的17个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: startInternal

import org.apache.catalina.tribes.tipis.ReplicatedMap; //导入依赖的package包/类
/**
 * Start this component and implement the requirements
 * of {@link org.apache.catalina.util.LifecycleBase#startInternal()}.
 *
 * @exception LifecycleException if this component detects a fatal error
 *  that prevents this component from being used
 */
@Override
protected synchronized void startInternal() throws LifecycleException {

    try {
        CatalinaCluster catclust = (CatalinaCluster)this.getCluster();
        if (this.context == null) this.context = new ReplApplContext(this);
        if ( catclust != null ) {
            ReplicatedMap<String,Object> map =
                    new ReplicatedMap<String,Object>(this,
                            catclust.getChannel(),DEFAULT_REPL_TIMEOUT,
                            getName(),getClassLoaders());
            map.setChannelSendOptions(mapSendOptions);
            ((ReplApplContext)this.context).setAttributeMap(map);
            if (getAltDDName() != null) context.setAttribute(Globals.ALT_DD_ATTR, getAltDDName());
        }
        super.startInternal();
    }  catch ( Exception x ) {
        log.error("Unable to start ReplicatedContext",x);
        throw new LifecycleException("Failed to start ReplicatedContext",x);
    }
}

开发者ID:liaokailin，项目名称:tomcat7，代码行数:29，代码来源:ReplicatedContext.java

示例2: startInternal

import org.apache.catalina.tribes.tipis.ReplicatedMap; //导入依赖的package包/类
/**
 * Start this component and implement the requirements of
 * {@link org.apache.catalina.util.LifecycleBase#startInternal()}.
 *
 * @exception LifecycleException
 *                if this component detects a fatal error that prevents this
 *                component from being used
 */
@Override
protected synchronized void startInternal() throws LifecycleException {
	super.startInternal();
	try {
		CatalinaCluster catclust = (CatalinaCluster) this.getCluster();
		if (catclust != null) {
			ReplicatedMap<String, Object> map = new ReplicatedMap<String, Object>(this, catclust.getChannel(),
					DEFAULT_REPL_TIMEOUT, getName(), getClassLoaders());
			map.setChannelSendOptions(mapSendOptions);
			((ReplApplContext) this.context).setAttributeMap(map);
		}
	} catch (Exception x) {
		log.error("Unable to start ReplicatedContext", x);
		throw new LifecycleException("Failed to start ReplicatedContext", x);
	}
}

开发者ID:how2j，项目名称:lazycat，代码行数:25，代码来源:ReplicatedContext.java

示例3: startInternal

import org.apache.catalina.tribes.tipis.ReplicatedMap; //导入依赖的package包/类
/**
 * Start this component and implement the requirements
 * of {@link org.apache.catalina.util.LifecycleBase#startInternal()}.
 *
 * @exception LifecycleException if this component detects a fatal error
 *  that prevents this component from being used
 */
@SuppressWarnings("unchecked")
@Override
protected synchronized void startInternal() throws LifecycleException {

    try {
        CatalinaCluster catclust = (CatalinaCluster)this.getCluster();
        if (this.context == null) this.context = new ReplApplContext(this);
        if ( catclust != null ) {
            ReplicatedMap map = new ReplicatedMap(this,catclust.getChannel(),DEFAULT_REPL_TIMEOUT,
                                                  getName(),getClassLoaders());
            map.setChannelSendOptions(mapSendOptions);
            ((ReplApplContext)this.context).setAttributeMap(map);
            if (getAltDDName() != null) context.setAttribute(Globals.ALT_DD_ATTR, getAltDDName());
        }
        super.startInternal();
    }  catch ( Exception x ) {
        log.error("Unable to start ReplicatedContext",x);
        throw new LifecycleException("Failed to start ReplicatedContext",x);
    }
}

开发者ID:deathspeeder，项目名称:class-guard，代码行数:28，代码来源:ReplicatedContext.java

示例4: startInternal

import org.apache.catalina.tribes.tipis.ReplicatedMap; //导入依赖的package包/类
/**
 * Start this component and implement the requirements
 * of {@link org.apache.catalina.util.LifecycleBase#startInternal()}.
 *
 * @exception LifecycleException if this component detects a fatal error
 *  that prevents this component from being used
 */
@Override
protected synchronized void startInternal() throws LifecycleException {

    try {
        CatalinaCluster catclust = (CatalinaCluster)this.getCluster();
        if (this.context == null) this.context = new ReplApplContext(this);
        if ( catclust != null ) {
            ReplicatedMap map = new ReplicatedMap(this,catclust.getChannel(),DEFAULT_REPL_TIMEOUT,
                                                  getName(),getClassLoaders());
            map.setChannelSendOptions(mapSendOptions);
            ((ReplApplContext)this.context).setAttributeMap(map);
            if (getAltDDName() != null) context.setAttribute(Globals.ALT_DD_ATTR, getAltDDName());
        }
        super.startInternal();
    }  catch ( Exception x ) {
        log.error("Unable to start ReplicatedContext",x);
        throw new LifecycleException("Failed to start ReplicatedContext",x);
    }
}

开发者ID:WhiteBearSolutions，项目名称:WBSAirback，代码行数:27，代码来源:ReplicatedContext.java

示例5: associate

import org.apache.catalina.tribes.tipis.ReplicatedMap; //导入依赖的package包/类
@Override
protected boolean associate(String ssoId, Session session) {
    boolean result = super.associate(ssoId, session);
    if (result) {
        ((ReplicatedMap<String,SingleSignOnEntry>) cache).replicate(ssoId, true);
    }
    return result;
}

开发者ID:liaokailin，项目名称:tomcat7，代码行数:9，代码来源:ClusterSingleSignOn.java

示例6: update

import org.apache.catalina.tribes.tipis.ReplicatedMap; //导入依赖的package包/类
@Override
protected boolean update(String ssoId, Principal principal, String authType,
        String username, String password) {
    boolean result = super.update(ssoId, principal, authType, username, password);
    if (result) {
        ((ReplicatedMap<String,SingleSignOnEntry>) cache).replicate(ssoId, true);
    }
    return result;
}

开发者ID:liaokailin，项目名称:tomcat7，代码行数:10，代码来源:ClusterSingleSignOn.java

示例7: startInternal

import org.apache.catalina.tribes.tipis.ReplicatedMap; //导入依赖的package包/类
/**
 * Start this component and implement the requirements
 * of {@link org.apache.catalina.util.LifecycleBase#startInternal()}.
 *
 * @exception LifecycleException if this component detects a fatal error
 *  that prevents this component from being used
 */
@Override
protected synchronized void startInternal() throws LifecycleException {
    
    // Load the cluster component, if any
    try {
        if(cluster == null) {
            Container host = getContainer();
            if(host instanceof Host) {
                if(host.getCluster() instanceof CatalinaCluster) {
                    setCluster((CatalinaCluster) host.getCluster());
                }
            }
        }
        if (cluster == null) {
            throw new LifecycleException(
                    "There is no Cluster for ClusterSingleSignOn");
        }

        ClassLoader[] cls = new ClassLoader[] { this.getClass().getClassLoader() };

        ReplicatedMap<String,SingleSignOnEntry> cache =
                new ReplicatedMap<String,SingleSignOnEntry>(
                this, cluster.getChannel(), rpcTimeout, cluster.getClusterName() + "-SSO-cache",
                cls, terminateOnStartFailure);
        cache.setChannelSendOptions(mapSendOptions);
        this.cache = cache;
    } catch (Throwable t) {
        ExceptionUtils.handleThrowable(t);
        throw new LifecycleException(
                "ClusterSingleSignOn exception during clusterLoad " + t);
    }

    super.startInternal();
}

开发者ID:liaokailin，项目名称:tomcat7，代码行数:42，代码来源:ClusterSingleSignOn.java

示例8: stopInternal

import org.apache.catalina.tribes.tipis.ReplicatedMap; //导入依赖的package包/类
/**
 * Stop this component and implement the requirements
 * of {@link org.apache.catalina.util.LifecycleBase#stopInternal()}.
 *
 * @exception LifecycleException if this component detects a fatal error
 *  that prevents this component from being used
 */
@Override
protected synchronized void stopInternal() throws LifecycleException {

    super.stopInternal();

    if (getCluster() != null) {
        ((ReplicatedMap<?,?>) cache).breakdown();
    }
}

开发者ID:liaokailin，项目名称:tomcat7，代码行数:17，代码来源:ClusterSingleSignOn.java

示例9: stopInternal

import org.apache.catalina.tribes.tipis.ReplicatedMap; //导入依赖的package包/类
/**
 * Stop this component and implement the requirements
 * of {@link org.apache.catalina.util.LifecycleBase#stopInternal()}.
 *
 * @exception LifecycleException if this component detects a fatal error
 *  that prevents this component from being used
 */
@Override
protected synchronized void stopInternal() throws LifecycleException {

    Map<String, Object> map = ((ReplApplContext) this.context)
            .getAttributeMap();

    super.stopInternal();

    if ( map!=null && map instanceof ReplicatedMap) {
        ((ReplicatedMap<?, ?>) map).breakdown();
    }

}

开发者ID:liaokailin，项目名称:tomcat7，代码行数:21，代码来源:ReplicatedContext.java

示例10: associate

import org.apache.catalina.tribes.tipis.ReplicatedMap; //导入依赖的package包/类
@Override
protected boolean associate(String ssoId, Session session) {
	boolean result = super.associate(ssoId, session);
	if (result) {
		((ReplicatedMap<String, SingleSignOnEntry>) cache).replicate(ssoId, true);
	}
	return result;
}

开发者ID:how2j，项目名称:lazycat，代码行数:9，代码来源:ClusterSingleSignOn.java

示例11: update

import org.apache.catalina.tribes.tipis.ReplicatedMap; //导入依赖的package包/类
@Override
protected boolean update(String ssoId, Principal principal, String authType, String username, String password) {
	boolean result = super.update(ssoId, principal, authType, username, password);
	if (result) {
		((ReplicatedMap<String, SingleSignOnEntry>) cache).replicate(ssoId, true);
	}
	return result;
}

开发者ID:how2j，项目名称:lazycat，代码行数:9，代码来源:ClusterSingleSignOn.java

示例12: startInternal

import org.apache.catalina.tribes.tipis.ReplicatedMap; //导入依赖的package包/类
/**
 * Start this component and implement the requirements of
 * {@link org.apache.catalina.util.LifecycleBase#startInternal()}.
 *
 * @exception LifecycleException
 *                if this component detects a fatal error that prevents this
 *                component from being used
 */
@Override
protected synchronized void startInternal() throws LifecycleException {

	// Load the cluster component, if any
	try {
		if (cluster == null) {
			Container host = getContainer();
			if (host instanceof Host) {
				if (host.getCluster() instanceof CatalinaCluster) {
					setCluster((CatalinaCluster) host.getCluster());
				}
			}
		}
		if (cluster == null) {
			throw new LifecycleException("There is no Cluster for ClusterSingleSignOn");
		}

		ClassLoader[] cls = new ClassLoader[] { this.getClass().getClassLoader() };

		ReplicatedMap<String, SingleSignOnEntry> cache = new ReplicatedMap<String, SingleSignOnEntry>(this,
				cluster.getChannel(), rpcTimeout, cluster.getClusterName() + "-SSO-cache", cls,
				terminateOnStartFailure);
		cache.setChannelSendOptions(mapSendOptions);
		cache.setAccessTimeout(accessTimeout);
		this.cache = cache;
	} catch (Throwable t) {
		ExceptionUtils.handleThrowable(t);
		throw new LifecycleException("ClusterSingleSignOn exception during clusterLoad " + t);
	}

	super.startInternal();
}

开发者ID:how2j，项目名称:lazycat，代码行数:41，代码来源:ClusterSingleSignOn.java

示例13: stopInternal

import org.apache.catalina.tribes.tipis.ReplicatedMap; //导入依赖的package包/类
/**
 * Stop this component and implement the requirements of
 * {@link org.apache.catalina.util.LifecycleBase#stopInternal()}.
 *
 * @exception LifecycleException
 *                if this component detects a fatal error that prevents this
 *                component from being used
 */
@Override
protected synchronized void stopInternal() throws LifecycleException {

	super.stopInternal();

	if (getCluster() != null) {
		((ReplicatedMap<?, ?>) cache).breakdown();
	}
}

开发者ID:how2j，项目名称:lazycat，代码行数:18，代码来源:ClusterSingleSignOn.java

示例14: stopInternal

import org.apache.catalina.tribes.tipis.ReplicatedMap; //导入依赖的package包/类
/**
 * Stop this component and implement the requirements
 * of {@link org.apache.catalina.util.LifecycleBase#stopInternal()}.
 *
 * @exception LifecycleException if this component detects a fatal error
 *  that prevents this component from being used
 */
@Override
protected synchronized void stopInternal() throws LifecycleException {

    super.stopInternal();

    AbstractMap<String,Object> map =
        ((ReplApplContext)this.context).getAttributeMap();
    if ( map!=null && map instanceof ReplicatedMap) {
        ((ReplicatedMap)map).breakdown();
    }
}

开发者ID:deathspeeder，项目名称:class-guard，代码行数:19，代码来源:ReplicatedContext.java

示例15: stopInternal

import org.apache.catalina.tribes.tipis.ReplicatedMap; //导入依赖的package包/类
/**
 * Stop this component and implement the requirements
 * of {@link org.apache.catalina.util.LifecycleBase#stopInternal()}.
 *
 * @exception LifecycleException if this component detects a fatal error
 *  that prevents this component from being used
 */
@Override
protected synchronized void stopInternal() throws LifecycleException {

    super.stopInternal();

    Map<String,Object> map =
            ((ReplApplContext)this.context).getAttributeMap();
    if ( map!=null && map instanceof ReplicatedMap) {
        ((ReplicatedMap<?,?>)map).breakdown();
    }
}

开发者ID:sdw2330976，项目名称:apache-tomcat-7.0.57，代码行数:19，代码来源:ReplicatedContext.java

示例16: stopInternal

import org.apache.catalina.tribes.tipis.ReplicatedMap; //导入依赖的package包/类
/**
 * Stop this component and implement the requirements
 * of {@link org.apache.catalina.util.LifecycleBase#stopInternal()}.
 *
 * @exception LifecycleException if this component detects a fatal error
 *  that prevents this component from being used
 */
@Override
protected synchronized void stopInternal() throws LifecycleException {
    
    super.stopInternal();

    AbstractMap<String,Object> map =
        ((ReplApplContext)this.context).getAttributeMap();
    if ( map!=null && map instanceof ReplicatedMap) {
        ((ReplicatedMap)map).breakdown();
    }
}

开发者ID:WhiteBearSolutions，项目名称:WBSAirback，代码行数:19，代码来源:ReplicatedContext.java

示例17: stopInternal

import org.apache.catalina.tribes.tipis.ReplicatedMap; //导入依赖的package包/类
/**
 * Stop this component and implement the requirements of
 * {@link org.apache.catalina.util.LifecycleBase#stopInternal()}.
 *
 * @exception LifecycleException
 *                if this component detects a fatal error that prevents this
 *                component from being used
 */
@Override
protected synchronized void stopInternal() throws LifecycleException {

	Map<String, Object> map = ((ReplApplContext) this.context).getAttributeMap();

	super.stopInternal();

	if (map != null && map instanceof ReplicatedMap) {
		((ReplicatedMap<?, ?>) map).breakdown();
	}

}

开发者ID:how2j，项目名称:lazycat，代码行数:21，代码来源:ReplicatedContext.java

注：本文中的org.apache.catalina.tribes.tipis.ReplicatedMap类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。