Code

WIP: MP Reactive Messaging POC#1148

Code

Closed

danielkec wants to merge 66 commits intohelidon-io:masterhelidon-io/helidon:masterfrom danielkec:kafka-mp-messaging-connectordanielkec/helidon:kafka-mp-messaging-connectorCopy head branch name to clipboard

+19,770-3,537

Commits

Commits on Dec 27, 2019

• Kafka connector with partial MicroProfile Reactive Messaging Specification

  Show description for 6d3ea5e
  danielkec

  committed
  6d3ea5e

  Copy full SHA for 6d3ea5e

• Proper context propagation

  Show description for 783b2bc
  danielkec

  committed
  783b2bc

  Copy full SHA for 783b2bc

• First few passable tck tests

  Show description for 88b37e9
  danielkec

  committed
  88b37e9

  Copy full SHA for 88b37e9

• Extra ugly ReactiveStreamEngine POC with Multi support

  Show description for dad9924
  danielkec

  committed
  dad9924

  Copy full SHA for dad9924

• Trivial Helidon engine implementation with fist few tck tests passing

  Show description for 4a1dac4
  danielkec

  committed
  4a1dac4

  Copy full SHA for 4a1dac4

• More tck bending

  Show description for e8d86e4
  danielkec

  committed
  e8d86e4

  Copy full SHA for e8d86e4

• Internal processor impl

  Show description for 63a337e
  danielkec

  committed
  63a337e

  Copy full SHA for 63a337e

• Passing 8/14 tck tests

  Show description for 92ae9b8
  danielkec

  committed
  92ae9b8

  Copy full SHA for 92ae9b8

• Passing 10/14 tck tests

  Show description for 175c2e7
  danielkec

  committed
  175c2e7

  Copy full SHA for 175c2e7

• Major refactor

  Show description for 5b9c714
  danielkec

  committed
  5b9c714

  Copy full SHA for 5b9c714

• Reactive engine - support from more stages (peek, filter)

  Show description for 651c735
  danielkec

  committed
  651c735

  Copy full SHA for 651c735

• Passing 11/14 tck tests

  Show description for c93ae8e
  danielkec

  committed
  c93ae8e

  Copy full SHA for c93ae8e

• Reactive streams Multi integration

  Show description for aeb3613
  danielkec

  committed
  aeb3613

  Copy full SHA for aeb3613

• Passing 12/14 tck tests

  Show description for 71b7007
  danielkec

  committed
  71b7007

  Copy full SHA for 71b7007

• Passing processor shape tests with Multi, not with small-rye

  Show description for 07e6bd4
  danielkec

  committed
  07e6bd4

  Copy full SHA for 07e6bd4

• Passing all MicroProfile Reactive Messaging tck tests

  Show description for df643ea
  danielkec

  committed
  df643ea

  Copy full SHA for df643ea

• Naming convention cleanup

  Show description for 64a7577
  danielkec

  committed
  64a7577

  Copy full SHA for 64a7577

• Check-style and coverage for:

  Show description for b3b5ba8
  danielkec

  committed
  b3b5ba8

  Copy full SHA for b3b5ba8

• Check-style fixes for MP Reactive Messaging

  Show description for e7b7015
  danielkec

  committed
  e7b7015

  Copy full SHA for e7b7015

• Spot-bugs fixes

  Show description for 11d6ecf
  danielkec

  committed
  11d6ecf

  Copy full SHA for 11d6ecf

• Method signatures decomposition to different ack types

  Show description for 3ccfea0
  danielkec

  committed
  3ccfea0

  Copy full SHA for 3ccfea0

• Method signature resolving refactor

  Show description for c40bde7
  danielkec

  committed
  c40bde7

  Copy full SHA for c40bde7

• Checkstyle fixes

  Show description for 5882f1d
  danielkec

  committed
  5882f1d

  Copy full SHA for 5882f1d

• Invalid javadoc fix

  Show description for 51ad1de
  danielkec

  committed
  51ad1de

  Copy full SHA for 51ad1de

• Partial ack impl

  Show description for 069e13d
  danielkec

  committed
  069e13d

  Copy full SHA for 069e13d

• Ack impl for incoming methods aka subscribers

  Show description for 6119dc4
  danielkec

  committed
  6119dc4

  Copy full SHA for 6119dc4

• Full Ack impl

  Show description for 1114a7d
  danielkec

  committed
  1114a7d

  Copy full SHA for 1114a7d

• Spot bugs fix

  Show description for 5a0bad2
  danielkec

  committed
  5a0bad2

  Copy full SHA for 5a0bad2

• Passing 509/1948 MP RS operators tck tests

  Show description for d7d46b1
  danielkec

  committed
  d7d46b1

  Copy full SHA for d7d46b1

• Passing 551/1948 MP RS operators tck tests

  Show description for bd572c6
  danielkec

  committed
  bd572c6

  Copy full SHA for bd572c6

• Passing 692/1948 MP RS operators tck tests

  Show description for 01bedd5
  danielkec

  committed
  01bedd5

  Copy full SHA for 01bedd5

• Passing 713/1948 MP RS operators tck tests

  Show description for 58e02ad
  danielkec

  committed
  58e02ad

  Copy full SHA for 58e02ad

• Passing 838/1948 MP RS operators tck tests

  Show description for 41b535d
  danielkec

  committed
  41b535d

  Copy full SHA for 41b535d

• Passing 886/1948 MP RS operators tck tests

  Show description for 589df80
  danielkec

  committed
  589df80

  Copy full SHA for 589df80

• Passing 946/1948 MP RS operators tck tests

  Show description for f37420e
  danielkec

  committed
  f37420e

  Copy full SHA for f37420e

• Passing 949/1948 MP RS operators tck tests

  Show description for 4b66061
  danielkec

  committed
  4b66061

  Copy full SHA for 4b66061

• Passing 973 failing 245/1948 MP RS operators tck tests

  Show description for f0e03e1
  danielkec

  committed
  f0e03e1

  Copy full SHA for f0e03e1

• Passing 980 failing 238/1948 MP RS operators tck tests

  Show description for 0182fac
  danielkec

  committed
  0182fac

  Copy full SHA for 0182fac

• Passing 1031 failing 189/1948 MP RS operators tck tests

  Show description for 02ea6c8
  danielkec

  committed
  02ea6c8

  Copy full SHA for 02ea6c8

• Passing 1044 failing 173/1948 MP RS operators tck tests

  Show description for a69e63e
  danielkec

  committed
  a69e63e

  Copy full SHA for a69e63e

• Passing 1106 failing 131/1948 MP RS operators tck tests

  Show description for 1f85366
  danielkec

  committed
  1f85366

  Copy full SHA for 1f85366

• Passing 1136 failing 104/1948 MP RS operators tck tests

  Show description for 6888226
  danielkec

  committed
  6888226

  Copy full SHA for 6888226

• Passing 1160 failing 81/1948 MP RS operators tck tests

  Show description for 0ea5559
  danielkec

  committed
  0ea5559

  Copy full SHA for 0ea5559

• Passing 1187 failing 54/1948 MP RS operators tck tests

  Show description for c6b8287
  danielkec

  committed
  c6b8287

  Copy full SHA for c6b8287

• Passing 1190 failing 50/1948 MP RS operators tck tests

  Show description for b04903f
  danielkec

  committed
  b04903f

  Copy full SHA for b04903f

• Passing 1202 failing 44/1948 MP RS operators tck tests

  Show description for ec0d4f2
  danielkec

  committed
  ec0d4f2

  Copy full SHA for ec0d4f2

• Passing 1208 failing 36/1948 MP RS operators tck tests

  Show description for 124869c
  danielkec

  committed
  124869c

  Copy full SHA for 124869c

• After rebase fix

  Show description for 934a93a
  danielkec

  committed
  934a93a

  Copy full SHA for 934a93a

• Passing 1216 failing 29/1948 MP RS operators tck tests

  Show description for b49eb2e
  danielkec

  committed
  b49eb2e

  Copy full SHA for b49eb2e

• Passing 1221 failing 24/1948 MP RS operators tck tests

  Show description for 56254f1
  danielkec

  committed
  56254f1

  Copy full SHA for 56254f1

• Passing 1226 failing 19/1948 MP RS operators tck tests

  Show description for 7a5669c
  danielkec

  committed
  7a5669c

  Copy full SHA for 7a5669c

• Passing 1246 failing 2/1948 MP RS operators tck tests

  Show description for 4d323e1
  danielkec

  committed
  4d323e1

  Copy full SHA for 4d323e1

• Clean up, Coupled deadlock fix, FlatMap lost last item fix

  Show description for ff02bf3
  danielkec

  committed
  ff02bf3

  Copy full SHA for ff02bf3

• Move additional processors to common module

  Show description for f309ed8
  danielkec

  committed
  f309ed8

  Copy full SHA for f309ed8

• Move tapped processor to common module

  Show description for 2a4270a
  danielkec

  committed
  2a4270a

  Copy full SHA for 2a4270a

• Move RS augments to BaseProcessor

  Show description for 5ed330d
  danielkec

  committed
  5ed330d

  Copy full SHA for 5ed330d

• Checkstyle cleanup of common module

  Show description for 31e045d
  danielkec

  committed
  31e045d

  Copy full SHA for 31e045d

• Reabase on java.util.concurrent.Flow

  Show description for da8b165
  danielkec

  committed
  da8b165

  Copy full SHA for da8b165

Commits on Dec 28, 2019

• Checkstyle fixes

  Show description for ff2812c
  danielkec

  committed
  ff2812c

  Copy full SHA for ff2812c

Commits on Dec 29, 2019

• FlatMap buffer overflow fix,

  Show description for 6699433
  danielkec

  committed
  6699433

  Copy full SHA for 6699433

Commits on Jan 6, 2020

• Multi PR review issues fix

  Show description for 8c873fa
  danielkec

  committed
  8c873fa

  Copy full SHA for 8c873fa

Commits on Jan 7, 2020

• Multi PR review issues fix

  Show description for e17290c
  danielkec

  committed
  e17290c

  Copy full SHA for e17290c

• Multi PR review issues fix

  Show description for 7d25ccf
  danielkec

  committed
  7d25ccf

  Copy full SHA for 7d25ccf

Commits on Jan 8, 2020

• Remove Valve helidon-io/issues/514

  Show description for 17f8342
  danielkec

  committed
  17f8342

  Copy full SHA for 17f8342

• HttpRequestScopedPublisher doesn't close connection

  Show description for e31d54b
  danielkec

  committed
  e31d54b

  Copy full SHA for e31d54b

• Copyright fix for happy new year 2020!

  Show description for 82e4926
  danielkec

  committed
  82e4926

  Copy full SHA for 82e4926