Слияние кода завершено, страница обновится автоматически
有任何疑问可以添加issues或者通过邮件询问我,我会第一时间回复大家~
<dependency>
<groupId>top.arkstack</groupId>
<artifactId>shine-mq</artifactId>
<version>2.2.0</version>
</dependency>
Demo戳 shine-mq-demo
分布式事务的配置,具体可配置的参数如下:
/**
* 是否初始化 开启分布式事务 缺省为false
*/
private boolean transaction = false;
/**
* 提交ack 失败最大重试次数
*/
private Integer commitMaxRetries = 3;
/**
* 接收消息 ack 失败最大尝试次数
*/
private Integer receiveMaxRetries = 3;
/**
* 默认提供redis中间件来实现消息提交到mq之前的持久化
*
* 也可以自己实现 {@link top.arkstack.shine.mq.coordinator.Coordinator}
* 或者不想用redis,可以设置为false,就不会有redis的依赖
*/
private boolean redisPersistence = true;
/**
* redis缓存前缀
*/
private String redisPrefix = "";
/**
* Prepare和Ready状态消息超时时间 默认为3分钟
* 单位为秒
*/
private long timeOut = 3 * 60;
/**
* returnCallback的状态过期时间 默认为1天
* 单位为秒
*/
private long returnCallbackTTL = 24 * 60 * 60;
封装mq的操作,具体可配置的参数如下:
/**
* 是否初始化消息监听者, 若服务只是Producer则关闭
*/
private boolean listenerEnable = false;
/**
* {@link org.springframework.amqp.core.AcknowledgeMode}
* <p>
* 0 AUTO
* 1 MANUAL
* 2 NONE
*/
private int acknowledgeMode = 1;
/**
* 每个消费者可能未完成的未确认消息的数量。
*/
private Integer prefetchCount = null;
/**
* 为每个已配置队列创建的消费者数
*/
private Integer consumersPerQueue = null;
/**
* 是否持久化,指是否保存到erlang自带得数据库mnesia中,即重启服务是否消失
*/
private boolean durable = true;
/**
* 是否排外,指当前定义的队列是connection中的channel共享的,其他connection连接访问不到
*/
private boolean exclusive = false;
/**
* 是否自动删除,指当connection.close时队列删除
*/
private boolean autoDelete = false;
/**
* 是否初始化消息监听者, 若服务只是Producer则关闭
*/
private boolean listenerEnable = false;
/**
* 通道缓存
*/
private Integer channelCacheSize = null;
如果对你有帮助,那就帮忙点个星星把 ^.^
Вы можете оставить комментарий после Вход в систему
Неприемлемый контент может быть отображен здесь и не будет показан на странице. Вы можете проверить и изменить его с помощью соответствующей функции редактирования.
Если вы подтверждаете, что содержание не содержит непристойной лексики/перенаправления на рекламу/насилия/вульгарной порнографии/нарушений/пиратства/ложного/незначительного или незаконного контента, связанного с национальными законами и предписаниями, вы можете нажать «Отправить» для подачи апелляции, и мы обработаем ее как можно скорее.
Комментарии ( 0 )