ScalaConsultants / reactive-rabbit

Reactive Streams driver for AMQP protocol. Powered by RabbitMQ library.
Apache License 2.0
184 stars 40 forks source link

Messages ordering test #33

Closed LGLO closed 8 years ago

LGLO commented 8 years ago

Test that checks if order of messages was not changed during publication or consumption. Node after QueueSubscriber should receive messages in order of publication +- prefetch (because RabbitMQ java library threads call 'handleDelivery' concurrently).

mkiedys commented 8 years ago

Good to see this. This will get into master right after https://github.com/ScalaConsultants/reactive-rabbit/pull/28.

LGLO commented 8 years ago

Test run in sbt fails when run second time. I'm working on it.

LGLO commented 8 years ago

Forgot to rebase.

LGLO commented 8 years ago

This should be rebased after #34 is merged.

mkiedys commented 8 years ago

Can you rebase this pull request?

LGLO commented 8 years ago

Sure, I'll try to do in next 12h.

LGLO commented 8 years ago

It is up-to-date. Sry that took so long.

LGLO commented 8 years ago

I'll fix according to message. Can I merge if tests passes?

mkiedys commented 8 years ago

👍