[10/50] [abbrv] incubator-rocketmq git commit: Removed author info and formatted.

[yu...@apache.org]

Removed author info and formatted.


Project: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/commit/0224f93d
Tree: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/tree/0224f93d
Diff: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/diff/0224f93d

Branch: refs/heads/develop
Commit: 0224f93d0201411be72735336f1f0e25809ffe6f
Parents: 07b3f41
Author: shroman <rs...@yahoo.com>
Authored: Thu May 4 20:45:11 2017 +0900
Committer: dongeforever <zh...@yeah.net>
Committed: Tue Jun 6 11:37:29 2017 +0800

----------------------------------------------------------------------
 .../common/MessageEncodeDecodeTest.java         | 30 ++++++++------------
 1 file changed, 12 insertions(+), 18 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/0224f93d/common/src/test/java/org/apache/rocketmq/common/MessageEncodeDecodeTest.java
----------------------------------------------------------------------
diff --git a/common/src/test/java/org/apache/rocketmq/common/MessageEncodeDecodeTest.java b/common/src/test/java/org/apache/rocketmq/common/MessageEncodeDecodeTest.java
index a219eda..42d3909 100644
--- a/common/src/test/java/org/apache/rocketmq/common/MessageEncodeDecodeTest.java
+++ b/common/src/test/java/org/apache/rocketmq/common/MessageEncodeDecodeTest.java
@@ -6,39 +6,33 @@
  * (the "License"); you may not use this file except in compliance with
  * the License.  You may obtain a copy of the License at
  *
- *     http://www.apache.org/licenses/LICENSE-2.0
+ * http://www.apache.org/licenses/LICENSE-2.0
  *
- *  Unless required by applicable law or agreed to in writing, software
- *  distributed under the License is distributed on an "AS IS" BASIS,
- *  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- *  See the License for the specific language governing permissions and
- *  limitations under the License.
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
  */
-
 package org.apache.rocketmq.common;
 
-import org.apache.rocketmq.common.message.Message;
-import org.apache.rocketmq.common.message.MessageDecoder;
-import org.junit.Test;
-
 import java.nio.ByteBuffer;
 import java.util.ArrayList;
 import java.util.Arrays;
 import java.util.List;
+import org.apache.rocketmq.common.message.Message;
+import org.apache.rocketmq.common.message.MessageDecoder;
+import org.junit.Test;
 
 import static org.junit.Assert.assertTrue;
 
-/**
- * Created by liuzhendong on 16/12/21.
- */
 public class MessageEncodeDecodeTest {
 
-
     @Test
-    public void testEncodeDecodeSingle() throws Exception{
+    public void testEncodeDecodeSingle() throws Exception {
         Message message = new Message("topic", "body".getBytes());
         message.setFlag(12);
-        message.putUserProperty("key","value");
+        message.putUserProperty("key", "value");
         byte[] bytes = MessageDecoder.encodeMessage(message);
         ByteBuffer buffer = ByteBuffer.allocate(bytes.length);
         buffer.put(bytes);
@@ -59,7 +53,7 @@ public class MessageEncodeDecodeTest {
             message.putUserProperty("key", "value" + i);
             messages.add(message);
         }
-        byte[]  bytes = MessageDecoder.encodeMessages(messages);
+        byte[] bytes = MessageDecoder.encodeMessages(messages);
 
         ByteBuffer buffer = ByteBuffer.allocate(bytes.length);
         buffer.put(bytes);