This is an automated email from the ASF dual-hosted git repository.
randgalt pushed a change to branch persistent-watch
in repository https://gitbox.apache.org/repos/asf/curator.git.
from d16734a The lock needs a timeout
add ca1e9fb Fix, maybe cannot deleteChildren completely when
multi-client delete concurrently
add b01926d add testcase testDeleteChildrenConcurrently
add 8daddd2 refactor the comment
add dccbd7a Merge branch 'CURATOR-430' of github.com:hebelala/curator
into CURATOR-430
add 3d6176c minor formatting
add 931f1de CURATOR-431 - Fixed stat population during create
add c86ca97 CURATOR-431 - Clean up stat population
add 6ba4de3 Merge branch 'master' of
https://git-wip-us.apache.org/repos/asf/curator
add d502dde getSortedChildren() should ignore NoNode exceptions and just
treat it as if there are no children. This works around issues with container
nodes, parents not yet created, etc.
add e37cb59 Update docs to document how to use the curator-test module
with ZooKeeper 3.4.x
add bef4993 should be testCompile
add 6d36a47 Remove calls to deprecated MoreExecutors.sameThreadExecutor
add b635596 Add a simple TreeCacheExample
add 97ddf91 Merge branch 'master' of
https://git-wip-us.apache.org/repos/asf/curator
add 21b0877 PathChildrenCache stops working if container node is
auto-removed and later recreated - test and a fix
add e2d243e Better logging
add de4432e Merge branch 'CURATOR-388'
add cd365c4 Closes #247
add bfdb790 To avoid massive spinning, background operations are paused
for 1 second when there is no connection. However, this can hurt performance
terribly if background operations are queued, for example, prior to initial
connection. This changes the behavior so that the sleeps are cleared when the
connection is re-established. A separate queue of "forced sleep" operations are
kept while the connection is down. This queue then gets its sleep cleared when
the connection is re-esta [...]
add c49f037 I believe the operation needs to be removed/added back to the
delay queue to get restorting to occur. I'm concerned however, about altering
operation ordering
add 0d01ea5 added comment
add 3f7b610 added comment
add 166b5c3 queue multiple operations for a more complete test
add ab2e756 only countdown on success
add 1fade17 Merge branch 'CURATOR-443'
add 4893dba Closes #248
add a9ab77a Closes #239
add debebe9 Closes #251
add 770a0f9 [maven-release-plugin] prepare release apache-curator-4.0.1
add 6978b09 [maven-release-plugin] prepare for next development iteration
add 1c7be85 remove nodeState field, improve thread safety of cache updates
add 939d7dc remove superfluous braces, unused private method
add 043270a revert TreeNode extends AtomicReference<ChildData> change
add 99acafe Minor cleanup and formatting
add 2cc3f1f tiny formatting change: remove superfluous parentheses
add f54ed8c Merge branch 'CURATOR-447'
add f57206d Merge branch 'master' of
https://git-wip-us.apache.org/repos/asf/curator
add 7bab002 When the connection is lost
client.getZookeeperClient().getZooKeeper() needs to be called periodically so
that the ensemble provider may update the connection string, etc.
add 1e2a906 oops - didn't mean to leave this in
add eb6ad40 ConnectionStateListener should be added before starting the
client
add d35318c Closes #264 means 'if and only if'. This is not a typo
add 46a9fb7 Closes #264 means "if and only if". This is not a typo
add 72b7b87 CURATOR-460 Adjust to obey sessionExpirationPercent value
add 6e85467 CURATOR-460 Synchronize access to startOfSuspendedEpoch
add 0a5b29d CURATOR-460 Move test from TestLeaderLatch to
TestConnectionStateManager
add 9123e04 CURATOR-460 Removing unnecessary empty lines
add b6af8fd CURATOR-460 Abstraction of getUseSessionTimeoutMs and
readability improvements
add 5920c74 CURATOR-460 Make startOfSuspendedEpoch volatile
add f9128a8 Fix CURATOR-462 -- return lease created in
org.apache.curator.framework.recipes.locks.InterProcessSemaphoreV2.internalAcquire1Lease(Builder<Lease>,
long, boolean, long) when the wait for it to become active is interrupted;
test for the fix
add 3ce2948 Merge branch 'CURATOR-462' of
https://github.com/krajcsovszkig-ms/curator into CURATOR-462
add 9383aa3 Merge branch 'master' of
https://git-wip-us.apache.org/repos/asf/curator
add 2af84b9 [CURATOR-450] Fix dead link in 'Getting Started'
documentation + update protocol: http -> https
add a1f620e Merge branch 'feature/CURATOR-450' of
github.com:dongjinleekr/curator into CURATOR-450
add cc30b67 Fix for CURATOR-452
add ba8ade0 Closes #261 - fixed in a separate PR
add fe2c7c4 CURATOR-408 Handle graceful close of ZookKeeper client
waiting for all resources to be released
add cfea1fb Merge branch 'fix/CURATOR-408-close-with-timeout' of
github.com:eolivelli/curator into CURATOR-408
add b6c9420 renamed arg
add aec1347 add defaultWaitForShutdownTimeoutMs
add 6f5c5f3 Merge branch 'fix/CURATOR-408-close-with-timeout' of
github.com:eolivelli/curator into CURATOR-408
add 633db98 rename property
add 5ad566e rename to waitForShutdownTimeoutMs
add 4d87380 Merge branch 'fix/CURATOR-408-close-with-timeout' of
github.com:eolivelli/curator into CURATOR-408
add 586efb5 rename method for clarity
add f686ec9 another rename
add d1d00bc last rename
add c097e4b Merge branch 'fix/CURATOR-408-close-with-timeout' of
github.com:eolivelli/curator into CURATOR-408
add 1fa4bf6 Added a test and moved to Java 8 - needed by ZK 3.5.4
add 49485b8 CURATOR-448 - Include curator framework state in error
messages
add d976c50 Merge branch 'CURATOR-448' of github.com:cjmctague/curator
into CURATOR-448
add 129ef5e Closes #267
add b5cb8a4 license header
add ae309a2 Closes #265 - closing in favor of an alternate PR
add 2fee3a5 CURATOR-471
add 5cb22be Java 8
add d4547b4 Merge branch 'master' into CURATOR-408
add 8a75db8 Added SO links
add 7a807ff Closes #273 - not needed
add 8950151 CURATOR-476 PathChildrenCache should check resultCode=-101
for getData(...) done on non-existent child and remove it from it's initialSet
add 36592e7 Merge branch 'master' of
https://git-wip-us.apache.org/repos/asf/curator
add 1afa38e Support client timeouts < 1000ms
add 26fcc3c Merge branch 'master' of github.com:matobet/curator into
CURATOR-475
add 91e3a64 fix path used when re-creating sequential PersistentNode with
protection
add 8e4dba7 add targeted unit test for bug/fix
add 824b727 change to use if statements; remove redundant isSequential
method
add 4d6069a fix bug in reworked createPath determination logic
add eebff92 Move sequential suffix extraction logic into ZKPaths helper
method
add b91036b CURATOR-472
add 90a3e4c added a comment on change
add 26ffdfb CURATOR-472 - Fixed unit test
add 5c27ecc CURATOR-489: CreateBuilderImpl assigns protectedId if
doProtected is true
add 6aa0a17 Added test for async create protected
add 1bc21db Merge pull request #1 from
Randgalt/CURATOR-489-set-protectedId
add 1720520 expanded async-create-protected test to verify protectedId
add d13a12f Closes #279 I have a test for this along with the fix. I'm
going to close this in favor of what I have.
add 6a9c6ab fixed the version handling,
https://issues.apache.org/jira/browse/CURATOR-480
add d7774c4 CURATOR-492 - Apache parent pom version 21
add b0cd919 CURATOR-491
add aea4086 removed debug prints
add 49d08cc left code commented out
add 85161ab Merge branch 'CURATOR-491' into CURATOR-490
add 4c99357 CURATOR-490
add 2adccc5 Merge branch 'CURATOR-491'
add d965266 CURATOR-405
add 1731834 Merge branch 'CURATOR-405' into CURATOR-490
add b94844a CURATOR-490 testReentrantSingleLock() should not be run for
TestInterProcessSemaphoreMutex as InterProcessSemaphoreMutex is not re-entrant
add 05f6a56 Fix test case with testDeleteChildrenConcurrently
add caf2a9d Merge branch 'CURATOR-493' into CURATOR-490
add 771e9a4 Merge branch 'CURATOR-405'
add 964f11a Closes #288 I have a different implementation that is more
generalized for future use. I'll close this and open a new PR
add a17d3af Merge branch 'master' into CURATOR-490
add 97e7691 CURATOR-468
add ddfcbc1 Add a comment explaining
add f49a6d1 Merge branch 'CURATOR-468'
add 06f6ccb CURATOR-461 removed some old settings
add 41a9e1e [maven-release-plugin] prepare release
apache-curator-4.0.2-SNAPSHOT
add a601cb0 [maven-release-plugin] prepare for next development iteration
add 1a94781 [maven-release-plugin] rollback the release of
apache-curator-4.0.2-SNAPSHOT
add 68f03eb [maven-release-plugin] prepare release apache-curator-4.0.2
add c495c1a [maven-release-plugin] prepare for next development iteration
add b1e69a6 [maven-release-plugin] rollback the release of
apache-curator-4.0.2
add 1429676 fixed CachedModeledFrameworkImpl children queries,
https://issues.apache.org/jira/browse/CURATOR-479
add a0f5f6e Merge branch 'CURATOR-479' of github.com:Hendrik-H/curator
into CURATOR-479
add 8187833 CURATOR-479
add b6cabde Merge branch 'CURATOR-479'
add 6457f26 Make GzipCompressionProvider to recycle Deflaters and
Inflaters in pools
add 7467e59 Add tests
add 388787c Merge branch 'GzipCompressionProvider-references' of
https://github.com/leventov/curator into CURATOR-487
add ec70208 CURATOR-487 - Rename unit test
add f6868f4 Merge branch 'CURATOR-487'
add 5b15f5f Merge branch 'master' of
https://git-wip-us.apache.org/repos/asf/curator
add d4a0d95 added support for zkwatches
add 88df79b address review feedback
add 60e9be8 fix test case
add 53c4770 address review comments
add 7680e15 reorder imports
add b7c902a added for exists watcher also
add 7e9628e use maybeWatch
add 2d4aa57 Merge branch 'CURATOR-477' of
https://github.com/ramaraochavali/curator into CURATOR-477
add 2a9f04a Merge branch 'master' of
https://git-wip-us.apache.org/repos/asf/curator
add 123a739 Make ZKPaths.makePath() methods to allocate less garbage
add 3517d96 CURATOR-479
add 2738324 CURATOR-479
add 647f278 Merge branch 'CURATOR-479-2' of
https://git-wip-us.apache.org/repos/asf/curator into CURATOR-479-2
add 22c028f Merge branch 'CURATOR-479-2'
add f91adb2 CURATOR-495
add 4fa5c1d CURATOR-495 - have methods return a CompletableFuture so that
callers can check completion, etc.
add 2e802ef CURATOR-495 runSafeService should return this
add 239c93e [maven-release-plugin] prepare release apache-curator-4.1.0
add df073e2 [maven-release-plugin] prepare for next development iteration
add 219c881 CURATOR-497 - include a link to the Download wiki page and
update doxia revs
add 4251fe3 CURATOR-501 remove ZK 3.5 only class from expectedExceptions
in test annotation
add 7f65c9e CURATOR-500 - move to Gitbox
add ea505f5 CURATOR-498
add 5751526 CURATOR-498
add e0b6c9b CURATOR-498
add e6defc4 CURATOR-498
add eada598 CURATOR-498
add 782448e CURATOR-498
add 6cf28ec CURATOR-498 - minor tuning to testSessionSurvives() test
add 973cb0b Merge branch 'CURATOR-498'
add 7f1c0dd CURATOR-505
add 96f186a CURATOR-505 - interim checking - refactoring,
simplifications, more testing, and documentation
add a162f5b CURATOR-505 - decoration of ConnectionStateListeners is now
automatic (a backdoor is provided)
add c9e3cf6 CURATOR-505 - refactoring/refining a new listener container
that doesn't rely on Guava and supports mapping. We need for this PR anyway.
add 7458a20 CURATOR-505 ctor should be private
add b18af51 CURATOR-505 - Some refactoring and more doc
add 2e980e7 CURATOR-505 - didn't mean to check this in
add 6e4466f CURATOR-505 - fix elapsed calculation in the circuit breaker
add 48bd767 Merge branch 'CURATOR-505'
add 9908d45 Closes CURATOR-413 - Added travis config file
add 73ce867 Update deps
add 518ac56 Improve comment
add 0a00aca Merge branch 'update-deps-2018' of github.com:metamx/curator
into CURATOR-503
add 6c07104 CURATOR-503 guava has been broken into multiple JARs it
seems. Our shading needs to reflect that
add eeeb198 Update README.md
add f474eb4 Update README.md
add aa5f161 Merge branch 'master' of
https://gitbox.apache.org/repos/asf/curator
add 20cda94 CURATOR-481 Remove jackson-mapper-asl-version and update to
latest version of jackson
add f91064b CURATOR-481 Remove jackson-mapper-asl-version and update to
latest version of jackson Max-Pudov 10/9/2018 3:11 PM
add e11279d Merge branch 'CURATOR-481' of github.com:Max-Pudov/curator
into CURATOR-481
add 3bd9583 changed phase of maven-license-plugin to validate in order to
avoid compilation and testing of invalid code (fail as early as possible)
add 1552755 Merge pull request #259 from krichter722/license-plugin-phase
add a6167b6 [maven-release-plugin] prepare release apache-curator-4.1.1
add 0dd7ce3 [maven-release-plugin] prepare for next development iteration
add dc6e785 [maven-release-plugin] prepare release apache-curator-4.2.0
add b18a431 [maven-release-plugin] prepare for next development iteration
add e74584f move to gitbox
add 8a7618f CURATOR-511: Add toString to ZKPaths PathAndNode
add 5ff7952 Merge pull request #305 from BELUGABEHR/CURATOR-511
add 6f0f5f2 Merge branch 'master' of
https://gitbox.apache.org/repos/asf/curator
add 7f353ec fixed some broken left nav links
add 824a2eb added myself in the developers section
add fa3f84d [CURATOR-429] Make Curator 4.x compatible with Zookeeper
3.4.x in OSGi too
add a3514d8 Merge pull request #311 from
JiriOndrusek/CURATOR-429_osgi-zookeeper-dependency
add 9fcd82b Modified javadoc for InterProcessLock and subclasses to be
less misleading
add 77470cb Style changes
add 4b08d44 Add note on InterProcessLock description
add 9aee198 Merge pull request #315 from emretetik96/CURATOR-530
add bc0a22a fix mailing-lists.html buttons to have mailto prefix; fix
doap.rdf to refer correctly to mailing-lists.html
add 3ed29bf Merge pull request #317 from
apache/CURATOR-528-fix-mailing-list-issues
add 5798acc Switch to OpenJDK 8 and 11
add b5eea4c Turn off spammy logs
add 9fb8dad CURATOR-536 break infinite loop in internalLeave() on timeout
add 0e4994b Merge pull request #322 from abcdenis/CURATOR-536
add 066ff40 CURATOR-533
add c670844 Merge pull request #320 from
apache/CURATOR-505-improve-circuit-breaker-to-shared
add aa7b0cf Fix ByteBuffer's compatibility issues
add db399d4 Merge pull request #321 from asdf2014/fix_bytebuffer
add cae5a53 Remove link to obsolete Stack Overflow tag
add 622fe94 Merge pull request #323 from sth/remove-obsolete-link
add d05e7dc CURATOR-537 - make getOurPath() public
add 20223ad Merge pull request #324 from apache/CURATOR-537
add 1b0bdf2 Update zookeeper to 3.5.5 stable version
add 1cd08fe Merge remote-tracking branch 'upstream/master'
add 2d33782 Merge pull request #314 from aseychell/master
add 3bef5e9 CURATOR-541
add 022a02a Merge branch 'CURATOR-541'
add b606885 temp checking to see if adding synchronized fixes travis
add 0ec8b44 Merge branch 'CURATOR-541-x'
add 3083f8d CURATOR-543
add f17e3e6 Merge pull request #327 from
apache/CURATOR-543-fix-testLockACLs-due-to-ZOOKEEPER-1392
new 6580885 Merge branch 'master' into persistent-watch
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.travis.yml | 4 +
README.md | 4 +
curator-client/pom.xml | 8 +-
.../java/org/apache/curator/ConnectionState.java | 9 +-
.../org/apache/curator/CuratorZookeeperClient.java | 54 +++-
.../main/java/org/apache/curator/HandleHolder.java | 19 +-
.../org/apache/curator/utils/Compatibility.java | 45 ++-
.../curator/utils/InjectSessionExpiration.java | 34 +-
.../java/org/apache/curator/utils/ZKPaths.java | 139 ++++++--
.../test/java/org/apache/curator/BasicTests.java | 4 +-
.../apache/curator/TestSessionFailRetryLoop.java | 10 +-
curator-examples/pom.xml | 14 +-
.../src/main/java/cache/TreeCacheExample.java | 57 ++++
.../src/main/java/discovery/InstanceDetails.java | 2 +-
curator-framework/pom.xml | 6 +-
.../apache/curator/framework/CuratorFramework.java | 38 ++-
.../curator/framework/CuratorFrameworkFactory.java | 69 +++-
.../curator/framework/imps/CreateBuilderImpl.java | 102 +++---
.../framework/imps/CuratorFrameworkImpl.java | 129 +++++---
.../framework/imps/CuratorTempFrameworkImpl.java | 4 +-
.../curator/framework/imps/EnsembleTracker.java | 6 +
.../framework/imps/GzipCompressionProvider.java | 311 ++++++++++++++++--
.../curator/framework/imps/OperationAndData.java | 5 +
.../curator/framework/imps/ProtectedMode.java | 113 +++++++
.../framework/listen/ListenerContainer.java | 11 +-
.../Watchable.java => listen/ListenerManager.java} | 32 +-
.../framework/listen/MappingListenerManager.java | 108 +++++++
.../framework/listen/StandardListenerManager.java | 96 ++++++
.../framework/listen/UnaryListenerManager.java | 10 +-
.../curator/framework/schema/SchemaViolation.java | 3 +-
.../curator/framework/state/CircuitBreaker.java | 111 +++++++
.../CircuitBreakingConnectionStateListener.java | 215 +++++++++++++
.../framework/state/CircuitBreakingManager.java | 91 ++++++
.../framework/state/ConnectionStateListener.java | 15 +-
.../ConnectionStateListenerManagerFactory.java | 69 ++++
.../framework/state/ConnectionStateManager.java | 69 ++--
.../framework/ensemble/TestEnsembleProvider.java | 162 ++++++++++
.../curator/framework/imps/TestCleanState.java | 4 +-
.../framework/imps/TestCreateReturningStat.java | 30 ++
.../imps/TestEnabledSessionExpiredState.java | 4 +-
.../curator/framework/imps/TestFramework.java | 47 +++
.../curator/framework/imps/TestFrameworkEdges.java | 355 +++++++++++++++++----
.../imps/TestGzipCompressionProvider.java | 125 ++++++++
.../curator/framework/imps/TestRemoveWatches.java | 12 +-
.../curator/framework/imps/TestTtlNodes.java | 6 +
.../curator/framework/imps/TestWithCluster.java | 4 +-
.../framework/state/TestCircuitBreaker.java | 98 ++++++
...TestCircuitBreakingConnectionStateListener.java | 227 +++++++++++++
.../state/TestConnectionStateManager.java | 82 +++++
curator-recipes/pom.xml | 6 +-
.../recipes/barriers/DistributedBarrier.java | 7 +-
.../recipes/barriers/DistributedDoubleBarrier.java | 14 +-
.../framework/recipes/cache/PathChildrenCache.java | 53 ++-
.../curator/framework/recipes/cache/TreeCache.java | 168 +++++-----
.../framework/recipes/leader/LeaderLatch.java | 43 ++-
.../framework/recipes/leader/LeaderSelector.java | 27 +-
.../framework/recipes/locks/InterProcessLock.java | 5 +-
.../recipes/locks/InterProcessMultiLock.java | 3 +
.../framework/recipes/locks/InterProcessMutex.java | 2 +-
.../recipes/locks/InterProcessSemaphoreMutex.java | 7 +
.../recipes/locks/InterProcessSemaphoreV2.java | 32 +-
.../framework/recipes/locks/LockInternals.java | 44 +--
.../framework/recipes/nodes/PersistentNode.java | 16 +-
.../recipes/queue/DistributedDelayQueue.java | 2 +-
.../framework/recipes/queue/QueueBuilder.java | 4 +-
.../framework/recipes/shared/SharedCount.java | 2 +-
.../framework/recipes/cache/BaseTestTreeCache.java | 12 +
.../framework/recipes/cache/TestNodeCache.java | 12 +-
.../recipes/cache/TestPathChildrenCache.java | 109 ++++++-
.../framework/recipes/cache/TestTreeCache.java | 39 ++-
.../framework/recipes/leader/TestLeaderLatch.java | 151 +++++++++
.../recipes/leader/TestLeaderSelector.java | 48 ++-
.../recipes/locks/TestInterProcessMutex.java | 4 +-
.../recipes/locks/TestInterProcessMutexBase.java | 4 +-
.../recipes/locks/TestInterProcessSemaphore.java | 49 +++
.../locks/TestInterProcessSemaphoreMutex.java | 10 +-
.../framework/recipes/locks/TestLockACLs.java | 4 +-
.../recipes/nodes/TestPersistentEphemeralNode.java | 52 +--
.../recipes/nodes/TestPersistentNode.java | 33 ++
.../recipes/nodes/TestPersistentTtlNode.java | 6 +
.../recipes/queue/TestDistributedQueue.java | 2 +-
curator-test-zk34/pom.xml | 13 +-
.../org/apache/curator/test/Compatibility.java | 8 -
curator-test/pom.xml | 6 +-
.../org/apache/curator/test/BaseClassForTests.java | 150 +++------
.../org/apache/curator/test/Compatibility.java | 7 -
.../curator/test/compatibility/KillSession2.java | 40 ---
curator-x-async/pom.xml | 14 +-
.../details/CachedModeledFrameworkImpl.java | 4 +-
.../modeled/details/ModeledFrameworkImpl.java | 2 +-
.../curator/framework/imps/TestFramework.java | 29 ++
.../async/modeled/TestCachedModeledFramework.java | 69 +++-
.../x/async/modeled/TestModeledFramework.java | 10 +-
curator-x-discovery-server/pom.xml | 43 ++-
.../server/contexts/GenericDiscoveryContext.java | 8 +-
.../server/contexts/IntegerDiscoveryContext.java | 4 +-
.../server/contexts/StringDiscoveryContext.java | 4 +-
.../entity/JsonServiceInstanceMarshaller.java | 6 +-
.../entity/JsonServiceInstancesMarshaller.java | 8 +-
.../server/entity/JsonServiceNamesMarshaller.java | 22 +-
.../x/discovery/server/rest/DiscoveryContext.java | 4 +-
.../server/jetty_jersey/ServiceDetails.java | 3 +-
curator-x-discovery/pom.xml | 11 +-
.../curator/x/discovery/ServiceInstance.java | 6 +-
.../discovery/details/JsonInstanceSerializer.java | 12 +-
.../x/discovery/details/OldServiceInstance.java | 5 +-
.../x/discovery/details/ServiceCacheImpl.java | 22 +-
.../TestJsonInstanceSerializerCompatibility.java | 4 +-
.../discovery/details/TestNewServiceInstance.java | 5 +-
.../x/discovery/details/TestServiceCacheRace.java | 128 ++++++++
.../x/discovery/details/TestServiceDiscovery.java | 8 +-
doap.rdf | 6 +-
pom.xml | 188 ++++++++---
src/site/confluence/errors.confluence | 4 +-
src/site/confluence/getting-started.confluence | 4 +-
src/site/confluence/index.confluence | 8 +
src/site/confluence/logging.confluence | 2 +-
src/site/confluence/utilities.confluence | 28 ++
src/site/confluence/zk-compatibility.confluence | 31 +-
src/site/site.xml | 14 +-
120 files changed, 4214 insertions(+), 868 deletions(-)
create mode 100644 .travis.yml
create mode 100644 curator-examples/src/main/java/cache/TreeCacheExample.java
create mode 100644
curator-framework/src/main/java/org/apache/curator/framework/imps/ProtectedMode.java
copy
curator-framework/src/main/java/org/apache/curator/framework/{api/Watchable.java
=> listen/ListenerManager.java} (61%)
create mode 100644
curator-framework/src/main/java/org/apache/curator/framework/listen/MappingListenerManager.java
create mode 100644
curator-framework/src/main/java/org/apache/curator/framework/listen/StandardListenerManager.java
copy curator-examples/src/main/java/pubsub/models/Priority.java =>
curator-framework/src/main/java/org/apache/curator/framework/listen/UnaryListenerManager.java
(81%)
create mode 100644
curator-framework/src/main/java/org/apache/curator/framework/state/CircuitBreaker.java
create mode 100644
curator-framework/src/main/java/org/apache/curator/framework/state/CircuitBreakingConnectionStateListener.java
create mode 100644
curator-framework/src/main/java/org/apache/curator/framework/state/CircuitBreakingManager.java
create mode 100644
curator-framework/src/main/java/org/apache/curator/framework/state/ConnectionStateListenerManagerFactory.java
create mode 100644
curator-framework/src/test/java/org/apache/curator/framework/ensemble/TestEnsembleProvider.java
create mode 100644
curator-framework/src/test/java/org/apache/curator/framework/imps/TestGzipCompressionProvider.java
create mode 100644
curator-framework/src/test/java/org/apache/curator/framework/state/TestCircuitBreaker.java
create mode 100644
curator-framework/src/test/java/org/apache/curator/framework/state/TestCircuitBreakingConnectionStateListener.java
create mode 100644
curator-framework/src/test/java/org/apache/curator/framework/state/TestConnectionStateManager.java
delete mode 100644
curator-test/src/main/java/org/apache/curator/test/compatibility/KillSession2.java
create mode 100644
curator-x-discovery/src/test/java/org/apache/curator/x/discovery/details/TestServiceCacheRace.java
