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.hedera.common.Member; 28 import org.continuent.sequoia.common.exceptions.ControllerException; 29 import org.continuent.sequoia.common.users.VirtualDatabaseUser; 30 import org.continuent.sequoia.controller.virtualdatabase.DistributedVirtualDatabase; 31 32 38 public class AddVirtualDatabaseUser extends DistributedVirtualDatabaseMessage 39 { 40 private static final long serialVersionUID = 6636720326759143526L; 41 42 private VirtualDatabaseUser vdbUser; 43 44 49 public AddVirtualDatabaseUser(VirtualDatabaseUser vdbUser) 50 { 51 this.vdbUser = vdbUser; 52 } 53 54 58 public Serializable handleMessageMultiThreaded( 59 DistributedVirtualDatabase dvdb, Member sender, 60 Object handleMessageSingleThreadedResult) 61 { 62 return (Serializable ) handleMessageSingleThreadedResult; 63 } 64 65 69 public Object handleMessageSingleThreaded(DistributedVirtualDatabase dvdb, 70 Member sender) 71 { 72 try 73 { 74 dvdb.performAddVirtualDatabaseUser(vdbUser); 75 } 76 catch (SQLException e) 77 { 78 return new ControllerException(e); 79 } 80 return null; 81 } 82 83 } 84 | Popular Tags |