You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@rocketmq.apache.org by GitBox <gi...@apache.org> on 2019/01/16 02:53:16 UTC
[GitHub] gchaoxue opened a new issue #690: Method
DLedgerCommitLog.putMessages(MessageExtBatch) not implemented
gchaoxue opened a new issue #690: Method DLedgerCommitLog.putMessages(MessageExtBatch) not implemented
URL: https://github.com/apache/rocketmq/issues/690
Method `org.apache.rocketmq.store.dledger.DLedgerCommitLog.putMessages(MessageExtBatch)` is not implemented.
I built the new dledger-implemented rocketmq from branch _store_with_dledger_ and wanted to try the new HA solution. But the client keeps getting "**MQBrokerException: CODE: 13 DESC: the message is illegal**" when I try to send a batch of messages. After debugging and making sure that there is nothing wrong with the client code, I read the server-side code and found that the batch-message putting method of `DledgerCommitLog` is under development and it is returning error code of `MESSAGE_ILLEGAL`.
```
package org.apache.rocketmq.store.dledger;
public class DLedgerCommitLog extends CommitLog {
@Override
public PutMessageResult putMessages(final MessageExtBatch messageExtBatch) {
return new PutMessageResult(PutMessageStatus.MESSAGE_ILLEGAL, null);
}
}
```
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
With regards,
Apache Git Services