rocketmq client for c#

public class TestListener : MessageListenerConcurrently
{
public ConsumeConcurrentlyStatus consumeMessage(List list, ConsumeConcurrentlyContext ccc)
{
for (int i = 0; i < list.size(); i++)
{
var msg = list.get(i) as Message;
byte[] body = msg.getBody();
var str = Encoding.UTF8.GetString(body);
if (body.Length == 2 && body[0] == 0 && body[1] == 0)
{

//System.out.println("Got the end signal");
continue;
}

}
return ConsumeConcurrentlyStatus.CONSUME_SUCCESS;
}
}