Code

Feature/manual ack#403

Code

Merged

SgtSilvio merged 26 commits intodevelophivemq/hivemq-mqtt-client:developfrom feature/manual-ackhivemq/hivemq-mqtt-client:feature/manual-ackCopy head branch name to clipboardApr 18, 2020

Commits

Commits on Apr 18, 2020

• Added manualAcknowledgement to MqttIncomingPublishFlow, Mqtt3/5Subscribe and publishes methods

  SgtSilvio

  committed
  3854d5f

  Copy full SHA for 3854d5f

• Fixed Mqtt3RxClientViewExceptionsTest

  SgtSilvio

  committed
  035980b

  Copy full SHA for 035980b

• Moved default methods of Mqtt3/5Rx/Async/BlockingClient to implementation

  SgtSilvio

  committed
  86fe847

  Copy full SHA for 86fe847

• Added CheckReturnValue annotations to Mqtt3/RxClient

  SgtSilvio

  committed
  f9ef7a4

  Copy full SHA for f9ef7a4

• Moved default methods of Mqtt3/5ReactorClient to implementation

  Show description for 2ef1882
  SgtSilvio

  committed
  2ef1882

  Copy full SHA for 2ef1882

• Added manualAcknowledgement to Mqtt3/5ReactorClient publishes methods

  SgtSilvio

  committed
  9fbbbb9

  Copy full SHA for 9fbbbb9

• Added manualAcknowledgement to subscribe(Stream) methods instead of property of Subscribe message

  SgtSilvio

  committed
  af85357

  Copy full SHA for af85357

• Fixed Mqtt3RxClientViewExceptionsTest

  SgtSilvio

  committed
  c0fbb85

  Copy full SHA for c0fbb85

• Refactored new IllegalStateException calls with Checks.state

  SgtSilvio

  committed
  b31f4ab

  Copy full SHA for b31f4ab

• Deprecated subscribeStream(With), replaced with subscribePublishes(With) that returns a builder to also specify manual ack

  SgtSilvio

  committed
  cc41b15

  Copy full SHA for cc41b15

• Readded default toRx/Async/Blocking methods (as they do not require internal imports)

  SgtSilvio

  committed
  a447a16

  Copy full SHA for a447a16

• Temporarily skip classes from japicc to avoid false positives

  SgtSilvio

  committed
  c5b7187

  Copy full SHA for c5b7187

• Removed unnecessary formatter:off tags

  SgtSilvio

  committed
  de94000

  Copy full SHA for de94000

• Added javadoc for Mqtt3/5AsyncClient.Mqtt3/5SubscribeAndCallbackBuilder

  SgtSilvio

  committed
  2a88446

  Copy full SHA for 2a88446

• Implemented manual acknowledgement

  SgtSilvio

  committed
  c01efc3

  Copy full SHA for c01efc3

• Added Mqtt3Publish.acknowledge

  SgtSilvio

  committed
  26cd99b

  Copy full SHA for 26cd99b

• Fixed unit tests

  SgtSilvio

  committed
  d6e5106

  Copy full SHA for d6e5106

• Improved exceptional cases for Mqtt3/5Publish.acknowledge

  SgtSilvio

  committed
  0345b2c

  Copy full SHA for 0345b2c

• Reduced visibility of internal classes

  SgtSilvio

  committed
  a914cb9

  Copy full SHA for a914cb9

• Fixed NotNull/Nullable annotation inspections

  SgtSilvio

  committed
  eeb76d3

  Copy full SHA for eeb76d3

• Improved acknowledge drain

  SgtSilvio

  committed
  ce34592

  Copy full SHA for ce34592

• Improved MqttMatchingPublishFlows.acknowledge

  SgtSilvio

  committed
  fece2dd

  Copy full SHA for fece2dd

• Fixed missing final inspection

  SgtSilvio

  committed
  efb30da

  Copy full SHA for efb30da

• Added missing javadoc parameter

  SgtSilvio

  committed
  2109e50

  Copy full SHA for 2109e50

• Fixed javadoc typos

  SgtSilvio

  committed
  0d9a541

  Copy full SHA for 0d9a541

• Fixed javadoc typo

  SgtSilvio

  committed
  c2df96c

  Copy full SHA for c2df96c