// Path: jms-server/src/main/java/me/chanjar/jms/server/request/RequestDtoEvent.java
// public class RequestDtoEvent {
// 
//   private RequestDto requestDto;
// 
//   /**
//    * 数据库操作Command收集器
//    */
//   private final CommandCollector commandCollector = new CommandCollector();
// 
//   /**
//    * 响应结果
//    */
//   private ResponseDto responseDto;
// 
//   public RequestDto getRequestDto() {
//     return requestDto;
//   }
// 
//   public void setRequestDto(RequestDto requestDto) {
//     this.requestDto = requestDto;
//   }
// 
//   public void setResponseDto(ResponseDto responseDto) {
//     this.responseDto = responseDto;
//   }
// 
//   public CommandCollector getCommandCollector() {
//     return commandCollector;
//   }
// 
//   public ResponseDto getResponseDto() {
//     return responseDto;
//   }
// 
//   public void clearForGc() {
//     this.requestDto = null;
//     this.commandCollector.getCommandList().clear();
//     this.responseDto = null;
//   }
// 
//   public boolean hasErrorOrException() {
//     return responseDto != null && (responseDto.getErrorMessage() != null);
//   }
// 
// }


import com.lmax.disruptor.EventFactory;
import me.chanjar.jms.server.request.RequestDtoEvent;
package me.chanjar.jms.server.request;


public class RequestDtoEventFactory implements EventFactory<RequestDtoEvent> {

  @Override
  public RequestDtoEvent newInstance() {
// Path: jms-server/src/main/java/me/chanjar/jms/server/request/RequestDtoEvent.java
// public class RequestDtoEvent {
// 
//   private RequestDto requestDto;
// 
//   /**
//    * 数据库操作Command收集器
//    */
//   private final CommandCollector commandCollector = new CommandCollector();
// 
//   /**
//    * 响应结果
//    */
//   private ResponseDto responseDto;
// 
//   public RequestDto getRequestDto() {
//     return requestDto;
//   }
// 
//   public void setRequestDto(RequestDto requestDto) {
//     this.requestDto = requestDto;
//   }
// 
//   public void setResponseDto(ResponseDto responseDto) {
//     this.responseDto = responseDto;
//   }
// 
//   public CommandCollector getCommandCollector() {
//     return commandCollector;
//   }
// 
//   public ResponseDto getResponseDto() {
//     return responseDto;
//   }
// 
//   public void clearForGc() {
//     this.requestDto = null;
//     this.commandCollector.getCommandList().clear();
//     this.responseDto = null;
//   }
// 
//   public boolean hasErrorOrException() {
//     return responseDto != null && (responseDto.getErrorMessage() != null);
//   }
// 
// }


// Path: jms-server/src/main/java/me/chanjar/jms/server/request/RequestDtoEventFactory.java
import com.lmax.disruptor.EventFactory;
import me.chanjar.jms.server.request.RequestDtoEvent;

package me.chanjar.jms.server.request;


public class RequestDtoEventFactory implements EventFactory<RequestDtoEvent> {

  @Override
  public RequestDtoEvent newInstance() {
    return new RequestDtoEvent();