diff --git a/pulsar-client/src/main/java/com/yahoo/pulsar/client/impl/BatchMessageIdImpl.java b/pulsar-client/src/main/java/com/yahoo/pulsar/client/impl/BatchMessageIdImpl.java index 89a0b7f38766e43f5706fb05b535518a70b8132c..1ecc328756faf41d6b0e13fb7d7d365a68e43d57 100644 --- a/pulsar-client/src/main/java/com/yahoo/pulsar/client/impl/BatchMessageIdImpl.java +++ b/pulsar-client/src/main/java/com/yahoo/pulsar/client/impl/BatchMessageIdImpl.java @@ -62,8 +62,7 @@ public class BatchMessageIdImpl extends MessageIdImpl implements Comparable { @Override public String toString() { - return Objects.toStringHelper(MessageIdImpl.class).add("ledgerId", ledgerId).add("entryId", entryId) - .add("partitionIndex", partitionIndex).toString(); + return String.format("%d:%d:%d", ledgerId, entryId, partitionIndex); } // / Serialization diff --git a/pulsar-client/src/test/java/com/yahoo/pulsar/client/api/MessageIdTest.java b/pulsar-client/src/test/java/com/yahoo/pulsar/client/api/MessageIdTest.java new file mode 100644 index 0000000000000000000000000000000000000000..9060e749f4ca7602cb6fddd060b158a3be5988c7 --- /dev/null +++ b/pulsar-client/src/test/java/com/yahoo/pulsar/client/api/MessageIdTest.java @@ -0,0 +1,46 @@ +/** + * Copyright 2016 Yahoo Inc. + * + * Licensed under the Apache License, Version 2.0 (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 + * + * 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 com.yahoo.pulsar.client.api; + +import org.testng.annotations.Test; + +import com.google.common.base.Objects; +import com.yahoo.pulsar.client.impl.BatchMessageIdImpl; +import com.yahoo.pulsar.client.impl.ConsumerId; +import com.yahoo.pulsar.client.impl.MessageIdImpl; + +import static org.testng.Assert.assertEquals; + +import org.testng.Assert; + +public class MessageIdTest { + + @Test + public void messageIdTest() { + MessageId mId = new MessageIdImpl(1, 2, 3); + assertEquals(mId.toString(), "1:2:3"); + + mId = new BatchMessageIdImpl(0, 2, 3, 4); + assertEquals(mId.toString(), "0:2:3:4"); + + mId = new BatchMessageIdImpl(-1, 2, -3, 4); + assertEquals(mId.toString(), "-1:2:-3:4"); + + mId = new MessageIdImpl(0, -23, 3); + assertEquals(mId.toString(), "0:-23:3"); + } +}