Code

Feature/replica broker#1

Code

Draft

NikitaShupletsov wants to merge 133 commits intomainamazon-mq/upstreaming-activemq:mainfrom feature/replica_brokeramazon-mq/upstreaming-activemq:feature/replica_brokerCopy head branch name to clipboard

+16,324-47

Commits

Commits on Jun 8, 2022

• [AMQ-8354] Add initial plugin skeleton

  NikitaShupletsov

  committed
  7bf6a5a

Commits on Jun 10, 2022

• [AMQ-8354] Replica Broker can connect to source broker

  NikitaShupletsov

  committed
  035eff7

• [AMQ-8354] Replication of destination creation and removal

  NikitaShupletsov

  committed
  29498aa

• [AMQ-8354] Replication of message send

  NikitaShupletsov

  committed
  6b1f0fc

• [AMQ-8354] Replication of purge queue and acknowledge message

  NikitaShupletsov

  committed
  e1e2dbd

• [AMQ-8354] Replication of transaction begin, prepare, forget, rollback, commit

  NikitaShupletsov

  committed
  aecc133

• [AMQ-8354] stop taskRunner on broker stop

  NikitaShupletsov

  committed
  79295ad

• [AMQ-8354] Ensure destinations are replicated on startup

  NikitaShupletsov

  committed
  c3f3298

• [AMQ-8354] Isolate the replication queue by letting to add consumers and producers only via the replication transport.

  NikitaShupletsov

  committed
  348c347

• [AMQ-8354] Support of durable subscribers

  NikitaShupletsov

  committed
  a0dda50

• [AMQ-8354] Test of replication of virtual topics and expired messages.

  NikitaShupletsov

  committed
  4506037

• [AMQ-8354] More tests for ReplicaSourceBroker

  NikitaShupletsov

  committed
  f475b55

Commits on Jun 20, 2022

• AMQ-8354 Add scheduled messages support to the replica plugin

  Dm-Chebotarskyi

  committed
  e69ed7f

Commits on Sep 12, 2022

• [AMQ-8354] Move ReplicaBroker before ReplicaSourceBroker.

  Show description for e78ca61
  NikitaShupletsov

  committed
  e78ca61

• [AMQ-8354] Atomic send message on primary broker

  NikitaShupletsov

  committed
  acb299d

• [AMQ-8354] Different implementation of ack replication.

  NikitaShupletsov

  committed
  d4ff43e

Commits on Sep 13, 2022

• [AMQ-8354] Add the license

  NikitaShupletsov

  committed
  851af7d

Commits on Jan 4, 2023

• [AMQ-8354] Add exponential replica retries.

  NikitaShupletsov

  committed
  d5a228f

• [AMQ-8354]

  Show description for 7e40ead
  NikitaShupletsov

  committed
  7e40ead

• [AMQ-8354] Add batches for main replication queue.

  NikitaShupletsov

  committed
  e48fa5f

• [AMQ-8354] Add compaction logic for send and ack events that cancel each other out.

  NikitaShupletsov

  committed
  1b78c03

• [AMQ-8354] Do not send messages to mainQueue if there are no consumers to apply message compaction on the main queue.

  NikitaShupletsov

  committed
  ba77112

• [AMQ-8354]

  Show description for 7f9f156
  NikitaShupletsov

  committed
  7f9f156

• [AMQ-8354] Add message compaction when there is no consumer.

  NikitaShupletsov

  committed
  004b459

• [AMQ-8354] Add replica batch acknowledge.

  NikitaShupletsov

  committed
  35a92dd

• [AMQ-8354]

  Show description for a382d0a
  NikitaShupletsov

  committed
  a382d0a

• [AMQ-8354] Improve Batcher to make batches bigger.

  NikitaShupletsov

  committed
  77512b0

• [AMQ-8354]

  Show description for 752094f
  NikitaShupletsov

  committed
  752094f

• [AMQ-8354] Replace ReplicaStorage with Sequence.Queue in ReplicaSequencer.

  NikitaShupletsov

  committed
  bb22ed5

• [AMQ-8354] Small refactoring.

  NikitaShupletsov

  committed
  bb9bfc1

• Merge branch 'apache:main' into feature/replica_broker

  NikitaShupletsov

  authored
  17956eb

• [AMQ-8354] Add missed licence.

  NikitaShupletsov

  committed
  24f84c8

• [AMQ-8354] Add missed licence.

  NikitaShupletsov

  committed
  ec191da

Commits on Jan 10, 2023

• [AMQ-8354] Add helper methods needed for replica plugin.

  NikitaShupletsov

  committed
  d2fb99e

Commits on Jan 13, 2023

• Reimplement getAllMessageIds method to avoid pontential out of memory errors.

  NikitaShupletsov

  committed
  1fecf52

Commits on Jan 17, 2023

• Convert AdvisoryBroker to MutableBrokerFilter

  NikitaShupletsov

  committed
  a32ab41

Commits on Apr 20, 2023

• Revert "Convert AdvisoryBroker to MutableBrokerFilter"

  Show description for 0cd0fdf
  NikitaShupletsov

  committed
  0cd0fdf

• Rollback the conversion of SchedulerBroker to MutableBrokerFilter.

  NikitaShupletsov

  committed
  abc69fa

• Remove getAllMessageIds.

  NikitaShupletsov

  committed
  db18607

• Rework processDispatchNotification.

  NikitaShupletsov

  committed
  83c0546

• Merge remote-tracking branch 'origin/main' into feature/replica_broker_internal

  Show description for 49d1d76
  NikitaShupletsov

  committed
  49d1d76

• Merge remote-tracking branch 'origin/main' into feature/replica_broker

  Show description for bf7958c
  NikitaShupletsov

  committed
  bf7958c

• Merge remote-tracking branch 'origin/feature/replica_broker_internal' into feature/replica_broker

  Show description for f1fce1e
  NikitaShupletsov

  committed
  f1fce1e

• [AMQ-8354] Fix replica sequence saving and parsing.

  Show description for 6e13d2c
  NikitaShupletsov

  committed
  6e13d2c

• [AMQ-8354] NoB support.

  NikitaShupletsov

  committed
  a95b37f

• [AMQ-8354] Extract constants to parameters.

  NikitaShupletsov

  committed
  7c6949c

• [AMQ-8354] Fix errors during DLQ messages replication.

  NikitaShupletsov

  committed
  c4d51ef

• [AMQ-8354] Add JMX controllers for the failover

  NikitaShupletsov

  committed
  2e08307

• [AMQ-8354] Fix btoker.stop() when there is a blocking operation on replica.

  NikitaShupletsov

  committed
  682389b

• [AMQ-8354] ReplicaBroker stop: close listener before close event consumer

  NikitaShupletsov

  committed
  f4dbc71

• [AMQ-8354] Small refactoring.

  NikitaShupletsov

  committed
  cce67aa

• [AMQ-8354] Block consumption from replication queues when wildcard selector used.

  Show description for e19ad66
  NikitaShupletsov

  committed
  e19ad66

• [AMQ-8354] Add deinitialization of ReplicaSequencer.

  NikitaShupletsov

  committed
  6f781ec

• [AMQ-8354] Disable replication of non-persistent messages.

  NikitaShupletsov

  committed
  8724e97

• [AMQ-8354] Add failover support for replication

  NikitaShupletsov

  committed
  a04803f

• [AMQ-8354] Fix compaction with additional messages.

  Show description for 09ca5f5
  NikitaShupletsov

  committed
  09ca5f5

• [AMQ-8354] Enable replication queue protection for replica.

  Show description for 6382d56
  NikitaShupletsov

  committed
  6382d56

• [AMQ-8354] ReplicationPlugin consumer is aborted by abortSlowAckConsumerStrategy

  NikitaShupletsov

  committed
  d1d5938

• [AMQ-8354] Fixed sequence recovery.

  NikitaShupletsov

  committed
  639715e

• [AMQ-8354] topic unsubscribe durable subscription event is not replicated

  NikitaShupletsov

  committed
  8e479f3

• [AMQ-8354] Replication queues purge notification

  NikitaShupletsov

  committed
  837366f

• [AMQ-8354] fix acknowledge replication message from AMQP protocol

  NikitaShupletsov

  committed
  6ec52b0

• [AMQ-8354] Soft failover implementation

  NikitaShupletsov

  committed
  87bdc6c

• [AMQ-8354] Change batch ack to individual acks.

  NikitaShupletsov

  committed
  c23f5eb

• [AMQ-8354] Fix transactions in compactor.

  Show description for ffe7fdd
  NikitaShupletsov

  committed
  ffe7fdd

• [AMQ-8354] Replication event is out of order. Current sequence 1 belongs to message with id

  NikitaShupletsov

  committed
  1aa6289

• [AMQ-8354] Isolate context to prevent concurrent modifications.

  NikitaShupletsov

  committed
  8d9b7be

• [AMQ-8354] Add web console access control.

  NikitaShupletsov

  committed
  1de0bfc

• [AMQ-8354] Save Broker failover state and make failover more resilient to failure

  NikitaShupletsov

  committed
  531b3f4

• [AMQ-8354] Fix send to main queue when there is only one message in the batch.

  Show description for a7cde2d
  NikitaShupletsov

  committed
  a7cde2d

• [AMQ-8354] Remove scheduled messages replication support.

  NikitaShupletsov

  committed
  2c1a9dc

• [AMQ-8354] bug fix - Virtual destinations replication works incorrectly

  NikitaShupletsov

  committed
  471d5dc

• [AMQ-8354] Fix acks when they are a single message in a batch.

  NikitaShupletsov

  committed
  3bb6552

• [AMQ-8354] Ignore MessageAck and Transactional replication events if corresponding entities do not exist

  NikitaShupletsov

  committed
  0bf290a

• [AMQ-8354] Redelivery plugin support.

  NikitaShupletsov

  committed
  41c36a5

Commits on Apr 26, 2023

• [AMQ-8354] Refactoring.

  Show description for fcb676c
  NikitaShupletsov

  committed
  fcb676c

• [AMQ-8354] Add handling failures during failover on replica side.

  NikitaShupletsov

  committed
  9450293

• [AMQ-8354] Fix Not authorized to access destination: topic://ActiveMQ.Plugin.Replication.Role.Advisory.Topic

  NikitaShupletsov

  committed
  c5695d6

• [AMQ-8354] Fix role switching when there is an ongoing failover already.

  NikitaShupletsov

  committed
  7a0451f

• [AMQ-8354] Less invasive implementation of advisory suppresor.

  NikitaShupletsov

  committed
  ae68560

• [AMQ-8354] Small refactoring.

  NikitaShupletsov

  committed
  e92b5d5

• [AMQ-8354] Fix and add tests.

  NikitaShupletsov

  committed
  44216d2

• [AMQ-8354] Replication plugin basic functionality tests - part 1.

  NikitaShupletsov

  committed
  1df8656

• [AMQ-8354] Replication plugin basic function tests - replication event handling

  NikitaShupletsov

  committed
  28c6ef6

• [AMQ-8354] Replication plugin basic function test - Replication event Ack

  NikitaShupletsov

  committed
  186a932

• [AMQ-8354] plugin test: queue operations

  NikitaShupletsov

  committed
  0c52cfb

• [AMQ-8354] plugin test: Topic operations

  NikitaShupletsov

  committed
  0fc8143

• [AMQ-8354] add message property replication test

  NikitaShupletsov

  committed
  75e4a06

• [AMQ-8354] replication NetworkConnector tests

  NikitaShupletsov

  committed
  f7b1956

• [AMQ-8354] plugin Connection level protocol connection tests

  NikitaShupletsov

  committed
  0cc90b4

• [AMQ-8354] added Connection mode tests and amqp connection test

  NikitaShupletsov

  committed
  d434315

• [AMQ-8354] Add Replication Queue Operations Tests

  NikitaShupletsov

  committed
  48e6360

• [AMQ-8354] Enable testDurableSubscribers

  NikitaShupletsov

  committed
  49b5a67

Commits on Apr 27, 2023

• [AMQ-8354] Replication test: hard failover

  NikitaShupletsov

  committed
  9890a3a

• [AMQ-8354] refactor integration tests

  NikitaShupletsov

  committed
  48455db

• [AMQ-8354] Replication Tests: soft failover tests

  NikitaShupletsov

  committed
  6d72d74

• [AMQ-8354] refactor integration tests

  NikitaShupletsov

  committed
  e7bf5c6

• [AMQ-8354] Fix integration tests.

  NikitaShupletsov

  committed
  4ab19f7

• [AMQ-8354] add replication redelivery plugin test

  NikitaShupletsov

  committed
  b670d43

• [AMQ-8354] fix Replica Plugin Queue Test

  NikitaShupletsov

  committed
  5e9bcec

Commits on May 4, 2023

• [AMQ-8354] Remove unused imports.

  NikitaShupletsov

  committed
  f0aa0cc

Commits on May 5, 2023

• [AMQ-8354] Add missing licenses.

  NikitaShupletsov

  committed
  47e37b5

Commits on May 12, 2023

• [AMQ-8354] Fix classloader issue.

  Show description for 2dd3c5e
  NikitaShupletsov

  committed
  2dd3c5e

Commits on May 25, 2023

• [AMQ-8354] Add heart beat messages.

  NikitaShupletsov

  committed
  519322e

Commits on Jun 3, 2023

• [AMQ-8354] Add versioning.

  NikitaShupletsov

  committed
  117c9cd

• [AMQ-8354] Throw exception on replication errors.

  NikitaShupletsov

  committed
  43b6775

• [AMQ-8354] Delete TODOs and FIXMEs

  NikitaShupletsov

  committed
  213802e

• [AMQ-8354] add replication lag and wait time metrics.

  NikitaShupletsov

  committed
  b5b3975

Commits on Jun 16, 2023

• Merge remote-tracking branch 'origin/main' into feature/replica_broker

  NikitaShupletsov

  committed
  eb7a9c5

Commits on Jun 17, 2023

• [AMQ-8394] Don't disable jolokia server.

  NikitaShupletsov

  committed
  5c580fb

Commits on Jun 19, 2023

• add replication plugin test profile: replica-plugin

  Charlie-chenchrl

  committed
  4ac7d1c

Commits on Jun 26, 2023

• Merge branch 'apache:main' into feature/replica_broker

  NikitaShupletsov

  authored
  600f8b6

Commits on Jun 27, 2023

• Fix slow ack replication.

  NikitaShupletsov

  committed
  b33dfbc

Commits on Jul 19, 2023

• [AMQ-8354] Fix Replication event is out of order on broker restart.

  NikitaShupletsov

  committed
  1dfc179

Commits on Aug 25, 2023

• [AMQ-8354] Force producer flow control.

  NikitaShupletsov

  committed
  c371eb3

• [AMQ-8354] Add replication flow control.

  NikitaShupletsov

  committed
  97fc15e

• [AMQ-8354] Add an error log if a replication message is being sent to DLQ.

  NikitaShupletsov

  committed
  47934f0

• [AMQ-8354] Add JMX metric to monitor replication flow control.

  NikitaShupletsov

  committed
  3ccb887

Commits on Jan 30, 2024

• mirrored queue does not mirror replication queues (#25)

  Charlie-chenchrl

  committed
  8ff284e

• Message expired failure when the destination doesn't exist

  Show description for 07bacc3
  

  alekseie

  authored and

  Charlie-chenchrl

  committed
  07bacc3

• fix flaky Replication Integration tests

  Charlie-chenchrl

  committed
  ba17974

• fix flaky test: ReplicaAcknowledgeReplicationEventTest

  Charlie-chenchrl

  committed
  bd5aa04

Commits on May 14, 2024

• [AMQ-8354] Fix deinitialization of ReplicaBroker.

  

  NikitaShupletsov

  authored and

  kenliao94

  committed
  136d056

• [AMQ-8354] Fix replication of durable subscribers.

  

  NikitaShupletsov

  authored and

  kenliao94

  committed
  faa08a0

Commits on Jun 14, 2024

• [AMQ-8354] Fix tests

  NikitaShupletsov

  committed
  a271b35

• [AMQ-8354] Add getMessagesUntilMatches method.

  NikitaShupletsov

  committed
  8de0322

• [AMQ-8354] Add logic to load more messages if we can't find last message for recovery.

  Show description for 5f825bb
  NikitaShupletsov

  committed
  5f825bb

Commits on Jun 27, 2024

• Fix casting to Topic if there are other interceptors.

  NikitaShupletsov

  committed
  a92ecb4

• [AMQ-8354] Update mirrored queues tests to include virtual topic interceptor.

  NikitaShupletsov

  committed
  2532299

• [AMQ-8354] Fix thread leak when replication connection is failing to get established.

  NikitaShupletsov

  committed
  d1eb0bc

• [AMQ-8354] Add the ability to hide replication destinations.

  NikitaShupletsov

  committed
  8edaa17

• [AMQ-8354] Fix broken tests.

  NikitaShupletsov

  committed
  2dc778c

• [AMQ-8354] Fix unit tests.

  NikitaShupletsov

  committed
  a35a6a5