This is an automated email from the ASF dual-hosted git repository. mivanac pushed a change to branch develop in repository https://gitbox.apache.org/repos/asf/geode.git.
from 7538de5 GEODE-8167: bump spring security to recommended version (#5144) add 19d5f78 GEODE-7458: Adding option in gfsh command "start gateway sender" to control clearing of existing queues (#4387) No new revisions were added by this update. Summary of changes: ...elGatewaySenderFlushedCoordinatorJUnitTest.java | 2 +- .../internal/ParallelAsyncEventQueueImpl.java | 12 +- .../internal/SerialAsyncEventQueueImpl.java | 19 +- .../org/apache/geode/cache/wan/GatewaySender.java | 6 + .../geode/internal/cache/ColocationHelper.java | 3 +- .../internal/cache/wan/AbstractGatewaySender.java | 3 + .../wan/AbstractGatewaySenderEventProcessor.java | 18 +- ...currentParallelGatewaySenderEventProcessor.java | 11 +- .../ConcurrentParallelGatewaySenderQueue.java | 6 + .../ParallelGatewaySenderEventProcessor.java | 14 +- .../wan/parallel/ParallelGatewaySenderQueue.java | 98 +++++-- ...oncurrentSerialGatewaySenderEventProcessor.java | 9 +- .../serial/SerialGatewaySenderEventProcessor.java | 8 +- .../cache/wan/serial/SerialGatewaySenderQueue.java | 23 +- .../xmlcache/ParallelAsyncEventQueueCreation.java | 3 + .../xmlcache/ParallelGatewaySenderCreation.java | 3 + .../xmlcache/SerialAsyncEventQueueCreation.java | 3 + .../xmlcache/SerialGatewaySenderCreation.java | 3 + .../geode/management/GatewaySenderMXBean.java | 9 + .../internal/beans/GatewaySenderMBean.java | 5 + .../internal/beans/GatewaySenderMBeanBridge.java | 5 + .../geode/management/internal/i18n/CliStrings.java | 6 +- .../internal/ParallelAsyncEventQueueImplTest.java | 97 +++++++ .../internal/SerialAsyncEventQueueImplTest.java | 31 ++- ...entParallelGatewaySenderEventProcessorTest.java | 4 +- .../ParallelGatewaySenderEventProcessorTest.java | 5 +- .../wan/parallel/ParallelGatewaySenderHelper.java | 3 +- .../ParallelGatewaySenderQueueJUnitTest.java | 8 +- ...SerialGatewaySenderEventProcessorJUnitTest.java | 2 +- ...SerialGatewaySenderEventProcessorJUnitTest.java | 2 +- .../TestSerialGatewaySenderEventProcessor.java | 6 +- .../beans/GatewaySenderMBeanBridgeTest.java | 94 +++++++ .../internal/beans/GatewaySenderMBeanTest.java} | 34 ++- .../gfsh/command-pages/start.html.md.erb | 15 +- .../cli/commands/StartGatewaySenderCommand.java | 13 +- .../java/org/apache/geode/test/fake/Fakes.java | 3 + .../geode/internal/cache/wan/WANTestBase.java | 39 +++ ...ParallelGatewaySenderOperation_1_DUnitTest.java | 8 + ...ParallelGatewaySenderOperation_2_DUnitTest.java | 2 + ...ANPersistenceEnabledGatewaySenderDUnitTest.java | 291 +++++++++++++++++++++ ...rialGatewaySenderOperationsDistributedTest.java | 10 +- ...ANPersistenceEnabledGatewaySenderDUnitTest.java | 148 +++++++++++ .../StartGatewaySenderCommandDUnitTest.java | 97 +++++++ .../wan/GatewaySenderEventRemoteDispatcher.java | 4 +- .../wan/parallel/ParallelGatewaySenderImpl.java | 12 +- ...currentParallelGatewaySenderEventProcessor.java | 9 +- .../RemoteParallelGatewaySenderEventProcessor.java | 9 +- ...oncurrentSerialGatewaySenderEventProcessor.java | 8 +- .../RemoteSerialGatewaySenderEventProcessor.java | 4 +- .../cache/wan/serial/SerialGatewaySenderImpl.java | 34 ++- .../parallel/ParallelGatewaySenderImplTest.java | 92 +++++++ .../wan/serial/SerialGatewaySenderImplTest.java | 89 ++++--- 52 files changed, 1272 insertions(+), 170 deletions(-) create mode 100644 geode-core/src/test/java/org/apache/geode/cache/asyncqueue/internal/ParallelAsyncEventQueueImplTest.java create mode 100644 geode-core/src/test/java/org/apache/geode/management/internal/beans/GatewaySenderMBeanBridgeTest.java copy geode-core/src/test/java/org/apache/geode/{internal/cache/tier/sockets/CCUStatsTest.java => management/internal/beans/GatewaySenderMBeanTest.java} (60%) create mode 100644 geode-wan/src/test/java/org/apache/geode/internal/cache/wan/parallel/ParallelGatewaySenderImplTest.java copy geode-core/src/test/java/org/apache/geode/cache/asyncqueue/internal/SerialAsyncEventQueueImplTest.java => geode-wan/src/test/java/org/apache/geode/internal/cache/wan/serial/SerialGatewaySenderImplTest.java (54%)