BufferProperties.java 591 B

123456789101112131415161718192021222324252627
  1. package com.yihu.base.es.properties;
  2. /**
  3. * Created by chenweida on 2018/2/24.
  4. * 缓冲区相关配置
  5. */
  6. public class BufferProperties {
  7. private Long sleepTime = 1000L;//多久消费一次消息
  8. private Integer bufferSize = 100000;//缓冲区的大小
  9. public Long getSleepTime() {
  10. return sleepTime;
  11. }
  12. public void setSleepTime(Long sleepTime) {
  13. this.sleepTime = sleepTime;
  14. }
  15. public Integer getBufferSize() {
  16. return bufferSize;
  17. }
  18. public void setBufferSize(Integer bufferSize) {
  19. this.bufferSize = bufferSize;
  20. }
  21. }