1 23 24 package org.objectweb.cjdbc.controller.virtualdatabase.protocol; 25 26 import java.sql.SQLException ; 27 28 import org.objectweb.cjdbc.common.sql.AbstractRequest; 29 import org.objectweb.cjdbc.common.sql.AbstractWriteRequest; 30 import org.objectweb.cjdbc.controller.requestmanager.distributed.DistributedRequestManager; 31 32 42 public class UnlogRequest extends DistributedRequest 43 { 44 private static final long serialVersionUID = 6056579752275966631L; 45 46 private long id; 47 48 55 public UnlogRequest(AbstractRequest request, long recoveryLogId) 56 { 57 super(request); 58 this.id = recoveryLogId; 59 } 60 61 64 public final void scheduleRequest(DistributedRequestManager drm) 65 throws SQLException 66 { 67 } 68 69 72 public final Object executeScheduledRequest(DistributedRequestManager drm) 73 throws SQLException 74 { 75 drm.removeFailedRequestFromRecoveryLog((AbstractWriteRequest) request, id); 76 return null; 77 } 78 79 } | Popular Tags |