Skip to content

Commit

Permalink
Browse files Browse the repository at this point in the history
  • Loading branch information
manzarul.haque committed Sep 25, 2017
2 parents 020f610 + b70654b commit 93e9a49
Show file tree
Hide file tree
Showing 4 changed files with 529 additions and 69 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -28,7 +28,7 @@ public SchedularActor() {
public void onReceive(Object message) throws Throwable {
if (message instanceof Request) {
try {
ProjectLogger.log("BulkUploadBackGroundJobActor onReceive called");
ProjectLogger.log("SchedularActor onReceive called");
Request actorMessage = (Request) message;
if (actorMessage.getOperation().equalsIgnoreCase(ActorOperations.SCHEDULE_BULK_UPLOAD.getValue())) {
schedule(actorMessage);
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -1813,7 +1813,7 @@ private Map<String, Object> getUserDetails(Request actorMessage) {
private void blockUser(Request actorMessage) {

ProjectLogger.log("Method call "+"deleteUser");
Util.DbInfo usrDbInfo = Util.dbInfoMap.get(JsonKey.USER_DB);
Util.DbInfo usrDbInfo = Util.dbInfoMap.get(JsonKey.USER_DB);
Map<String , Object> userMap=(Map<String, Object>) actorMessage.getRequest().get(JsonKey.USER);
if(ProjectUtil.isNull(userMap.get(JsonKey.USER_ID))) {
ProjectCommonException exception = new ProjectCommonException(
Expand Down
5 changes: 4 additions & 1 deletion actors/src/main/resources/cassandra.cql
Original file line number Diff line number Diff line change
Expand Up @@ -557,4 +557,7 @@ updatedDate text, updatedBy text, isDeleted boolean, PRIMARY KEY (id));

CREATE INDEX inx_un_userId ON sunbird.user_notes(userId);
CREATE INDEX inx_un_courseId ON sunbird.user_notes(courseId);
CREATE INDEX inx_un_contentId ON sunbird.user_notes(contentId);
CREATE INDEX inx_un_contentId ON sunbird.user_notes(contentId);

//Sept 25th 2017
ALTER TABLE sunbird.user ADD createdBy text;
Loading

0 comments on commit 93e9a49

Please sign in to comment.