1 21 22 package org.continuent.sequoia.controller.virtualdatabase.protocol; 23 24 import java.io.Serializable ; 25 import java.sql.SQLException ; 26 27 import org.continuent.sequoia.common.exceptions.VirtualDatabaseException; 28 import org.continuent.sequoia.controller.requestmanager.distributed.DistributedRequestManager; 29 import org.continuent.sequoia.controller.requests.AbstractRequest; 30 31 40 public class NotifyInconsistency extends DistributedRequest 41 { 42 private static final long serialVersionUID = -5744767614853747783L; 43 44 49 public NotifyInconsistency(AbstractRequest request) 50 { 51 super(request); 52 } 53 54 57 public final Object scheduleRequest(DistributedRequestManager drm) 58 throws SQLException 59 { 60 return null; 61 } 62 63 66 public final Serializable executeScheduledRequest( 67 DistributedRequestManager drm) throws SQLException 68 { 69 try 70 { 71 drm.getLogger() 72 .warn( 73 "Disabling all backends after an inconsistency was detected for request " 74 + request.getId() 75 + (request.isAutoCommit() ? "" : " " 76 + request.getTransactionId()) + " " + request); 77 drm.getVirtualDatabase().disableAllBackends(true); 78 } 79 catch (VirtualDatabaseException e) 80 { 81 drm 82 .getLogger() 83 .error( 84 "An error occured while disabling all backends after an inconsistency was detected for request " 85 + request.getId() 86 + (request.isAutoCommit() ? "" : " " 87 + request.getTransactionId()) + " " + request, e); 88 } 89 return null; 90 } 91 92 } | Popular Tags |