add mono support.

ziyunhx · Nov 10, 2015 · a21eb36 · a21eb36
1 parent 6612899
commit a21eb36
Show file tree

Hide file tree

Showing 6 changed files with 8 additions and 7 deletions.
diff --git a/Storm.Net.Adapter/ApacheStorm.cs b/Storm.Net.Adapter/ApacheStorm.cs
@@ -94,7 +94,8 @@ public static void SendMsgToParent(string message)
             if (string.IsNullOrEmpty(message))
                 return;
 
-            Console.OutputEncoding = Encoding.UTF8;
+            //fix output bug on mono.
+            //Console.OutputEncoding = Encoding.UTF8;
             Console.WriteLine(message);
             Console.WriteLine("end");
         }

diff --git a/Storm.Net.Adapter/Properties/AssemblyInfo.cs b/Storm.Net.Adapter/Properties/AssemblyInfo.cs
@@ -32,5 +32,5 @@
 // You can specify all the values or you can default the Build and Revision Numbers 
 // by using the '*' as shown below:
 // [assembly: AssemblyVersion("1.0.*")]
-[assembly: AssemblyVersion("1.2.0.1")]
-[assembly: AssemblyFileVersion("1.2.0.1")]
+[assembly: AssemblyVersion("1.3.0.1")]
+[assembly: AssemblyFileVersion("1.3.0.1")]
diff --git a/storm-starter/multilang/resources/Storm.Net.Adapter.dll b/storm-starter/multilang/resources/Storm.Net.Adapter.dll
diff --git a/storm-starter/multilang/resources/StormSample.exe b/storm-starter/multilang/resources/StormSample.exe
diff --git a/storm-starter/src/jvm/storm/starter/DrpcTestTopologyCsharp.java b/storm-starter/src/jvm/storm/starter/DrpcTestTopologyCsharp.java
@@ -41,7 +41,7 @@ public class DrpcTestTopologyCsharp {
 	public static class SimpleDRPC extends ShellBolt implements IRichBolt {
 
 		public SimpleDRPC() {
-			super("cmd", "/k", "CALL", "StormSample.exe", "SimpleDRPC");
+			super("mono", "StormSample.exe", "SimpleDRPC");
 
 		}
 

diff --git a/storm-starter/src/jvm/storm/starter/WordCountTopologyCsharp.java b/storm-starter/src/jvm/storm/starter/WordCountTopologyCsharp.java
@@ -37,7 +37,7 @@ public class WordCountTopologyCsharp {
 	public static class Generator extends ShellSpout implements IRichSpout {
 
 		public Generator() {
-			super("cmd", "/k", "CALL", "StormSimple.exe", "generator");
+			super("mono", "StormSample.exe", "generator");
 
 		}
 
@@ -55,7 +55,7 @@ public Map<String, Object> getComponentConfiguration() {
 	public static class Splitter extends ShellBolt implements IRichBolt {
 
 		public Splitter() {
-			super("cmd", "/k", "CALL", "StormSimple.exe", "splitter");
+			super("mono", "StormSample.exe", "splitter");
 		}
 
 		@Override
@@ -72,7 +72,7 @@ public Map<String, Object> getComponentConfiguration() {
 	public static class Counter extends ShellBolt implements IRichBolt {
 
 		public Counter(){
-			super("cmd", "/k", "CALL", "StormSimple.exe", "counter");
+			super("mono", "StormSample.exe", "counter");
 		}
 
 		@Override