class QueueSynchronizationProcessor extends ReplyProcessor21 {

  @Override
  public void process(DistributionMessage msg) {
    try {
      reply = (QueueSynchronizationReplyMessage) msg;
    } finally {
      super.process(msg);
    }
  }

    QueueSynchronizationProcessor(DistributionManager dm, InternalDistributedMember primary);

}