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.scheduler.AbstractScheduler; 28 import org.continuent.sequoia.controller.virtualdatabase.DistributedVirtualDatabase; 29 30 41 public class ResumeActivity extends DistributedVirtualDatabaseMessage 42 { 43 private static final long serialVersionUID = 7285174496382359441L; 44 45 48 public ResumeActivity() 49 { 50 } 51 52 56 public Object handleMessageSingleThreaded(DistributedVirtualDatabase dvdb, 57 Member sender) 58 { 59 return null; 60 } 61 62 66 public Serializable handleMessageMultiThreaded( 67 DistributedVirtualDatabase dvdb, Member sender, 68 Object handleMessageSingleThreadedResult) 69 { 70 71 AbstractScheduler scheduler = dvdb.getRequestManager().getScheduler(); 72 scheduler.resumeWritesTransactionsAndPersistentConnections(); 73 return null; 74 } 75 } 76 | Popular Tags |