public class MyClass implements MessageSubscriber<QueryMsg> {
  public void onMessage(QueryMsg query, Host sourceHost) {
    ...
  }
}
MyClass c = new MyClass();
Servent.getInstance().getMessageService().addMessageSubscriber(
  QueryMsg.class, c);