131 Commits

Author	SHA1	Message	Date
Nikolai Kochetov	6eac433c55	Review fixes.	2020-09-15 13:40:39 +03:00
Artem Zuikov	51ba12c2c3	Try speedup build (#14809)	2020-09-15 12:55:57 +03:00
Nikolai Kochetov	bcfc83022a	Return query plan from storage.	2020-09-14 17:13:58 +03:00
kssenii	40c8290dde	Tiny fixes, better tests	2020-09-07 14:48:50 +00:00
alesapin	17650e803f	Tiny improvements	2020-09-07 14:08:53 +03:00
alesapin	f6237dc334	Better name	2020-09-07 12:32:45 +03:00
kssenii	e1ef558a2d	Fixes	2020-09-03 06:50:20 +00:00
kssenii	6682c62a90	Fixes	2020-09-01 20:07:34 +00:00
kssenii	c2fb72abf8	Better mv, more comments	2020-09-01 07:58:41 +00:00
kssenii	e57d1c827f	Better shutdown	2020-08-31 10:00:28 +00:00
kssenii	647cf5718e	Better settings	2020-08-31 09:27:42 +00:00
kssenii	4e0c619721	Global refactoring	2020-08-28 10:03:54 +00:00
kssenii	4fecfdbe2f	Better & cleaner	2020-08-26 18:52:45 +00:00
kssenii	1e7eb49481	Add one more mes property, support format_schema	2020-08-15 15:05:53 +00:00
kssenii	c6fdeb6c02	Better	2020-08-15 08:00:56 +00:00
kssenii	9a409db5c0	Merge branch 'master' of https://github.com/ClickHouse/ClickHouse into rabbitmq-improvements	2020-08-15 06:51:22 +00:00
Nikolai Kochetov	9b67cd9faf	Merge branch 'master' into refactor-pipes-3	2020-08-10 10:50:17 +03:00
kssenii	2ea32a710a	More tests, better reconnect	2020-08-08 17:03:55 +00:00
Alexey Milovidov	12f66fa82c	Fix 99% of typos	2020-08-08 04:01:47 +03:00
kssenii	1213161cf4	Add some message properties	2020-08-06 20:34:13 +00:00
kssenii	24b032b378	Allow multiple consumers for same queues	2020-08-06 13:50:44 +00:00
Nikolai Kochetov	20e63d2271	Refactor Pipe [part 6]	2020-08-06 15:24:05 +03:00
kssenii	053f31cb77	Better confirmListener	2020-08-04 20:50:41 +00:00
kssenii	d5b1332b67	Stop publish untill batch is confirmed	2020-08-03 14:40:51 +00:00
kssenii	60124b769c	Merge	2020-08-03 09:17:23 +00:00
kssenii	62293f80c0	Small fixes	2020-08-03 09:14:25 +00:00
kssenii	c2bed351ae	Add consumer connection track and restore	2020-08-01 13:05:06 +00:00
Vitaly Baranov	56665a15f7	Rework and rename the template class SettingsCollection => BaseSettings.	2020-07-31 20:54:18 +03:00
Vitaly Baranov	4ad99f1472	Make type names of settings shorter: SettingUInt64 => UInt64.	2020-07-31 19:11:27 +03:00
kssenii	5a934c079e	Add connection restore in insert, better confirms	2020-07-31 04:59:56 +00:00
kssenii	763c337be9	Remove redundant, move subscription	2020-07-31 04:59:18 +00:00
kssenii	469e46a539	Fix build	2020-07-28 12:46:44 +00:00
kssenii	0ee54c8a4a	Fix build, async acks -> sync acks, fix tests	2020-07-28 10:43:25 +00:00
kssenii	22b16060f6	More reliable publishing	2020-07-25 16:56:29 +00:00
kssenii	2b57857afc	Add dl-exchange, commits	2020-07-25 16:56:12 +00:00
kssenii	f9a4bf9e61	Add queue resume read	2020-07-25 16:55:58 +00:00
kssenii	f0f6111655	Move exchange init, add bridge-exchange	2020-07-25 16:55:44 +00:00
kssenii	ac448db491	Add virtuals	2020-07-25 16:55:32 +00:00
kssenii	a88e391bd2	Fix bug with insert, simplify exchanges logic	2020-07-25 16:55:18 +00:00
Alexey Milovidov	8f2055b0a0	Fix trash from RabbitMQ	2020-07-13 04:11:48 +03:00
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	3d2cc9d4b2	Remove libevent library	2020-06-29 12:11:17 +00:00
kssenii	5fc0b93400	Use ConcurentBoundedQueue instead of vector	2020-06-29 09:50:33 +00:00
kssenii	649eb8e348	Move reading from RabbitMQ into background task	2020-06-28 18:20:18 +00:00
alesapin	36eb2c3028	Simplify code around locks	2020-06-25 13:25:22 +03: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	472b04b69c	Better producer	2020-06-10 19:59:37 +00:00
kssenii	897a592ee6	Move subscription	2020-06-10 15:41:49 +00:00
kssenii	17e7cc03c0	Add consumer failure handler	2020-06-08 01:11:48 +00:00
kssenii	ce448d9291	Better event handler	2020-06-07 11:24:10 +00:00
kssenii	cb618a32b8	Fix style	2020-06-05 14:27:56 +00:00
kssenii	68b94c5c20	Fixes	2020-06-05 13:46:20 +00:00
kssenii	972611e31b	Fix consumer	2020-06-04 06:22:53 +00:00
kssenii	5624066195	Fix producer	2020-06-04 06:21:28 +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	386dc4d95e	Fixes	2020-06-01 17:02:56 +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