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/d72addff Tree: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/tree/d72addff Diff: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/diff/d72addff Branch: refs/heads/release-4.1.0-incubating Commit: d72addffb3c31a76da5c96f11c183402d8d4323f Parents: 8feb88d Author: shroman <rsht...@yahoo.com> Authored: Thu May 4 20:45:11 2017 +0900 Committer: shroman <rsht...@yahoo.com> Committed: Thu May 4 20:45:11 2017 +0900 ---------------------------------------------------------------------- .../common/MessageEncodeDecodeTest.java | 30 ++++++++------------ 1 file changed, 12 insertions(+), 18 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/d72addff/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);