首页
开源
资讯
活动
开源许可证
软件工程云服务
软件代码质量检测云服务
持续集成与部署云服务
社区个性化内容推荐服务
贡献审阅人推荐服务
群体化学习服务
重睛鸟代码扫描工具
登录
注册
代码拉取完成，页面将自动刷新
Watch
1
Star
0
Fork
0
src-upstream-repos
/
amqp-client.cr
Fork 仓库
加载中
取消
确认
代码
Issues
0
Pull Requests
0
Wiki
0
统计
标签
标签名
描述
提交信息
操作
v1.2.1
1.2.1 Changed - `Channel#basic_publish` (as well as `Queue#publish`) callback now receivies a boolean if the message was Acked or Nacked by the server Fixed - On channel close all outstanding publish confirm callbacks are rejected
beed865
2024-01-05 19:38
下载
v1.2.0
1.2.0 Changed - `Channel#basic_publish` (as well as `Queue#publish`) now takes a block, which will be executed when the message is confirmed - `Channel#on_confirm(msgid)` is removed - `Channel#wait_for_confirm(msgid)` is dropped Fixed - Raise an exception if a blocked subscriber is closed by the server
d6b8e23
2024-01-05 18:38
下载
v1.0.13
1.0.13 Fixed - Raise an exception if a blocked subscriber is closed by the server Added - no_wait support for queue_declare/delete/purge
de6d825
2023-12-19 23:08
下载
v1.1.0
v1.1.0 - `basic_publish_confirm` waits for all unconfirmed messages to be confirmed. - `wait_for_confirm(msgid)` and `on_confirm(msgid)` and deprecated in favour of new `wait_for_confirms`. - `no_wait` support for queue declare/delete/purge.
8dbcf07
2023-11-16 21:02
下载
v1.0.12
d3df89d
2023-07-05 20:01
下载
v1.0.11
v1.0.11 - Default to amqp protocol when scheme is missing from URI - Update connection tune parameters after negotation (before eg. the frame_max wouldn't be respected if tuned to a lower value by the server)
bec5bf6
2023-04-16 05:34
下载
v1.0.10
1.0.10 Added - Can configure multiple TCP options, both TCP and internal buffer sizes - Streams queue example Changed - Default to 60s (before 15s) read timeout during connection establishment - Cancel consumer if callback raises unexpected exception - Augment Connection::ClosedException with host, user and vhost - Don't try to reject messages coming to a deleted consumer (might have been a noack consumer) Fixed - Don't flush socket when publishing when in transaction mode, greatly increasing Tx publishing speed - Removed exchange_declare's exclusive parameter - Match parameter names for inherited methods - Close all consumers when closing Channel to prevent blocks - Raise an exception if trying to call wait_for_confirm on a channel that isn't in confirm mode
fd6c7f4
2022-12-05 22:54
下载
v1.0.9
Reuse TLS context between connections
d843b30
2022-03-27 23:06
下载
v1.0.8
Can disable TCP keepalive
bca3a65
2022-03-25 04:52
下载
v1.0.7
v1.0.7 - VERSION is correct (not the version of the app the lib is included in) - Default connection_name to PROGRAM_NAME, for easier identifitcation in the server's connection listing
fd5fe3b
2022-01-31 18:28
下载
v1.0.6
v1.0.6 - Restore AMQP::Client::Message, as a abstract struct for Deliver and Get messages - Requeue messages received for cancelled consumers - Make basic_cancel no_wait by default, so that consumers with prefetch 0 won't block on it.
4279d1a
2022-01-13 17:39
下载
v1.0.5
1.0.5 - Memory usage per connection is down 95% - Allow custom queue properties also for temporary queues (where name is empty) - Log warning that user should increase prefetch limit, when the read loop have to wait to deliver messages to worker(s) - Queue#unsubscribe now supports the no_wait argument - Better API documentation - Blocking consumers can now also have multiple workers - Better exception handling in blocking consumers - Reduced cyclomatic complexity in many methods
806a118
2022-01-11 07:00
下载
v1.0.4
95% less memory usage - Can configure tcp keepalive settings with ?tcp_keepalive=60:10:3, (idle, interval, count) - Can configure tcp nodelay settings with ?tcp_nodelay - Support for AMQP Transactions - Each connection is now using 95% less memory, 37KB/connection
f375f3f
2021-11-16 17:13
下载
v1.0.3
v1.0.3 Fixed - Handle CloseOk write errors - Using a closed channel would break connection
2d3c75f
2021-10-08 15:36
下载
v1.0.2
ChannelCLosedError on write if closed
fe21a7d
2021-09-21 20:10
下载
v1.0.1
1.0.1
ed1d4cf
2021-04-02 04:26
下载
v1.0.0
Crystal 1.0.0 compability
1a06f5c
2021-03-23 16:07
下载
v0.6.6
Expect FlowOk after setting Flow mode
10bbc97
2021-02-26 08:51
下载
v0.6.5
Websocket support
68c3614
2021-02-23 16:04
下载
v0.6.4
Fixed - AMQP::Client::Connection::ClosedException is not wrapped as AMQP::Client::Error
3acdd03
2021-02-08 01:21
下载
下载
请输入验证码，防止盗链导致资源被占用
取消
下载