import org.apache.cassandra.db.WriteResponse; //导入依赖的package包/类
public void doVerb(MessageIn<Commit> message, int id)
{
    PaxosState.commit(message.payload);

    WriteResponse response = new WriteResponse();
    Tracing.trace("Enqueuing acknowledge to {}", message.from);
    MessagingService.instance().sendReply(response.createMessage(), id, message.from);
}
 

import org.apache.cassandra.db.WriteResponse; //导入依赖的package包/类
public void doVerb(MessageIn<Commit> message, int id)
{
    PaxosState.commit(message.payload);

    Tracing.trace("Enqueuing acknowledge to {}", message.from);
    MessagingService.instance().sendReply(WriteResponse.createMessage(), id, message.from);
}
 

import org.apache.cassandra.db.WriteResponse; //导入依赖的package包/类
public void doVerb(MessageIn<Batch> message, int id)
{
    BatchlogManager.store(message.payload);
    MessagingService.instance().sendReply(WriteResponse.createMessage(), id, message.from);
}