[jboss-svn-commits] JBL Code SVN: r33406 - in labs/jbossrules/branches/salaboy_drools_grid_api_separation/drools-grid/drools-grid-remote-mina: src/main/java/org/drools/grid/remote/mina and 1 other directory.

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

Author: diegoll
Date: 2010-06-08 14:03:28 -0400 (Tue, 08 Jun 2010)
New Revision: 33406

Added:
   labs/jbossrules/branches/salaboy_drools_grid_api_separation/drools-grid/drools-grid-remote-mina/src/main/java/org/drools/grid/remote/mina/MinaNodeRunner.java
Modified:
   labs/jbossrules/branches/salaboy_drools_grid_api_separation/drools-grid/drools-grid-remote-mina/pom.xml
Log:
added main for running as a standalone node

Modified: labs/jbossrules/branches/salaboy_drools_grid_api_separation/drools-grid/drools-grid-remote-mina/pom.xml
===================================================================
--- labs/jbossrules/branches/salaboy_drools_grid_api_separation/drools-grid/drools-grid-remote-mina/pom.xml	2010-06-08 17:47:07 UTC (rev 33405)
+++ labs/jbossrules/branches/salaboy_drools_grid_api_separation/drools-grid/drools-grid-remote-mina/pom.xml	2010-06-08 18:03:28 UTC (rev 33406)
@@ -53,6 +53,29 @@
             <version>4.8.1</version>
             <scope>test</scope>
         </dependency>
+    </dependencies>
 
-    </dependencies>
+  <build>
+    <plugins>
+      <plugin>
+        <inherited>true</inherited>
+        <groupId>org.apache.maven.plugins</groupId>
+        <artifactId>maven-compiler-plugin</artifactId>
+        <configuration>
+          <source>1.5</source>
+          <target>1.5</target>
+          <optimize>true</optimize>
+          <debug>true</debug>
+        </configuration>
+      </plugin>
+      <plugin>
+        <groupId>org.codehaus.mojo</groupId>
+        <artifactId>exec-maven-plugin</artifactId>
+        <configuration>
+          <mainClass>org.drools.grid.remote.mina.MinaNodeRunner</mainClass>
+          <commandlineArgs>-Djava.net.preferIPv4Stack=true</commandlineArgs>
+        </configuration>
+      </plugin>
+    </plugins>
+  </build>
 </project>

Added: labs/jbossrules/branches/salaboy_drools_grid_api_separation/drools-grid/drools-grid-remote-mina/src/main/java/org/drools/grid/remote/mina/MinaNodeRunner.java
===================================================================
--- labs/jbossrules/branches/salaboy_drools_grid_api_separation/drools-grid/drools-grid-remote-mina/src/main/java/org/drools/grid/remote/mina/MinaNodeRunner.java	                        (rev 0)
+++ labs/jbossrules/branches/salaboy_drools_grid_api_separation/drools-grid/drools-grid-remote-mina/src/main/java/org/drools/grid/remote/mina/MinaNodeRunner.java	2010-06-08 18:03:28 UTC (rev 33406)
@@ -0,0 +1,39 @@
+package org.drools.grid.remote.mina;
+
+import java.io.IOException;
+import java.net.InetSocketAddress;
+import java.net.SocketAddress;
+
+import org.apache.mina.transport.socket.SocketAcceptor;
+import org.apache.mina.transport.socket.nio.NioSocketAcceptor;
+import org.drools.SystemEventListenerFactory;
+import org.drools.grid.internal.GenericMessageHandlerImpl;
+import org.drools.grid.internal.NodeData;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+public class MinaNodeRunner {
+
+	private static Logger logger = LoggerFactory.getLogger(MinaNodeRunner.class);
+	
+	public static void main(String[] args) throws IOException {
+		logger.info("server starting");
+		SocketAddress address = new InetSocketAddress("127.0.0.1", 9123);
+		NodeData nodeData = new NodeData();
+		// setup Server
+		SocketAcceptor acceptor = new NioSocketAcceptor();
+		acceptor.setHandler(new MinaIoHandler(SystemEventListenerFactory.getSystemEventListener(),
+							new GenericMessageHandlerImpl(nodeData,
+									SystemEventListenerFactory.getSystemEventListener())));
+		
+       final MinaAcceptor minaAcceptor = new MinaAcceptor(acceptor, address);
+       Runtime.getRuntime().addShutdownHook(new Thread() {
+           public void run() {
+               minaAcceptor.stop();
+               logger.info("server stoped...");
+           }
+        });
+       minaAcceptor.start();
+       logger.info("server started at "+ address.toString() +" ... (ctrl-c to stop it)");
+	}
+}