MqInfo.java 1.1 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465
  1. package com.caimei.modules.utils.message;
  2. import lombok.Data;
  3. import lombok.experimental.Accessors;
  4. import org.hibernate.validator.constraints.Range;
  5. @Data
  6. @Accessors(fluent = true)
  7. public class MqInfo {
  8. /**
  9. * 异步消息(可选):1是,0否
  10. */
  11. @Range(min = 0, max = 1)
  12. private Integer async;
  13. /**
  14. * 1-18,0否,对应时间依次:1s 5s 10s 30s 1m 2m 3m 4m 5m 6m 7m 8m 9m 10m 20m 30m 1h 2h
  15. */
  16. @Range(min = 0, max = 18)
  17. private Integer delay;
  18. /**
  19. * 消息主题
  20. */
  21. private String topic;
  22. /**
  23. * 消息标签(可选)
  24. */
  25. private String tag;
  26. public Integer getAsync() {
  27. return async;
  28. }
  29. public void setAsync(Integer async) {
  30. this.async = async;
  31. }
  32. public Integer getDelay() {
  33. return delay;
  34. }
  35. public void setDelay(Integer delay) {
  36. this.delay = delay;
  37. }
  38. public String getTopic() {
  39. return topic;
  40. }
  41. public void setTopic(String topic) {
  42. this.topic = topic;
  43. }
  44. public String getTag() {
  45. return tag;
  46. }
  47. public void setTag(String tag) {
  48. this.tag = tag;
  49. }
  50. }