amqp-client icon indicating copy to clipboard operation
amqp-client copied to clipboard

[THIS PROJECT HAS BEEN ARCHIVED AND IS NO LONGER MAINTAINED] Simple fault-tolerant AMQP client written in Scala and based on Akka and the RabbitMQ java client

Results 21 amqp-client issues
Sort by recently updated
recently updated
newest added

Bumps logback-classic from 1.1.2 to 1.2.0. [![Dependabot compatibility score](https://dependabot-badges.githubapp.com/badges/compatibility_score?dependency-name=ch.qos.logback:logback-classic&package-manager=maven&previous-version=1.1.2&new-version=1.2.0)](https://docs.github.com/en/github/managing-security-vulnerabilities/about-dependabot-security-updates#about-compatibility-scores) Dependabot will resolve any conflicts with this PR as long as you don't alter it yourself. You can also trigger a...

dependencies

Updates all dependencies to their latest versions and cross-compiles amqp-client to Scala 2.12.

Bumps [junit](https://github.com/junit-team/junit4) from 4.12 to 4.13.1. Release notes Sourced from junit's releases. JUnit 4.13.1 Please refer to the release notes for details. JUnit 4.13 Please refer to the release notes...

dependencies

Bumps `akka.version` from 2.4.3 to 2.5.25. Updates `akka-actor_2.11` from 2.4.3 to 2.5.25 Commits - [`31ed3b3`](https://github.com/akka/akka/commit/31ed3b3d3d8ca410a5fecf7210e654faf8c547f5) Update version for release 2.5.25 - [`7f1198b`](https://github.com/akka/akka/commit/7f1198bd88adbf6f0a2331961cba394464c10434) Update paradox theme to 0.23 ([#27505](https://github-redirect.dependabot.com/akka/akka/issues/27505)) - [`ee18856`](https://github.com/akka/akka/commit/ee188565b9f3cf2257ebda218cec6af5a4777439)...

dependencies

This allows the original sender to receive back the reply, rather than the actor that connected. Otherwise, things like the `ask` pattern won't work while disconnected (because the reply goes...

I have a complex object which is serializable. But when I convert it into byte array and publish it via Publish method, I am unable to receive it at other...

Our AMQP servers do not permit our users to perform `declareExchange` nor `queueBind`. This simple solution allows the queue consumer to specify that their binding only needs to consume. Please...

In one of my applications I am generating an array of messages and iterating over them and pushing them (Publish) to the producer. I am creating the producer as follows...

Hi Fabrice, we found another issue regarding the internal forwarder. If the message frequency is higher than the forwarder can deliver the messages, the actor inbox starts to pile up....