001/* 002 * (C) Copyright 2006-2014 Nuxeo SA (http://nuxeo.com/) and others. 003 * 004 * Licensed under the Apache License, Version 2.0 (the "License"); 005 * you may not use this file except in compliance with the License. 006 * You may obtain a copy of the License at 007 * 008 * http://www.apache.org/licenses/LICENSE-2.0 009 * 010 * Unless required by applicable law or agreed to in writing, software 011 * distributed under the License is distributed on an "AS IS" BASIS, 012 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. 013 * See the License for the specific language governing permissions and 014 * limitations under the License. 015 */ 016package org.nuxeo.ecm.core.redis; 017 018import java.util.HashSet; 019import java.util.Set; 020 021import org.nuxeo.common.xmap.annotation.XNode; 022import org.nuxeo.common.xmap.annotation.XNodeList; 023import org.nuxeo.common.xmap.annotation.XObject; 024 025import redis.clients.jedis.JedisPoolConfig; 026import redis.clients.jedis.JedisSentinelPool; 027 028@XObject("sentinel") 029public class RedisSentinelDescriptor extends RedisPoolDescriptor { 030 031 @XNodeList(value = "host", type = RedisHostDescriptor[].class, componentType = RedisHostDescriptor.class) 032 public RedisHostDescriptor[] hosts = new RedisHostDescriptor[0]; 033 034 @XNode("master") 035 public String master = "master"; 036 037 @XNode("failoverTimeout") 038 public int failoverTimeout = 300; 039 040 @Override 041 public RedisExecutor newExecutor() throws RuntimeException { 042 RedisExecutor base = new RedisPoolExecutor(new JedisSentinelPool(master, toSentinels(hosts), 043 new JedisPoolConfig(), timeout, password, database)); 044 return new RedisFailoverExecutor(failoverTimeout, base); 045 } 046 047 protected Set<String> toSentinels(RedisHostDescriptor[] hosts) { 048 Set<String> sentinels = new HashSet<String>(); 049 for (RedisHostDescriptor host : hosts) { 050 sentinels.add(host.name + ":" + host.port); 051 } 052 return sentinels; 053 } 054}