Java Code Examples for redis.clients.jedis.Jedis


Java Code Examples for redis.clients.jedis.Jedis
The following code examples are extracted from open source projects. You can click


to vote up the examples you like. Your votes will be used in an intelligent system to get more and better code examples. Thanks for your votes!

Code Example 1:
8



From project abiquo, under directory
/model/src/main/java/com/abiquo/server/core/task/.

Source AsyncTaskRep.java

public Task findTask(final String taskId){
Jedis jedis=jedisPool.getResource();
try {
Task task=taskDao.findById(taskId,jedis);
if (task != null) {
task.getJobs().addAll(jobDao.findJobs(taskDao.getTaskJobsEntityKey(task.getIdAsString()),jedis));
}
return task;
}
finally {
jedisPool.returnResource(jedis);
}
}

Code Example 2:
8



From project abiquo, under directory
/model/src/main/java/com/abiquo/server/core/task/.

Source AsyncTaskRep.java

public Task findTaskByJobId(final String jobId){
Jedis jedis=jedisPool.getResource();
try {
Job job=findJob(jobId);
if (job == null) {
return null;
}
return findTask(job.getParentTaskId());
}
finally {
jedisPool.returnResource(jedis);
}
}

Code Example 3:
8



From project abiquo, under directory
/model/src/main/java/com/abiquo/server/core/task/.

Source AsyncTaskRep.java

public Job findJob(final String jobId){
Jedis jedis=jedisPool.getResource();
try {
return jobDao.findById(jobId,jedis);
}
finally {
jedisPool.returnResource(jedis);
}
}

Code Example 4:
8



From project abiquo, under directory
/model/src/main/java/com/abiquo/server/core/task/.

Source CacheEntryRep.java

public CacheEntry find(final String id){
Jedis jedis=jedisPool.getResource();
try {
return entryDao.findById(id,jedis);
}
finally {
jedisPool.returnResource(jedis);
}
}

Code Example 5:
8



From project abiquo, under directory
/vsm/src/main/java/com/abiquo/vsm/migration/.

Source Migrator.java

public void migrateNonPersistedModelFromRedis() throws UnknownHostException, IOException {
RedisDao dao=RedisDaoFactory.getInstance();
Jedis jedis=new Jedis(host,port);
jedis.connect();
jedis.select(database);
long len=jedis.llen(MachineListKey);
for (int i=0; i < len; i++) {
insertMachineFromCSVLine(dao,jedis.lindex(MachineListKey,i));
}
jedis.del(MachineListKey);
jedis.disconnect();
}

Code Example 6:
8



From project abiquo, under directory
/vsm/src/main/java/com/abiquo/vsm/redis/util/.

Source RedisUtils.java

/**
* Pings a redis server.
* @param host The redis host
* @param port The redis port
* @return True on successful ping. Otherwise false.
*/
public static boolean ping(String host,int port){
Jedis client=new Jedis(host,port);
boolean success=false;
try {
client.connect();
success=client.ping().equalsIgnoreCase("pong");
client.disconnect();
}
catch (  IOException e) {
return false;
}
return success;
}

Code Example 7:
7



From project abiquo, under directory
/am/src/main/java/com/abiquo/appliancemanager/web/servlet/.

Source CheckServlet.java

public synchronized boolean checkRedis(){
Jedis redis=null;
try {
redis=REDIS_POOL.getResource();
return "PONG".equalsIgnoreCase(redis.ping());
}
catch (  final JedisConnectionException e) {
return false;
}
finally {
if (redis != null) {
REDIS_POOL.returnResource(redis);
}
}
}

Code Example 8:
7



From project abiquo, under directory
/model/src/main/java/com/abiquo/server/core/task/.

Source AsyncTaskRep.java

public Task save(Task task){
Jedis jedis=jedisPool.getResource();
Transaction transaction=jedis.multi();
boolean discard=true;
try {
for (    Job job : task.getJobs()) {
job.setParentTaskId(task.getTaskId());
jobDao.save(job,transaction);
}
taskDao.save(task,transaction);
transaction.exec();
discard=false;
}
finally {
if (discard) {
transaction.discard();
}
jedisPool.returnResource(jedis);
}
return task;
}

Code Example 9:
7



From project abiquo, under directory
/model/src/main/java/com/abiquo/server/core/task/.

Source AsyncTaskRep.java

public Job save(Job job){
Jedis jedis=jedisPool.getResource();
Transaction transaction=jedis.multi();
boolean discard=true;
try {
jobDao.save(job,transaction);
transaction.exec();
discard=false;
}
finally {
if (discard) {
transaction.discard();
}
jedisPool.returnResource(jedis);
}
return job;
}

Code Example 10:
7



From project abiquo, under directory
/model/src/main/java/com/abiquo/server/core/task/.

Source AsyncTaskRep.java

public void delete(Task task){
Jedis jedis=jedisPool.getResource();
Transaction transaction=jedis.multi();
boolean discard=true;
try {
for (    Job job : task.getJobs()) {
jobDao.delete(job,transaction);
}
taskDao.delete(task,transaction);
transaction.exec();
discard=false;
}
finally {
if (discard) {
transaction.discard();
}
jedisPool.returnResource(jedis);
}
}

Code Example 11:
7



From project abiquo, under directory
/model/src/main/java/com/abiquo/server/core/task/.

Source AsyncTaskRep.java

public List<Task> findTasksByOwnerId(final TaskOwnerType type,final String ownerId){
Jedis jedis=jedisPool.getResource();
try {
List<Task> tasks=taskDao.findByOwnerId(type,ownerId,jedis);
for (    Task task : tasks) {
if (task != null) {
task.getJobs().addAll(jobDao.findJobs(taskDao.getTaskJobsEntityKey(task.getIdAsString()),jedis));
}
}
return tasks;
}
finally {
jedisPool.returnResource(jedis);
}
}

Code Example 12:
7



From project abiquo, under directory
/model/src/main/java/com/abiquo/server/core/task/.

Source CacheEntryRep.java

public CacheEntry save(CacheEntry entry){
Jedis jedis=jedisPool.getResource();
Transaction transaction=jedis.multi();
boolean discard=true;
try {
entryDao.save(entry,transaction);
transaction.exec();
discard=false;
}
finally {
if (discard) {
transaction.discard();
}
jedisPool.returnResource(jedis);
}
return entry;
}

Code Example 13:
7



From project abiquo, under directory
/model/src/main/java/com/abiquo/server/core/task/.

Source CacheEntryRep.java

public void delete(CacheEntry entry){
Jedis jedis=jedisPool.getResource();
Transaction transaction=jedis.multi();
boolean discard=true;
try {
entryDao.delete(entry,transaction);
transaction.exec();
discard=false;
}
finally {
if (discard) {
transaction.discard();
}
jedisPool.returnResource(jedis);
}
}

Code Example 14:
7



From project abiquo, under directory
/vsm/src/main/java/com/abiquo/vsm/redis/pubsub/.

Source RedisSubscriber.java

/**
* Subscribe to redis eventing channel.
*/
@Override public void run(){
try {
Jedis redis=new Jedis(host,port,0);
redis.connect();
running=true;
RedisSubscriberCallback callback=new RedisSubscriberCallback(host,port);
redis.subscribe(callback,EventingChannel);
redis.disconnect();
}
catch (  Exception e) {
RedisDaoFactory.refreshConnectionsPool();
logger.error("Error on redis subscription. {}.",e);
logger.error("VSM is not able to notify events. Please check redis server at {}:{}.",host,port);
}
finally {
running=false;
}
}

Code Example 15:
7



From project abiquo, under directory
/vsm/src/test/java/com/abiquo/vsm/migration/.

Source MigratorTest.java

@Test(enabled=false) public void test_NonPersistedMigration() throws UnknownHostException, IOException {
Jedis jedis=new Jedis(TEST_HOST,TEST_PORT);
jedis.select(TEST_DATABASE);
jedis.connect();
jedis.lpush(Migrator.MachineListKey,"10.60.1.74,8889,root,temp0,XEN_3");
jedis.lpush(Migrator.MachineListKey,"10.60.1.71,443,root,temp1,VMX_04");
jedis.disconnect();
new Migrator(TEST_HOST,TEST_PORT,TEST_DATABASE).migrateNonPersistedModelFromRedis();
jedis.connect();
jedis.select(TEST_DATABASE);
assertFalse(jedis.exists(Migrator.MachineListKey));
jedis.disconnect();
RedisTestDaoFactory.selectDatabase(TEST_HOST,TEST_PORT,TEST_DATABASE);
assertEquals(dao.findAllPhysicalMachines().size(),2);
PhysicalMachine machine0=dao.findPhysicalMachineByAddress("http://10.60.1.74:8889/");
PhysicalMachine machine1=dao.findPhysicalMachineByAddress("http://10.60.1.71:443/");
assertNotNull(machine0);
assertNotNull(machine1);
assertEquals(machine0.getAddress(),"http://10.60.1.74:8889/");
assertEquals(machine0.getType(),"XEN_3");
assertEquals(machine0.getUsername(),"root");
assertEquals(machine0.getPassword(),"temp0");
assertEquals(machine1.getAddress(),"http://10.60.1.71:443/");
assertEquals(machine1.getType(),"VMX_04");
assertEquals(machine1.getUsername(),"root");
assertEquals(machine1.getPassword(),"temp1");
}

Code Example 16:
5



From project abiquo, under directory
/model/src/main/java/com/abiquo/server/core/task/.

Source CacheEntryDAO.java

public CacheEntry findById(final String id,Jedis jedis){
String key=getEntityKey(CacheEntry.class,id);
CacheEntry entry=null;
if (jedis.exists(key)) {
entry=new CacheEntry(id);
entry.getValues().addAll(jedis.lrange(key,0,-1));
}
return entry;
}

Code Example 17:
5



From project abiquo, under directory
/model/src/main/java/com/abiquo/server/core/task/.

Source JobDAO.java

public List<Job> findJobs(final String jobsKey,Jedis jedis){
List<Job> jobs=new LinkedList<Job>();
for (  String jobKey : jedis.lrange(jobsKey,0,-1)) {
Job job=find(jobKey,jedis);
if (job != null) {
jobs.add(job);
}
}
return jobs;
}

Code Example 18:
5



From project abiquo, under directory
/model/src/main/java/com/abiquo/server/core/task/.

Source JobDAO.java

protected Job find(final String jobKey,Jedis jedis){
Map<String,String> hashed=jedis.hgetAll(jobKey);
if (hashed.isEmpty()) {
return null;
}
Job job=new Job();
job.setId(hashed.get("id"));
job.setType(JobType.valueOf(hashed.get("type")));
job.setState(JobState.valueOf(hashed.get("state")));
job.setRollbackState(JobState.valueOf(hashed.get("rollbackState")));
job.setDescription(hashed.get("description"));
job.setTimestamp(Long.parseLong(hashed.get("timestamp")));
job.setParentTaskId(hashed.get("parentTaskId"));
Map<String,String> data=jedis.hgetAll(getJobDataKey(job.getIdAsString()));
if (data != null && !data.isEmpty()) {
job.getData().putAll(data);
}
return job;
}

Code Example 19:
5



From project abiquo, under directory
/model/src/main/java/com/abiquo/server/core/task/.

Source TaskDAO.java

public List<Task> findByOwnerId(final TaskOwnerType type,final String ownerId,Jedis jedis){
List<Task> tasks=new ArrayList<Task>();
String ownerKey=getOwnerTaskEntityKey(type,ownerId);
for (  String taskKey : jedis.lrange(ownerKey,0,-1)) {
Task task=find(taskKey,jedis);
if (task != null) {
tasks.add(task);
}
}
return tasks;
}

Code Example 20:
5



From project abiquo, under directory
/model/src/main/java/com/abiquo/server/core/task/.

Source TaskDAO.java

protected Task find(final String taskKey,Jedis jedis){
Map<String,String> hashed=jedis.hgetAll(taskKey);
if (hashed.isEmpty()) {
return null;
}
Task task=new Task();
task.setOwnerId(hashed.get("ownerId"));
task.setTaskId(hashed.get("taskId"));
task.setUserId(hashed.get("userId"));
task.setType(TaskType.valueOf(hashed.get("type")));
task.setState(TaskState.valueOf(hashed.get("state")));
task.setTimestamp(Long.parseLong(hashed.get("timestamp")));
return task;
}