[jboss-svn-commits] JBL Code SVN: r32971 - labs/jbossrules/branches/remote_implementation_using_hornetq-lucaz/drools-process/drools-process-task/src/main/java/org/drools/task/service/hornetq.

[jboss-svn-commits at lists.jboss.org]

Author: lucazamador
Date: 2010-05-19 16:17:40 -0400 (Wed, 19 May 2010)
New Revision: 32971

Modified:
   labs/jbossrules/branches/remote_implementation_using_hornetq-lucaz/drools-process/drools-process-task/src/main/java/org/drools/task/service/hornetq/BaseHornetQTaskServer.java
   labs/jbossrules/branches/remote_implementation_using_hornetq-lucaz/drools-process/drools-process-task/src/main/java/org/drools/task/service/hornetq/HornetQTaskClientConnector.java
Log:
fixing standalone integration

Modified: labs/jbossrules/branches/remote_implementation_using_hornetq-lucaz/drools-process/drools-process-task/src/main/java/org/drools/task/service/hornetq/BaseHornetQTaskServer.java
===================================================================
--- labs/jbossrules/branches/remote_implementation_using_hornetq-lucaz/drools-process/drools-process-task/src/main/java/org/drools/task/service/hornetq/BaseHornetQTaskServer.java	2010-05-19 19:59:46 UTC (rev 32970)
+++ labs/jbossrules/branches/remote_implementation_using_hornetq-lucaz/drools-process/drools-process-task/src/main/java/org/drools/task/service/hornetq/BaseHornetQTaskServer.java	2010-05-19 20:17:40 UTC (rev 32971)
@@ -125,15 +125,16 @@
 		session = factory.createSession();
 		try {
 			session.createQueue(SERVER_TASK_COMMANDS_QUEUE, SERVER_TASK_COMMANDS_QUEUE, true);
-		} catch (HornetQException e) {
+			consumer = session.createConsumer(SERVER_TASK_COMMANDS_QUEUE);
+			session.start();
+			internalServerRunning = true;
+		}
+		catch (HornetQException e) {
 			if (e.getCode()!=HornetQException.QUEUE_EXISTS) {
 				logger.info(e.getMessage());
 				throw new RuntimeException("Server Exception with class " + getClass() + " using port " + port, e);
 			}
 		}
-		consumer = session.createConsumer(SERVER_TASK_COMMANDS_QUEUE);
-		session.start();
-		internalServerRunning = true;
 	}
 
 	public void stop() throws Exception {

Modified: labs/jbossrules/branches/remote_implementation_using_hornetq-lucaz/drools-process/drools-process-task/src/main/java/org/drools/task/service/hornetq/HornetQTaskClientConnector.java
===================================================================
--- labs/jbossrules/branches/remote_implementation_using_hornetq-lucaz/drools-process/drools-process-task/src/main/java/org/drools/task/service/hornetq/HornetQTaskClientConnector.java	2010-05-19 19:59:46 UTC (rev 32970)
+++ labs/jbossrules/branches/remote_implementation_using_hornetq-lucaz/drools-process/drools-process-task/src/main/java/org/drools/task/service/hornetq/HornetQTaskClientConnector.java	2010-05-19 20:17:40 UTC (rev 32971)
@@ -78,6 +78,17 @@
 				public void run() {
 					try {
 						session.createQueue(name, name, true);
+					}
+					catch (HornetQException e) {
+						switch (e.getCode()) {
+						case HornetQException.QUEUE_EXISTS:
+							logger.info(e.getMessage());
+							break;
+						default:
+							throw new RuntimeException("Client Exception with class " + getClass() + " using port " + port, e);
+						}
+					}
+					try {
 						ClientConsumer consumer = session.createConsumer(name);
 						while (true) {
 							ClientMessage serverMessage = consumer.receive();
@@ -89,7 +100,6 @@
 					catch (HornetQException e) {
 						switch (e.getCode()) {
 						case HornetQException.OBJECT_CLOSED:
-						case HornetQException.QUEUE_EXISTS:
 							logger.info(e.getMessage());
 							break;
 						default: