代码拉取完成,页面将自动刷新
同步操作将从 7le/shine-mq 强制同步,此操作会覆盖自 Fork 仓库以来所做的任何修改,且无法恢复!!!
确定后同步将在后台操作,完成时将刷新页面,请耐心等待。
有任何疑问可以添加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;
如果对你有帮助,那就帮忙点个星星把 ^.^
此处可能存在不合适展示的内容,页面不予展示。您可通过相关编辑功能自查并修改。
如您确认内容无涉及 不当用语 / 纯广告导流 / 暴力 / 低俗色情 / 侵权 / 盗版 / 虚假 / 无价值内容或违法国家有关法律法规的内容,可点击提交进行申诉,我们将尽快为您处理。