drpc例子

centmeng · centmeng · commit 187367a914fc · 2017-05-11T19:00:06.000+08:00
diff --git a/src/com/msj/storm/drpc/basic/BasicDRPCTopology.java b/src/com/msj/storm/drpc/basic/BasicDRPCTopology.java
@@ -1,4 +1,4 @@
-package bhz.drpc1;
+ package com.msj.storm.drpc.basic;
 
 import backtype.storm.Config;
 import backtype.storm.LocalCluster;
diff --git a/src/com/msj/storm/drpc/basic/DrpcExclam.java b/src/com/msj/storm/drpc/basic/DrpcExclam.java
@@ -1,7 +1,13 @@
-package bhz.drpc1;
+package com.msj.storm.drpc.basic;
 
 import backtype.storm.utils.DRPCClient;
 
+/**
+ * @author Vincent.M mengshaojie@188.com
+ * @date 2017/5/11 下午2:57
+ * @copyright ©2017 孟少杰 All Rights Reserved
+ * @desc 远程调用drpc测试
+ */
 public class DrpcExclam {
 
 	public static void main(String[] args) throws Exception {

Original file line number	Diff line number	Diff line change
`@@ -1,4 +1,4 @@`
`1`		`-package bhz.drpc1;`
	`1`	`+ package com.msj.storm.drpc.basic;`
`2`	`2`
`3`	`3`	`import backtype.storm.Config;`
`4`	`4`	`import backtype.storm.LocalCluster;`