1 21 22 package org.continuent.sequoia.controller.virtualdatabase.protocol; 23 24 import java.io.Serializable ; 25 26 import org.continuent.hedera.common.Member; 27 import org.continuent.sequoia.controller.virtualdatabase.DistributedVirtualDatabase; 28 29 37 public class GetRequestResultFromFailoverCache 38 extends DistributedVirtualDatabaseMessage 39 { 40 private static final long serialVersionUID = 4366642512317344521L; 41 42 private long requestId; 43 44 49 public GetRequestResultFromFailoverCache(long id) 50 { 51 this.requestId = id; 52 } 53 54 58 public Object handleMessageSingleThreaded(DistributedVirtualDatabase dvdb, 59 Member sender) 60 { 61 return null; 62 } 63 64 68 public Serializable handleMessageMultiThreaded( 69 DistributedVirtualDatabase dvdb, Member sender, 70 Object handleMessageSingleThreadedResult) 71 { 72 return dvdb.getRequestResultFailoverCache().retrieve(requestId); 73 } 74 75 } 76 | Popular Tags |