• 设为首页
  • 点击收藏
  • 手机版
    手机扫一扫访问
    迪恩网络手机版
  • 关注官方公众号
    微信扫一扫关注
    公众号

Java ReplicatedMap类代码示例

原作者: [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;未经允许,请勿转载。


鲜花

握手

雷人

路过

鸡蛋
该文章已有0人参与评论

请发表评论

全部评论

专题导读
上一篇:
Java SelectOption类代码示例发布时间:2022-05-22
下一篇:
Java NullLocalizable类代码示例发布时间:2022-05-22
热门推荐
阅读排行榜

扫描微信二维码

查看手机版网站

随时了解更新最新资讯

139-2527-9053

在线客服(服务时间 9:00~18:00)

在线QQ客服
地址:深圳市南山区西丽大学城创智工业园
电邮:jeky_zhao#qq.com
移动电话:139-2527-9053

Powered by 互联科技 X3.4© 2001-2213 极客世界.|Sitemap