sstone/amqp-client
[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
ScalaMIT
Issues
- 13
- 13
Consumers are not redefined after channel reconnect, resulting in ack errors: reply-code=406, reply-text=PRECONDITION_FAILED - unknown delivery tag
#30 opened by tomrogers3 - 0
- 3
- 3
Publish messages getting dropped
#86 opened by anindyaju99 - 3
Waiting for all messages to be sent
#72 opened by krvss - 0
Message loss through Shutdown Signal Exception
#85 opened by n1ko-w1ll - 2
ChannelOwner tries to create forwarder before old one is suspended (forwarder is not unique)
#84 opened by n1ko-w1ll - 2
if createChannel fails, children of ConnectionOwner are not notified about disconnect
#83 opened by n1ko-w1ll - 2
How to create more than one channels?
#82 opened by Yi-G - 3
How to cleanly close a channel owner?
#81 opened by anindyaju99 - 2
Jar contains samples
#80 opened by thjaeckle - 4
- 2
- 2
Support Akka 2.4.3
#74 opened by stephennancekivell - 5
Adding multiple Bindings to a Consumer results in multiple consumer instances
#68 opened by thjaeckle - 2
- 2
- 2
- 1
Exchange to Exchange Binding
#66 opened by SayreBladesWW - 2
- 3
- 1
Consumer stalls with qos set - 1.3
#60 opened by bearrito - 6
- 7
Channel actor should be created with routerconfig to enable round robin publishing
#56 opened by ahaid - 5
Update to RabbitMQ Java Client 3.3.0
#47 opened by soumikb - 8
Actor doesn't get Garbage Collected
#55 opened by ahaid - 6
Keepalive Support
#54 opened by henricook - 2
Alternate constructor for RabbitMQConnection
#21 opened by jkodumal - 4
header value when longer than 1024 bytes converted to java.io.DataInputStream
#53 opened by durgadeep - 5
Update to akka 2.3.0
#41 opened by akhil - 4
Custom ExecutionContext for RpcServer
#45 opened by slorion - 12
Update Akka to 2.2.0
#18 opened by tiagoboldt - 6
Consumer Cancellation Notifications
#43 opened by vishramachandran - 4
Requests dropped during re-connect
#34 opened by ljcoomber - 8
Removing/cancelling a consumer
#35 opened by soumikb - 0
consumers do not create exchanges when they should when processing AddBinding messages
#33 opened by sstone - 1
Support for Akka 2.2.3
#37 opened by durgadeep - 1
SStone supporting Akka 2.2.3
#40 opened by durgadeep - 1
1.3-ML4 Queries
#39 opened by rohitgupta-90 - 0
- 4
Update to Akka 2.2.1
#23 opened by atif-frag - 4
Erroneous Success for Publish
#24 opened by brycechesternewman - 1
When using the AMPQ client's Transaction the Header's Basic Properties are nulled out.
#25 opened by brycechesternewman - 3
- 3
Support for RabbitMQ 3.x
#20 opened by jkodumal - 1
ConnectionOwner.scala:179: type mismatch
#19 opened - 3
I need a way to pass a "context" to a request so I can receive it in an Ok or Error
#16 opened by mhamrah - 0
integrate with travis CI
#13 opened by sstone - 0
RpcServer should return a Future
#10 opened by sstone