[virtualcommons-svn] SF.net SVN: virtualcommons:[258] mentalmodels/trunk/src/main/java/edu/asu/ commons/mme/service

[<see...@us...>]

Revision: 258
          http://virtualcommons.svn.sourceforge.net/virtualcommons/?rev=258&view=rev
Author:   seematalele
Date:     2009-08-18 22:14:33 +0000 (Tue, 18 Aug 2009)

Log Message:
-----------
Written code to push student list to the clients.

Modified Paths:
--------------
    mentalmodels/trunk/src/main/java/edu/asu/commons/mme/service/StartGame.java
    mentalmodels/trunk/src/main/java/edu/asu/commons/mme/service/StartupService.java
    mentalmodels/trunk/src/main/java/edu/asu/commons/mme/service/StudentService.java

Modified: mentalmodels/trunk/src/main/java/edu/asu/commons/mme/service/StartGame.java
===================================================================
--- mentalmodels/trunk/src/main/java/edu/asu/commons/mme/service/StartGame.java	2009-08-18 21:56:49 UTC (rev 257)
+++ mentalmodels/trunk/src/main/java/edu/asu/commons/mme/service/StartGame.java	2009-08-18 22:14:33 UTC (rev 258)
@@ -1,5 +1,7 @@
 package edu.asu.commons.mme.service;
 
+import java.util.List;
+
 import edu.asu.commons.mme.entity.Block;
 import edu.asu.commons.mme.entity.Game;
 import edu.asu.commons.mme.entity.ModuleRoundConfig;
@@ -45,9 +47,9 @@
 		return roundService.createGame(game);
 	}
 	
-	public void assignGroups()
+	public List<Student> assignGroups()
 	{
-		studentService.assignGroups();
+		return studentService.assignGroups();
 	}
 
 	/**

Modified: mentalmodels/trunk/src/main/java/edu/asu/commons/mme/service/StartupService.java
===================================================================
--- mentalmodels/trunk/src/main/java/edu/asu/commons/mme/service/StartupService.java	2009-08-18 21:56:49 UTC (rev 257)
+++ mentalmodels/trunk/src/main/java/edu/asu/commons/mme/service/StartupService.java	2009-08-18 22:14:33 UTC (rev 258)
@@ -1,16 +1,18 @@
 package edu.asu.commons.mme.service;
 
+import java.util.ArrayList;
+import java.util.List;
+
 import org.springframework.beans.BeansException;
 import org.springframework.context.ApplicationContext;
 import org.springframework.context.ApplicationContextAware;
-import org.springframework.context.ApplicationEvent;
-import org.springframework.context.ApplicationListener;
-import org.springframework.context.event.ContextRefreshedEvent;
 import org.springframework.transaction.annotation.Transactional;
 
-import edu.asu.commons.mme.dao.HibernateGameDao;
 import edu.asu.commons.mme.entity.Game;
 import edu.asu.commons.mme.entity.Student;
+import flex.messaging.MessageBroker;
+import flex.messaging.messages.AsyncMessage;
+import flex.messaging.util.UUIDUtils;
 
 @Transactional
 public class StartupService implements ApplicationContextAware {
@@ -36,15 +38,32 @@
 	
 	public void assignGroups()
 	{
-		getStartGame().assignGroups();
+		
+		MessageBroker msgBroker = MessageBroker.getMessageBroker(null);
+		String clientID = UUIDUtils.createUUID();
+		AsyncMessage msg = new AsyncMessage();
+		msg.setDestination("DataPush");
+		//msg.setHeader("DSSubtopic", "hello");
+		msg.setClientId(clientID);
+		msg.setMessageId(UUIDUtils.createUUID());
+		msg.setTimestamp(System.currentTimeMillis());
+		List<Student> students = new ArrayList<Student>();
+	
+		msg.setBody(students);
+		System.out.println("Message broker is: "+ msgBroker);
+		System.out.println("Students size is: " + students.size());
+				
+		msgBroker.routeMessageToService(msg, null);
+		
 	}
 	
 	public void startGame() 
 	{
 		//push assign groups to all the students
+		assignGroups();
 		
 		//start the game
-		
+		this.startGame.run();
 	}
 
 	public void stop() {
@@ -65,7 +84,7 @@
 		try{
 			if (startGame == null) {
 				this.startGame = (StartGame)ctx.getBean("startGame");
-				//this.startGame.run();
+				
 			}
 		}catch(Exception e)
 		{

Modified: mentalmodels/trunk/src/main/java/edu/asu/commons/mme/service/StudentService.java
===================================================================
--- mentalmodels/trunk/src/main/java/edu/asu/commons/mme/service/StudentService.java	2009-08-18 21:56:49 UTC (rev 257)
+++ mentalmodels/trunk/src/main/java/edu/asu/commons/mme/service/StudentService.java	2009-08-18 22:14:33 UTC (rev 258)
@@ -26,9 +26,8 @@
 public class StudentService extends Service.Base<Student, HibernateStudentDao> {
 
 	HibernateGroupDao groupDao;
+	private List<Student> studentWithGroupsAssigned = new ArrayList<Student>();
 
-
-
 	private List<Student> students = new ArrayList<Student>();
 
 	public Student createStudent(Student student) {
@@ -44,11 +43,15 @@
 		}
 		else
 			return null;
+		initializeStudent(student);
+
+		return student;
+	}
+
+	private void initializeStudent(Student student) {
 		Hibernate.initialize(student);
 		Hibernate.initialize(student.getGame());
 		Hibernate.initialize(student.getGroup());
-
-		return student;
 	}
 
 	public boolean checkStudentAlreadyExists(Student student)
@@ -63,10 +66,9 @@
 	}
 
 
-	public void assignGroups()
+	public List<Student> assignGroups()
 	{
 		//write an algorithm to form groups
-
 		int totalStudents = students.size();
 		int noOfGroupsWithSize3=0;
 		int noOfGroupsWithSize4=0;
@@ -118,6 +120,7 @@
 			assignGroupstoStudents(3,noOfGroupsWithSize3);
 
 		}
+		return studentWithGroupsAssigned;
 
 	}
 
@@ -140,6 +143,9 @@
 					//assign student no and group to each student
 					student.setStudentNo(studentNo);
 					student.setGroup(grp);
+					save(student);
+					initializeStudent(student);
+					studentWithGroupsAssigned.add(student);
 					students.remove(i);
 				}
 			}


This was sent by the SourceForge.net collaborative development platform, the world's largest Open Source development site.