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.requestmanager.distributed.DistributedRequestManager; 28 import org.continuent.sequoia.controller.virtualdatabase.DistributedVirtualDatabase; 29 30 37 public class FailoverForTransaction extends DistributedVirtualDatabaseMessage 38 { 39 private static final long serialVersionUID = 4356953098910034513L; 40 private long transactionId; 41 42 47 public FailoverForTransaction(long transactionId) 48 { 49 this.transactionId = transactionId; 50 } 51 52 57 public long getTransactionId() 58 { 59 return transactionId; 60 } 61 62 66 public Object handleMessageSingleThreaded(DistributedVirtualDatabase dvdb, 67 Member sender) 68 { 69 return null; 70 } 71 72 76 public Serializable handleMessageMultiThreaded( 77 DistributedVirtualDatabase dvdb, Member sender, 78 Object handleMessageSingleThreadedResult) 79 { 80 long controllerId = transactionId 81 & DistributedRequestManager.CONTROLLER_ID_BIT_MASK; 82 83 Long tid = new Long (transactionId); 84 85 dvdb.notifyTransactionFailover(new Long (controllerId), tid); 86 return null; 87 } 88 89 } 90 | Popular Tags |