Commit Graph

30 Commits

Author SHA1 Message Date
alesapin
c57edd2018 Tiny fixes 2020-07-03 11:02:35 +03:00
alesapin
c6c7ee30d9 Less race conditions 2020-07-02 19:44:04 +03:00
alesapin
96df2e6b71 Better shutdown and conversion 2020-07-02 17:35:10 +03:00
kssenii
f797efb04c Fix build 2020-06-30 01:48:11 +00:00
kssenii
fd9b416871 Fix and simplify code 2020-06-29 15:47:25 +00:00
kssenii
88ece429c9 Move writing to RabbitMQ into background task 2020-06-29 12:33:01 +00:00
kssenii
649eb8e348 Move reading from RabbitMQ into background task 2020-06-28 18:20:18 +00:00
alesapin
d5847d29d6 Avoid memory leaks 2020-06-25 12:44:39 +03:00
alesapin
addee61bcb Trying to do everything on top of libuv, add heartbeats 2020-06-25 00:14:49 +03:00
alesapin
cb30dbfe28 Correct merge with master 2020-06-24 20:32:57 +03:00
kssenii
9e1b8b2872 Better exchanges, fix build, better comments, better tests 2020-06-14 18:36:56 +00:00
kssenii
dcd7b7351c Support headers-exchange type 2020-06-13 21:47:22 +00:00
kssenii
b8a4c7708a Make local exchanges unique for each table 2020-06-13 18:15:59 +00:00
kssenii
462e8bcdc9 Support transactions for publishing 2020-06-12 18:10:13 +00:00
kssenii
3b0a3e00c0 Some fixes 2020-06-12 18:09:49 +00:00
kssenii
626eb53baa Fix multiple bindings for single queue & rm hardcoded strings 2020-06-11 11:13:13 +00:00
kssenii
9350472ee4 Support multiple bindings 2020-06-11 10:29:08 +00:00
kssenii
d7b2694806 Support all exchange types 2020-06-10 23:06:23 +00:00
kssenii
68b94c5c20 Fixes 2020-06-05 13:46:20 +00:00
kssenii
786874e867 Better publish & some fixes 2020-06-02 15:57:30 +00:00
kssenii
806fd27395 Fix build & fix style & fix 2020-06-01 20:48:24 +00:00
kssenii
5757dd1d57 Add insert part 2020-06-01 17:01:41 +00:00
kssenii
e80b405359 Merge branch 'master' of https://github.com/ClickHouse/ClickHouse into add-storage-rabbitmq-read-only 2020-05-31 10:30:53 +00:00
kssenii
037ed3a02c Code fix & style fix & merge fix 2020-05-31 09:34:57 +00:00
kssenii
8266715c49 Fix build & fix style 2020-05-31 08:39:22 +00:00
kssenii
0362bb2d2f Make connection between concurrent consumers shared - not private 2020-05-29 16:28:52 +00:00
kssenii
5e472af425 Fix merge & small fix 2020-05-26 20:43:20 +00:00
kssenii
14c67c6ae6 Fixes 2020-05-26 17:34:57 +00:00
kssenii
aeffab3fdb Enable SELECT and CREATE MV queries with engine RabbitMQ 2020-05-20 09:40:49 +00:00
kssenii
3b75f214c5 Register RabbitMQ storage 2020-05-20 09:09:20 +03:00