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

Java ConnectionStateListener类代码示例

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

本文整理汇总了Java中com.netflix.curator.framework.state.ConnectionStateListener的典型用法代码示例。如果您正苦于以下问题:Java ConnectionStateListener类的具体用法?Java ConnectionStateListener怎么用?Java ConnectionStateListener使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。



ConnectionStateListener类属于com.netflix.curator.framework.state包,在下文中一共展示了ConnectionStateListener类的3个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: createConnectionStateListener

import com.netflix.curator.framework.state.ConnectionStateListener; //导入依赖的package包/类
private ConnectionStateListener createConnectionStateListener() {
	return new ConnectionStateListener() {
		@Override
		public void stateChanged(CuratorFramework client,
				ConnectionState newState) {
			LOGGER.log(Level.INFO,
					"Curator Connection state is changed to " + newState);
			if (newState == ConnectionState.CONNECTED) {
				zkConnected.set(true);
			} else if (newState == ConnectionState.SUSPENDED
					|| newState == ConnectionState.LOST) {
				zkConnected.set(false);
			} else if (newState == ConnectionState.RECONNECTED) {
				zkConnected.set(true);
			}
		}
	};
}
 
开发者ID:pulsarIO,项目名称:jetstream,代码行数:19,代码来源:ZkConnector.java


示例2: createZookeeperConnection

import com.netflix.curator.framework.state.ConnectionStateListener; //导入依赖的package包/类
public static CuratorFramework createZookeeperConnection(String connectString,
		int sessionTimeoutMs, int connectionTimeoutMs, ConnectionStateListener cnxnListener,
		int retrycount, int retryWaitTime, long sessionId, byte[] sessionPwd) throws Exception {
	
	RetryPolicy	retryPolicy = new RetryNTimes(retrycount , retryWaitTime);
		
	ZookeeperFactory factory = new ZooKeeperFactory(sessionId, sessionPwd);
	
	CuratorFramework client = CuratorFrameworkFactory.builder().zookeeperFactory(factory)
			.sessionTimeoutMs(sessionTimeoutMs)
			.connectionTimeoutMs(connectionTimeoutMs)
			.connectString(connectString).retryPolicy(retryPolicy).build();
			
	client.getConnectionStateListenable().addListener(cnxnListener);
	client.start();
	
	return client;
}
 
开发者ID:pulsarIO,项目名称:jetstream,代码行数:19,代码来源:ZooKeeperConnectionUtil.java


示例3: createConnectionStateListener

import com.netflix.curator.framework.state.ConnectionStateListener; //导入依赖的package包/类
private ConnectionStateListener createConnectionStateListener() {
	return new ConnectionStateListener() {
		@Override
		public void stateChanged(CuratorFramework client,
				ConnectionState newState) {
			if (LOGGER.isInfoEnabled())
				LOGGER.info(
						"Curator Connection state is changed to "
								+ newState);

			if (newState == ConnectionState.CONNECTED) {
				m_zkConnected.set(true);
				if (LOGGER.isInfoEnabled())
					LOGGER.info(
							"Zookeeper connected is set to true.");
				new Thread(new OnConnectedTask()).start();

			} else if (newState == ConnectionState.SUSPENDED
					|| newState == ConnectionState.LOST) {
				m_zkConnected.set(false);
				m_rebalanceable.set(false);
				if (LOGGER.isInfoEnabled())
					LOGGER.info(
							"Zookeeper connection is lost and it's now unrebalanceable.");

			} else if (newState == ConnectionState.RECONNECTED) {
				noticeZkReconnected();
				m_zkConnected.set(true);
				m_rebalanceable.set(true);
				if (LOGGER.isInfoEnabled())
					LOGGER.info(
							"Zookeeper is reconnected and it's rebalanceable again.");
			}
		}
	};
}
 
开发者ID:pulsarIO,项目名称:jetstream,代码行数:37,代码来源:KafkaController.java



注:本文中的com.netflix.curator.framework.state.ConnectionStateListener类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。


鲜花

握手

雷人

路过

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

请发表评论

全部评论

专题导读
上一篇:
Java PdfSignatureAppearance类代码示例发布时间:2022-05-22
下一篇:
Java ProjectViewNodeDecorator类代码示例发布时间: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