808 tests were completed in 2127s with 793 passed, 1 failed and 14 skipped. |Test suite|Passed|Failed|Skipped|Time| |:---|---:|---:|---:|---:| |org.apache.pulsar.AddMissingPatchVersionTest||1❌|1✖️|116ms| |org.apache.pulsar.broker.admin.AdminApiOffloadTest|7✔️|||19s| |org.apache.pulsar.broker.auth.AuthenticationServiceTest|2✔️|||185ms| |org.apache.pulsar.broker.auth.AuthLogsTest|2✔️|||1s| |org.apache.pulsar.broker.auth.AuthorizationTest|1✔️|||2s| |org.apache.pulsar.broker.lookup.http.HttpTopicLookupv2Test|4✔️|||2s| |org.apache.pulsar.broker.namespace.NamespaceCreateBundlesTest|2✔️|||33s| |org.apache.pulsar.broker.namespace.NamespaceOwnershipListenerTests|2✔️|||32s| |org.apache.pulsar.broker.namespace.NamespaceServiceTest|10✔️|||75s| |org.apache.pulsar.broker.namespace.NamespaceUnloadingTest|2✔️|||14s| |org.apache.pulsar.broker.namespace.OwnerShipCacheForCurrentServerTest|1✔️|||16s| |org.apache.pulsar.broker.namespace.OwnershipCacheTest|8✔️|||16s| |org.apache.pulsar.broker.protocol.ProtocolHandlersTest|6✔️|||946ms| |org.apache.pulsar.broker.protocol.ProtocolHandlerUtilsTest|3✔️|||7s| |org.apache.pulsar.broker.protocol.ProtocolHandlerWithClassLoaderTest|1✔️|||15ms| |org.apache.pulsar.broker.PulsarServiceTest|2✔️|||96ms| |org.apache.pulsar.broker.service.MessagePublishBufferThrottleTest|3✔️|||14s| |org.apache.pulsar.broker.service.ReplicatorTest|22✔️|||40s| |org.apache.pulsar.broker.service.TopicOwnerTest|8✔️|||114s| |org.apache.pulsar.broker.SLAMonitoringTest|4✔️|||9s| |org.apache.pulsar.broker.stats.BookieClientsStatsGeneratorTest|2✔️|||49ms| |org.apache.pulsar.broker.stats.ConsumerStatsTest|3✔️|||21s| |org.apache.pulsar.broker.stats.ManagedCursorMetricsTest|1✔️|||281ms| |org.apache.pulsar.broker.stats.ManagedLedgerMetricsTest|1✔️|||285ms| |org.apache.pulsar.broker.stats.prometheus.AggregatedNamespaceStatsTest|1✔️|||40ms| |org.apache.pulsar.broker.stats.PrometheusMetricsTest|15✔️|||83s| |org.apache.pulsar.broker.stats.SubscriptionStatsTest|2✔️|||2s| |org.apache.pulsar.broker.systopic.NamespaceEventsSystemTopicServiceTest|1✔️|||1s| |org.apache.pulsar.broker.transaction.buffer.InMemTransactionBufferReaderTest|3✔️|||28ms| |org.apache.pulsar.broker.transaction.buffer.TransactionBufferClientTest|4✔️|||93ms| |org.apache.pulsar.broker.transaction.buffer.TransactionBufferTest|7✔️|||81ms| |org.apache.pulsar.broker.transaction.buffer.TransactionEntryImplTest|1✔️|||14ms| |org.apache.pulsar.broker.transaction.buffer.TransactionLowWaterMarkTest|2✔️|||38s| |org.apache.pulsar.broker.transaction.buffer.TransactionStablePositionTest|2✔️||1✖️|49s| |org.apache.pulsar.broker.transaction.coordinator.TransactionCoordinatorClientTest|3✔️|||95ms| |org.apache.pulsar.broker.transaction.coordinator.TransactionMetaStoreAssignmentTest|1✔️|||1s| |org.apache.pulsar.broker.transaction.pendingack.PendingAckInMemoryDeleteTest|2✔️||1✖️|57s| |org.apache.pulsar.broker.transaction.TransactionConsumeTest|2✔️|||30s| |org.apache.pulsar.broker.web.RestExceptionTest|3✔️|||37ms| |org.apache.pulsar.broker.web.WebServiceTest|9✔️|||27s| |org.apache.pulsar.client.impl.AdminApiKeyStoreTlsAuthTest|4✔️|||8s| |org.apache.pulsar.client.impl.BatchMessageIdImplSerializationTest|4✔️|||30ms| |org.apache.pulsar.client.impl.BatchMessageIndexAckDisableTest|4✔️|||14s| |org.apache.pulsar.client.impl.BatchMessageIndexAckTest|5✔️|||44s| |org.apache.pulsar.client.impl.BrokerClientIntegrationTest|15✔️|||148s| |org.apache.pulsar.client.impl.CompactedOutBatchMessageTest|1✔️|||1s| |org.apache.pulsar.client.impl.ConsumerAckResponseTest|1✔️|||549ms| |org.apache.pulsar.client.impl.ConsumerConfigurationTest|4✔️|||12s| |org.apache.pulsar.client.impl.ConsumerDedupPermitsUpdate|7✔️|||4s| |org.apache.pulsar.client.impl.ConsumerUnsubscribeTest|1✔️|||129ms| |org.apache.pulsar.client.impl.KeyStoreTlsProducerConsumerTestWithAuth|3✔️|||23s| |org.apache.pulsar.client.impl.KeyStoreTlsProducerConsumerTestWithoutAuth|3✔️|||8s| |org.apache.pulsar.client.impl.KeyStoreTlsTest|1✔️|||183ms| |org.apache.pulsar.client.impl.MessageChecksumTest|3✔️|||47s| |org.apache.pulsar.client.impl.MessageChunkingTest|8✔️||1✖️|73s| |org.apache.pulsar.client.impl.MessageParserTest|2✔️|||5s| |org.apache.pulsar.client.impl.MultiTopicsReaderTest|8✔️|||35s| |org.apache.pulsar.client.impl.NegativeAcksTest|32✔️|||11s| |org.apache.pulsar.client.impl.PatternTopicsConsumerImplTest|11✔️|||63s| |org.apache.pulsar.client.impl.PerMessageUnAcknowledgedRedeliveryTest|5✔️|||34s| |org.apache.pulsar.client.impl.PulsarMultiHostClientTest|3✔️|||15s| |org.apache.pulsar.client.impl.RawMessageSerDeserTest|1✔️|||10ms| |org.apache.pulsar.client.impl.SchemaDeleteTest|1✔️|||2s| |org.apache.pulsar.client.impl.SequenceIdWithErrorTest|3✔️||2✖️|18s| |org.apache.pulsar.client.impl.TopicDoesNotExistsTest|2✔️|||4s| |org.apache.pulsar.client.impl.TopicFromMessageTest|5✔️|||14s| |org.apache.pulsar.client.impl.TopicsConsumerImplTest|17✔️|||133s| |org.apache.pulsar.client.impl.UnAcknowledgedMessagesTimeoutTest|7✔️|||44s| |org.apache.pulsar.client.impl.ZeroQueueSizeTest|14✔️|||16s| |org.apache.pulsar.common.api.raw.RawMessageImplTest|1✔️|||316ms| |org.apache.pulsar.common.compression.CommandsTest|1✔️|||30ms| |org.apache.pulsar.common.compression.CompressorCodecBackwardCompatTest|6✔️|||223ms| |org.apache.pulsar.common.compression.CompressorCodecTest|45✔️|||737ms| |org.apache.pulsar.common.compression.Crc32cChecksumTest|6✔️|||5s| |org.apache.pulsar.common.lookup.data.LookupDataTest|4✔️|||2s| |org.apache.pulsar.common.naming.MetadataTests|2✔️|||161ms| |org.apache.pulsar.common.naming.NamespaceBundlesTest|5✔️|||99ms| |org.apache.pulsar.common.naming.NamespaceBundleTest|6✔️|||64ms| |org.apache.pulsar.common.naming.NamespaceNameTest|2✔️|||207ms| |org.apache.pulsar.common.naming.ServiceConfigurationTest|4✔️|||48ms| |org.apache.pulsar.common.naming.TopicNameTest|4✔️|||529ms| |org.apache.pulsar.common.net.ServiceURITest|21✔️|||237ms| |org.apache.pulsar.common.policies.data.AutoFailoverPolicyDataTest|1✔️|||15ms| |org.apache.pulsar.common.policies.data.AutoFailoverPolicyTypeTest|1✔️|||19ms| |org.apache.pulsar.common.policies.data.AutoTopicCreationOverrideTest|6✔️|||64ms| |org.apache.pulsar.common.policies.data.BacklogQuotaTest|1✔️|||12ms| |org.apache.pulsar.common.policies.data.ClusterDataTest|1✔️|||9ms| |org.apache.pulsar.common.policies.data.ConsumerStatsTest|1✔️|||8ms| |org.apache.pulsar.common.policies.data.EnsemblePlacementPolicyConfigTest|2✔️|||948ms| |org.apache.pulsar.common.policies.data.LocalPolicesTest|1✔️|||48ms| |org.apache.pulsar.common.policies.data.NamespaceIsolationDataTest|1✔️|||76ms| |org.apache.pulsar.common.policies.data.NamespaceOwnershipStatusTest|1✔️|||45ms| |org.apache.pulsar.common.policies.data.OffloadPoliciesTest|6✔️|||216ms| |org.apache.pulsar.common.policies.data.PartitionedTopicStatsTest|1✔️|||12ms| |org.apache.pulsar.common.policies.data.PersistencePoliciesTest|1✔️|||19ms| |org.apache.pulsar.common.policies.data.PersistentOfflineTopicStatsTest|1✔️|||29ms| |org.apache.pulsar.common.policies.data.PersistentTopicStatsTest|2✔️|||51ms| |org.apache.pulsar.common.policies.data.PoliciesDataTest|4✔️|||1s| |org.apache.pulsar.common.policies.data.PublisherStatsTest|2✔️|||37ms| |org.apache.pulsar.common.policies.data.ReplicatorStatsTest|2✔️|||30ms| |org.apache.pulsar.common.policies.data.ResourceQuotaTest|2✔️|||45ms| |org.apache.pulsar.common.policies.data.RetentionPolicesTest|1✔️|||8ms| |org.apache.pulsar.common.policies.impl.AutoFailoverPolicyFactoryTest|1✔️|||22ms| |org.apache.pulsar.common.policies.impl.MinAvailablePolicyTest|1✔️|||1ms| |org.apache.pulsar.common.policies.impl.NamespaceIsolationPoliciesTest|7✔️|||265ms| |org.apache.pulsar.common.policies.impl.NamespaceIsolationPolicyImplTest|7✔️|||309ms| |org.apache.pulsar.common.protocol.ByteBufPairTest|2✔️|||5s| |org.apache.pulsar.common.protocol.CommandUtilsTests|7✔️|||3s| |org.apache.pulsar.common.protocol.MarkersTest|6✔️|||3s| |org.apache.pulsar.common.protocol.PulsarDecoderTest|1✔️|||4s| |org.apache.pulsar.common.stats.JvmDefaultGCMetricsLoggerTest|1✔️|||82ms| |org.apache.pulsar.common.util.collections.BitSetRecyclableRecyclableTest|2✔️|||13ms| |org.apache.pulsar.common.util.collections.ConcurrentBitSetRecyclableTest|2✔️|||63ms| |org.apache.pulsar.common.util.collections.ConcurrentLongHashMapTest|13✔️|||28s| |org.apache.pulsar.common.util.collections.ConcurrentLongPairSetTest|15✔️|||2s| |org.apache.pulsar.common.util.collections.ConcurrentOpenHashMapTest|12✔️|||9s| |org.apache.pulsar.common.util.collections.ConcurrentOpenHashSetTest|11✔️|||7s| |org.apache.pulsar.common.util.collections.ConcurrentOpenLongPairRangeSetTest|13✔️|||1s| |org.apache.pulsar.common.util.collections.ConcurrentSortedLongPairSetTest|9✔️|||342ms| |org.apache.pulsar.common.util.collections.FieldParserTest|2✔️|||64ms| |org.apache.pulsar.common.util.collections.GrowableArrayBlockingQueueTest|6✔️|||350ms| |org.apache.pulsar.common.util.collections.GrowablePriorityLongPairQueueTest|15✔️|||3s| |org.apache.pulsar.common.util.collections.TripleLongPriorityQueueTest|3✔️|||238ms| |org.apache.pulsar.common.util.FieldParserTest|1✔️|||242ms| |org.apache.pulsar.common.util.FileModifiedTimeUpdaterTest|6✔️|||6s| |org.apache.pulsar.common.util.netty.ChannelFuturesTest|5✔️|||2s| |org.apache.pulsar.common.util.RateLimiterTest|11✔️|||7s| |org.apache.pulsar.common.util.ReflectionsTest|12✔️|||172ms| |org.apache.pulsar.common.util.RelativeTimeUtilTest|1✔️|||39ms| |org.apache.pulsar.discovery.service.web.DiscoveryServiceWebTest|1✔️|||5s| |org.apache.pulsar.functions.worker.PulsarFunctionE2ESecurityTest|2✔️|||28s| |org.apache.pulsar.functions.worker.PulsarFunctionPublishTest|3✔️|||42s| |org.apache.pulsar.functions.worker.PulsarFunctionTlsTest|1✔️|||12s| |org.apache.pulsar.io.PulsarFunctionTlsTest|1✔️|||30s| |org.apache.pulsar.proxy.server.AdminProxyHandlerTest|1✔️|||474ms| |org.apache.pulsar.proxy.server.AuthedAdminProxyHandlerTest|1✔️|||2s| |org.apache.pulsar.proxy.server.FunctionWorkerRoutingTest|1✔️|||10ms| |org.apache.pulsar.proxy.server.ProxyAdditionalServletTest|1✔️|||125ms| |org.apache.pulsar.proxy.server.ProxyAuthenticatedProducerConsumerTest|1✔️|||2s| |org.apache.pulsar.proxy.server.ProxyAuthenticationTest|1✔️|||17s| |org.apache.pulsar.proxy.server.ProxyConnectionThrottlingTest|1✔️|||2s| |org.apache.pulsar.proxy.server.ProxyEnableHAProxyProtocolTest|1✔️|||511ms| |org.apache.pulsar.proxy.server.ProxyForwardAuthDataTest|1✔️|||32s| |org.apache.pulsar.proxy.server.ProxyIsAHttpProxyTest|10✔️|||2s| |org.apache.pulsar.proxy.server.ProxyKeyStoreTlsTestWithAuth|3✔️|||7s| |org.apache.pulsar.proxy.server.ProxyKeyStoreTlsTestWithoutAuth|3✔️|||7s| |org.apache.pulsar.proxy.server.ProxyLookupThrottlingTest|1✔️|||3s| |org.apache.pulsar.proxy.server.ProxyParserTest|5✔️|||1s| |org.apache.pulsar.proxy.server.ProxyRolesEnforcementTest|1✔️|||10s| |org.apache.pulsar.proxy.server.ProxyStatsTest|3✔️|||533ms| |org.apache.pulsar.proxy.server.ProxyTest|6✔️|||3s| |org.apache.pulsar.proxy.server.ProxyTlsTest|2✔️|||414ms| |org.apache.pulsar.proxy.server.ProxyTlsTestWithAuth|1✔️|||4ms| |org.apache.pulsar.proxy.server.ProxyWithAuthorizationNegTest|1✔️|||2s| |org.apache.pulsar.proxy.server.ProxyWithAuthorizationTest|13✔️|||33s| |org.apache.pulsar.proxy.server.ProxyWithoutServiceDiscoveryTest|1✔️|||2s| |org.apache.pulsar.proxy.server.SuperUserAuthedAdminProxyHandlerTest|3✔️|||8s| |org.apache.pulsar.proxy.server.UnauthedAdminProxyHandlerTest|2✔️|||114ms| |org.apache.pulsar.PulsarBrokerStarterTest|9✔️|||591ms| |org.apache.pulsar.schema.compatibility.SchemaCompatibilityCheckTest|23✔️|||107s| |org.apache.pulsar.schema.PartitionedTopicSchemaTest|1✔️|||29s| |org.apache.pulsar.schema.SchemaTest|3✔️|||31s| |org.apache.pulsar.stats.client.PulsarBrokerStatsClientTest|2✔️|||41s| |org.apache.pulsar.tests.EnumValuesDataProviderTest|6✔️|||23ms| |org.apache.pulsar.tests.TestRetrySupportBeforeMethodRetryTest|1✔️||4✖️|36ms| |org.apache.pulsar.tests.TestRetrySupportRetryTest|1✔️||4✖️|27ms| |org.apache.pulsar.tests.TestRetrySupportSuccessTest|3✔️|||1ms| |org.apache.pulsar.tests.ThreadDumpUtilTest|2✔️|||17ms| |org.apache.pulsar.utils.SimpleTextOutputStreamTest|4✔️|||50ms| |org.apache.pulsar.utils.StatsOutputStreamTest|6✔️|||59ms| |org.apache.pulsar.websocket.proxy.ProxyAuthenticationTest|4✔️|||29s| |org.apache.pulsar.websocket.proxy.ProxyAuthorizationTest|1✔️|||1s| |org.apache.pulsar.websocket.proxy.ProxyConfigurationTest|2✔️|||9s| |org.apache.pulsar.websocket.proxy.ProxyPublishConsumeTlsTest|1✔️|||11s| |org.apache.pulsar.websocket.proxy.ProxyPublishConsumeWithoutZKTest|1✔️|||7s| |org.apache.pulsar.websocket.proxy.v1.V1_ProxyAuthenticationTest|4✔️|||30s|
✖️ testVersionStrings ❌ testVersionStrings java.lang.AssertionError: expected [1.2.1] but found [1.2.0]
✔️ testOffloadPoliciesAppliedApi ✔️ testOffloadV2 ✔️ testTopicLevelOffloadNonPartitioned ✔️ testTopicLevelOffloadPartitioned ✔️ testOffloadV1 ✔️ testOffloadPolicies ✔️ testOffloadPoliciesApi
✔️ testAuthentication ✔️ testAuthenticationHttp
✔️ httpEndpoint ✔️ binaryEndpoint
✔️ simple
✔️ crossColoLookup ✔️ testNotEnoughLookupPermits ✔️ testValidateReplicationSettingsOnNamespace ✔️ testDataPojo
✔️ testCreateNamespaceWithDefaultBundles ✔️ testSplitBundleUpdatesLocalPoliciesWithoutOverwriting
✔️ testGetAllPartitions ✔️ testNamespaceBundleOwnershipListener
✔️ testSplitMapWithRefreshedStatMap ✔️ testRemoveOwnershipNamespaceBundle ✔️ testIsServiceUnitDisabled ✔️ testLoadReportDeserialize ✔️ testCreateLookupResult ✔️ testUnloadNamespaceBundleWithStuckTopic ✔️ testUnloadNamespaceBundleFailure ✔️ testSplitAndOwnBundles ✔️ testCreateNamespaceWithDefaultNumberOfBundles ✔️ testRemoveOwnershipAndSplitBundle
✔️ testUnloadNotLoadedNamespace ✔️ testUnloadPartiallyLoadedNamespace
✔️ testOwnershipForCurrentServer
✔️ testGetOwnedServiceUnits ✔️ testRemoveOwnership ✔️ testGetOwnedServiceUnit ✔️ testGetOrSetOwner ✔️ testConstructor ✔️ testGetOwner ✔️ testDisableOwnership ✔️ testReestablishOwnership
✔️ testStart ✔️ testGetProtocol ✔️ testNewChannelInitializersSuccess ✔️ testInitialize ✔️ testNewChannelInitializersOverlapped ✔️ testGetProtocolDataToAdvertise
✔️ testLoadProtocolHandler ✔️ testLoadProtocolHandlerBlankHandlerClass ✔️ testLoadProtocolHandlerWrongHandlerClass
✔️ testWrapper
✔️ testGetWorkerService ✔️ testGetWorkerServiceException
✔️ testMessagePublishBufferThrottleEnable ✔️ testBlockByPublishRateLimiting ✔️ testMessagePublishBufferThrottleDisabled
✔️ testResumptionAfterBacklogRelaxed ✔️ testReplicationOverrides ✔️ testResetCursorNotFail ✔️ testUpdateGlobalTopicPartition ✔️ testReplication ✔️ testReplicatorOnPartitionedTopic ✔️ testConcurrentReplicator ✔️ testTopicReplicatedAndProducerCreate ✔️ testDeleteReplicatorFailure ✔️ testReplicatorOnPartitionedTopic ✔️ testReplicationForBatchMessages ✔️ testReplicatorClearBacklog ✔️ verifyChecksumAfterReplication ✔️ testCloseReplicatorStartProducer ✔️ activeBrokerParse ✔️ testReplicatePeekAndSkip ✔️ testReplication ✔️ testReplicatedCluster ✔️ testTopicReplicatedAndProducerCreate ✔️ testConfigChange ✔️ testFailures ✔️ testReplicatorProducerClosing
✔️ testReleaseOwnershipWithZookeeperDisconnectedBeforeOwnershipNodeDeleted ✔️ testAcquireOwnershipWithZookeeperDisconnectedAfterOwnershipNodeCreated ✔️ testConnectToInvalidateBundleCacheBroker ✔️ testAcquireOwnershipWithZookeeperDisconnectedBeforeOwnershipNodeCreated ✔️ testLookupPartitionedTopic ✔️ testListNonPersistentTopic ✔️ testReleaseOwnershipWithZookeeperDisconnectedAfterOwnershipNodeDeleted ✔️ testReestablishOwnershipAfterInvalidateCache
✔️ testOwnedNamespaces ✔️ testOwnershipAfterSetup ✔️ testUnloadIfBrokerCrashes ✔️ testOwnershipViaAdminAfterSetup
✔️ testJvmDirectMemoryUsedMetric ✔️ testBookieClientStatsGenerator
✔️ testAckStatsOnPartitionedTopicForExclusiveSubscription ✔️ testConsumerStatsOnZeroMaxUnackedMessagesPerConsumer ✔️ testUpdateStatsForActiveConsumerAndSubscription
✔️ testManagedCursorMetrics
✔️ testManagedLedgerMetrics
✔️ testSimpleAggregation
✔️ testPerTopicStats ✔️ testAuthMetrics ✔️ testPerTopicExpiredStat ✔️ testPerProducerStats ✔️ testMetricsTopicCount ✔️ testManagedLedgerBookieClientStats ✔️ testDuplicateMetricTypeDefinitions ✔️ testExpiringTokenMetrics ✔️ testPerConsumerStats ✔️ testPerNamespaceStats ✔️ testManagedCursorPersistStats ✔️ testDuplicateMetricTypeDefinitions ✔️ testExpiredTokenMetrics ✔️ testManagedLedgerCacheStats ✔️ testManagedLedgerStats
✔️ testConsumersAfterMarkDelete ✔️ testNonContiguousDeletedMessagesRanges
✔️ testSendAndReceiveNamespaceEvents
✔️ testCloseReleaseAllEntries ✔️ testInvalidNumEntriesArgument ✔️ testEndOfTransactionException
✔️ testAbortOnTopic ✔️ testAbortOnSubscription ✔️ testCommitOnTopic ✔️ testCommitOnSubscription
✔️ testOpenReaderOnNonExistentTxn ✔️ testAbortCommittedTxn ✔️ testAbortTxn ✔️ testAbortNonExistentTxn ✔️ testCommitNonExistentTxn ✔️ testCommitTxn ✔️ testOpenReaderOnAnOpenTxn
✔️ testCloseShouldReleaseBuffer
✔️ testTransactionBufferLowWaterMark ✔️ testPendingAckLowWaterMark
✔️ commitTxnTest ✔️ abortTxnTest ✖️ commitTxnTest
✔️ testClientStart ✔️ testCommitAndAbort ✔️ testNewTxn
✔️ testTransactionMetaStoreAssignAndFailover
✖️ txnAckTestNoBatchAndSharedSubMemoryDeleteTest ✔️ txnAckTestNoBatchAndSharedSubMemoryDeleteTest ✔️ txnAckTestBatchAndSharedSubMemoryDeleteTest
✔️ noSortedTest ✔️ sortedTest
✔️ testRestException ✔️ testWebApplicationException ✔️ testOtherException
✔️ testTlsAuthDisallowInsecure ✔️ testBrokerReady ✔️ testDefaultClientVersion ✔️ testTlsEnabled ✔️ testTlsAuthAllowInsecure ✔️ testSplitPath ✔️ testMaxRequestSize ✔️ testTlsDisabled ✔️ testRateLimiting
✔️ testAuthorizedUserAsOriginalPrincipal ✔️ testSuperUserCantListNamespaces ✔️ testPersistentList ✔️ testSuperUserCanListTenants
✔️ testSerializationEmpty ✔️ testSerialization1 ✔️ testSerializationNull ✔️ testSerialization2
✔️ testBatchMessageIndexAckForExclusiveSubscription ✔️ testBatchMessageIndexAckForSharedSubscription ✔️ testBatchMessageIndexAckForExclusiveSubscription ✔️ testBatchMessageIndexAckForSharedSubscription
✔️ testBatchMessageIndexAckForSharedSubscription ✔️ testBatchMessageIndexAckForSharedSubscription ✔️ testDoNotRecycleAckSetMultipleTimes ✔️ testBatchMessageIndexAckForExclusiveSubscription ✔️ testBatchMessageIndexAckForExclusiveSubscription
✔️ testDisconnectClientWithoutClosingConnection ✔️ testResetCursor ✔️ testResetCursor ✔️ testCloseBrokerService ✔️ testUnsupportedBatchMessageConsumer ✔️ testAvroSchemaProducerConsumerWithSpecifiedReaderAndWriter ✔️ testJsonSchemaProducerConsumerWithSpecifiedReaderAndWriter ✔️ testOperationTimeout ✔️ testCleanProducer ✔️ testUnsupportedBatchMessageConsumer ✔️ testCloseConnectionOnBrokerRejectedRequest ✔️ testAddEntryOperationTimeout ✔️ testInvalidDynamicConfiguration ✔️ testMaxConcurrentTopicLoading ✔️ testCloseConnectionOnInternalServerError
✔️ testCompactedOutMessages
✔️ testAckResponse
✔️ testReadCompactNonPersistentExclusive ✔️ testReadCompactPersistentExclusive ✔️ testReadCompactPersistentFailover ✔️ testReadCompactPersistentShared
✔️ testConsumerDedup ✔️ testConsumerDedup ✔️ testConsumerDedup ✔️ testConsumerDedup ✔️ testConsumerDedup ✔️ testConsumerDedup ✔️ testConsumerDedup
✔️ testConsumerUnsubscribeReference
✔️ testTlsClientAuthOverHTTPProtocol ✔️ testTlsClientAuthOverBinaryProtocol ✔️ testTlsLargeSizeMessage
✔️ testTlsClientAuthOverHTTPProtocol ✔️ testTlsClientAuthOverBinaryProtocol ✔️ testTlsLargeSizeMessage
✔️ testValidate
✔️ testChecksumCompatibilityInMixedVersionBrokerCluster ✔️ testTamperingMessageIsDetected ✔️ testChecksumCompatibilityInMixedVersionBrokerCluster
✔️ testPublishWithFailure ✔️ testInvalidUseCaseForChunking ✔️ testLargeMessage ✔️ testExpireIncompleteChunkMessage ✔️ testInvalidConfig ✔️ testLargeMessageAckTimeOut ✔️ testLargeMessageAckTimeOut ✔️ testLargeMessage ✖️ testMaxPendingChunkMessages
✔️ testWithoutBatches ✔️ testWithBatches
✔️ testReadMessageWithBatchingWithMessageInclusive ✔️ testKeyHashRangeReader ✔️ testRemoveSubscriptionForReaderNeedRemoveCursor ✔️ testReadMessageWithBatching ✔️ testReadMessageWithoutBatchingWithMessageInclusive ✔️ testMultiReaderSeek ✔️ testReadMessageWithoutBatching ✔️ testReaderWithTimeLong
✔️ testNegativeAcks ✔️ testNegativeAcks ✔️ testNegativeAcks ✔️ testNegativeAcks ✔️ testNegativeAcks ✔️ testNegativeAcks ✔️ testNegativeAcks ✔️ testNegativeAcks ✔️ testNegativeAcks ✔️ testNegativeAcks ✔️ testNegativeAcks ✔️ testNegativeAcks ✔️ testNegativeAcks ✔️ testNegativeAcks ✔️ testNegativeAcks ✔️ testNegativeAcks ✔️ testNegativeAcks ✔️ testNegativeAcks ✔️ testNegativeAcks ✔️ testNegativeAcks ✔️ testNegativeAcks ✔️ testNegativeAcks ✔️ testNegativeAcks ✔️ testNegativeAcks ✔️ testNegativeAcks ✔️ testNegativeAcks ✔️ testNegativeAcks ✔️ testNegativeAcks ✔️ testNegativeAcks ✔️ testNegativeAcks ✔️ testNegativeAcks ✔️ testNegativeAcks
✔️ testStartEmptyPatternConsumer ✔️ testBinaryProtoToGetTopicsOfNamespaceAll ✔️ testPatternTopicsSubscribeWithBuilderFail ✔️ testPubRateOnNonPersistent ✔️ testTopicDeletion ✔️ testAutoUnbubscribePatternConsumer ✔️ testTopicsPatternFilter ✔️ testBinaryProtoToGetTopicsOfNamespaceNonPersistent ✔️ testBinaryProtoToGetTopicsOfNamespacePersistent ✔️ testTopicsListMinus ✔️ testAutoSubscribePatternConsumer
✔️ testSharedAckedNormalTopic ✔️ testUnAckedMessageTrackerSize ✔️ testSharedAckedPartitionedTopic ✔️ testExclusiveAckedNormalTopic ✔️ testFailoverAckedNormalTopic
✔️ testMultiHostUrlRetrySuccess ✔️ testGetPartitionedTopicDataTimeout ✔️ testGetPartitionedTopicMetaData
✔️ testSerializationAndDeserialization
✔️ createTopicDeleteTopicCreateTopic
✔️ testCheckSequenceId ✔️ testDeleteTopicWithMissingData ✔️ testTopicWithWildCardChar ✖️ testCrashBrokerWithoutCursorLedgerLeak ✖️ testSkipCorruptDataLedger
✔️ testCreateConsumerOnNotExistsTopic ✔️ testCreateProducerOnNotExistsTopic
✔️ testSingleTopicConsumerNoBatchFullName ✔️ testMultiTopicConsumerBatchShortName ✔️ testSingleTopicConsumerNoBatchShortName ✔️ testMultiTopicConsumerNoBatchShortName ✔️ testSingleTopicConsumerBatchShortName
✔️ testTopicAutoUpdatePartitions ✔️ testDifferentTopicsNameSubscribe ✔️ testGetLastMessageId ✔️ testConsumerUnackedRedelivery ✔️ testSubscriptionMustCompleteWhenOperationTimeoutOnMultipleTopics ✔️ testConsumerDistributionInFailoverSubscriptionWhenUpdatePartitions ✔️ multiTopicsInDifferentNameSpace ✔️ testDefaultBacklogTTL ✔️ testGetConsumersAndGetTopics ✔️ testSubscribeUnsubscribeSingleTopic ✔️ testResubscribeSameTopic ✔️ testSyncProducerAndConsumer ✔️ testPartitionsUpdatesForMultipleTopics ✔️ testTopicsNameSubscribeWithBuilderFail ✔️ testMultiTopicsMessageListener ✔️ testTopicNameValid ✔️ testAsyncConsumer
✔️ testCheckUnAcknowledgedMessageTimer ✔️ testExclusiveSingleAckedNormalTopic ✔️ testFailoverSingleAckedPartitionedTopic ✔️ testSharedSingleAckedPartitionedTopic ✔️ testAckTimeoutMinValue ✔️ testExclusiveCumulativeAckedNormalTopic ✔️ testSingleMessageBatch
✔️ zeroQueueSizeSharedSubscription ✔️ testPauseAndResume ✔️ testZeroQueueSizeMessageRedeliveryForAsyncReceive ✔️ zeroQueueSizeConsumerListener ✔️ zeroQueueSizeFailoverSubscription ✔️ validQueueSizeConfig ✔️ zeroQueueSizeNormalConsumer ✔️ zeroQueueSizeReceieveAsyncInCompatibility ✔️ InvalidQueueSizeConfig ✔️ testZeroQueueSizeMessageRedeliveryForListener ✔️ testZeroQueueSizeMessageRedelivery ✔️ zeroQueueSizePartitionedTopicInCompatibility ✔️ testFailedZeroQueueSizeBatchMessage ✔️ testPauseAndResumeWithUnloading
✔️ testGetProperties
✔️ testChecksumSendCommand
✔️ testCompressDecompress ✔️ testCompressDecompress ✔️ testCompressDecompress ✔️ testCompressDecompress ✔️ testCompressDecompress ✔️ testCompressDecompress
✔️ testCompressDecompress ✔️ testMultpileUsages ✔️ testMultpileUsages ✔️ testCompressDecompress ✔️ testMultpileUsages ✔️ testCompressDecompress ✔️ testMultpileUsages ✔️ testCompressDecompress ✔️ testDecompressFromSampleBuffer ✔️ testDecompressReadonlyByteBuf ✔️ testDecompressReadonlyByteBuf ✔️ testCodecProvider ✔️ testEmptyInput ✔️ testEmptyInput ✔️ testCompressDecompress ✔️ testCodecProvider ✔️ testDecompressFromSampleBuffer ✔️ testMultpileUsages ✔️ testCodecProvider ✔️ testEmptyInput ✔️ testDecompressReadonlyByteBuf ✔️ testCompressDecompress ✔️ testDecompressReadonlyByteBuf ✔️ testCompressDecompress ✔️ testCompressDecompress ✔️ testMultpileUsages ✔️ testEmptyInput ✔️ testDecompressReadonlyByteBuf ✔️ testDecompressFromSampleBuffer ✔️ testDecompressFromSampleBuffer ✔️ testDecompressFromSampleBuffer ✔️ testDecompressReadonlyByteBuf ✔️ testDecompressReadonlyByteBuf ✔️ testMultpileUsages ✔️ testCompressDecompress ✔️ testCodecProvider ✔️ testMultpileUsages ✔️ testCompressDecompress ✔️ testMultpileUsages ✔️ testDecompressReadonlyByteBuf ✔️ testEmptyInput ✔️ testCodecProvider ✔️ testDecompressReadonlyByteBuf ✔️ testDecompressReadonlyByteBuf ✔️ testMultpileUsages
✔️ testCrc32cHardware ✔️ testCrc32cDirectMemoryHardware ✔️ testCrc32c ✔️ testCrc32cSoftware ✔️ testCrc32cIncremental ✔️ testCrc32cIncrementalUsingProvider
✔️ testLoadReportSerialization ✔️ testUrlEncoder ✔️ serializeToJsonTest ✔️ withConstructor
✔️ testInvalidMetadata ✔️ testValidMetadata
✔️ testConstructor ✔️ testSplitBundleInTwo ✔️ testsplitBundles ✔️ testFindBundle ✔️ testSplitBundleByFixBoundary
✔️ testIncludes ✔️ testGetBundle ✔️ testCompareTo ✔️ testConstructor ✔️ testToString ✔️ testEquals
✔️ namespace ✔️ testNewScheme
✔️ testOptionalSettingPresent ✔️ testOptionalSettingEmpty ✔️ testInit ✔️ testInitFailure
✔️ testShortTopicName ✔️ topic ✔️ testTopicNameWithoutCluster ✔️ testDecodeEncode
✔️ testEmptyServiceUriString ✔️ testMultipleHostsSemiColon ✔️ testInvalidServiceUris ✔️ testMultipleHostsWithoutHttpPorts ✔️ testRootPath ✔️ testMultipleHostsMixedPorts ✔️ testMultipleHostsWithoutPulsarTlsPorts ✔️ testUserInfoWithMultipleHosts ✔️ testMultipleHostsComma ✔️ testMultipleHostsMixed ✔️ testUserInfo ✔️ testIpv6UriWithoutPulsarPort ✔️ testMultiIpv6Uri ✔️ testMultiIpv6UriWithoutPulsarPort ✔️ testEmptyPath ✔️ testNullServiceUriString ✔️ testNullServiceUriInstance ✔️ testMissingServiceName ✔️ testMultipleHostsWithoutHttpsPorts ✔️ testMultipleHostsWithoutPulsarPorts ✔️ testIpv6Uri
✔️ testAutoFailoverPolicyData
✔️ testAutoFailoverPolicyType
✔️ testInvalidTopicType ✔️ testNumPartitionsTooLow ✔️ testNumPartitionsNotSet ✔️ testValidOverrideNonPartitioned ✔️ testNumPartitionsOnNonPartitioned ✔️ testValidOverridePartitioned
✔️ testBacklogQuotaIdentity
✔️ simple
✔️ testConsumerStats
✔️ testDecodeFailed ✔️ testEncodeDecodeSuccessfully
✔️ testLocalPolices
✔️ testNamespaceIsolationData
✔️ testSerialization
✔️ testGcsConfiguration ✔️ mergeTest ✔️ compatibleWithConfigFileTest ✔️ testCreateByProperties ✔️ testS3Configuration ✔️ oldPoliciesCompatibleTest
✔️ testPartitionedTopicStats
✔️ testPersistencePolicies
✔️ testPersistentOfflineTopicStats
✔️ testPersistentTopicStatsAggregation ✔️ testPersistentTopicStats
✔️ propertyAdmin ✔️ policies ✔️ bundlesData ✔️ bundlesPolicies
✔️ testPublisherStats ✔️ testPublisherStatsAggregation
✔️ testReplicatorStatsAdd ✔️ testReplicatorStatsNull
✔️ testResourceQuotaDefault ✔️ testResourceQuotaEqual
✔️ testRetentionPolices
✔️ testAutoFailoverPolicyFactory
✔️ testMinAvailablePolicty
✔️ testBrokerAssignment ✔️ testGetNamespaceIsolationPolicyByName ✔️ testDeletePolicy ✔️ testSetPolicy ✔️ testJsonSerialization ✔️ testDefaultConstructor ✔️ testGetNamespaceIsolationPolicyByNamespace
✔️ testFindBrokers ✔️ testGetSecondaryBrokers ✔️ testShouldFailover ✔️ testGetPrimaryBrokers ✔️ testGetAvailablePrimaryBrokers ✔️ testConstructor ✔️ testIsPrimaryOrSecondaryBroker
✔️ testEncoder ✔️ testDoubleByteBuf
✔️ testSkipBrokerEntryMetadata ✔️ testPeekBrokerEntryMetadata ✔️ testParseBrokerEntryMetadata ✔️ testMetadataFromCommandSubscribe ✔️ testMetadataFromCommandProducer ✔️ testAddBrokerEntryMetadata ✔️ testByteBufComposite
✔️ testSnapshot ✔️ testTxnAbortMarker ✔️ testUpdate ✔️ testTxnCommitMarker ✔️ testSnapshotRequest ✔️ testSnapshotResponse
✔️ testChannelRead
✔️ testInvokeJVMInternals
✔️ testResetWords ✔️ testRecycle
✔️ testRecycle ✔️ testGenerateByBitSet
✔️ testRehashingWithDeletes ✔️ concurrentInsertionsAndReads ✔️ testRemove ✔️ testRehashing ✔️ simpleInsertions ✔️ testComputeIfAbsent ✔️ testConstructor ✔️ testPutIfAbsent ✔️ testIteration ✔️ testHashConflictWithDeletion ✔️ concurrentInsertions ✔️ stressConcurrentInsertionsAndReads ✔️ testNegativeUsedBucketCount
✔️ concurrentInsertionsAndReads ✔️ testEqualsObjects ✔️ testIfRemoval ✔️ testRehashing ✔️ testToString ✔️ testRemove ✔️ testItems ✔️ testRehashingWithDeletes ✔️ testHashConflictWithDeletion ✔️ testIteration ✔️ simpleInsertions ✔️ testRehashingRemoval ✔️ testRemoval ✔️ testConstructor ✔️ concurrentInsertions
✔️ testRemove ✔️ simpleInsertions ✔️ testPutIfAbsent ✔️ concurrentInsertions ✔️ testHashConflictWithDeletion ✔️ testRehashingWithDeletes ✔️ testComputeIfAbsent ✔️ testRehashing ✔️ testIteration ✔️ testEqualsKeys ✔️ concurrentInsertionsAndReads ✔️ testConstructor
✔️ concurrentInsertions ✔️ testRehashing ✔️ testRemoval ✔️ testEqualsObjects ✔️ testHashConflictWithDeletion ✔️ testConstructor ✔️ concurrentInsertionsAndReads ✔️ testIteration ✔️ simpleInsertions ✔️ testRehashingWithDeletes ✔️ testRemove
✔️ testAddForDifferentKey ✔️ testToString ✔️ testCacheFlagConflict ✔️ testDeleteWithLeastMost ✔️ testDeleteForDifferentKey ✔️ testLastRange ✔️ testAddCompareCompareWithGuava ✔️ testSpanWithGuava ✔️ testDeleteCompareWithGuava ✔️ testFirstRange ✔️ testAddForSameKey ✔️ testDeleteWithAtMost ✔️ testRangeContaining
✔️ concurrentInsertions ✔️ testIfRemoval ✔️ testRemoval ✔️ testRemove ✔️ testItems ✔️ testEqualsObjects ✔️ simpleInsertions ✔️ testIteration ✔️ testToString
✔️ testUpdateObject ✔️ testConversion
✔️ removeTest ✔️ growArray ✔️ pollTimeout ✔️ simple ✔️ pollTimeout2 ✔️ blockingTake
✔️ testItems ✔️ testRemove ✔️ testExpandQueue ✔️ testInsertAndRemove ✔️ testEqualsObjects ✔️ testExpandRemoval ✔️ testIteration ✔️ simpleInsertions ✔️ concurrentInsertions ✔️ testConstructor ✔️ testSetWithDuplicateInsert ✔️ testExpandWithDeletes ✔️ concurrentInsertionsAndReads ✔️ testRemoval ✔️ testIfRemoval
✔️ testQueue ✔️ testCheckForEmpty ✔️ testCompareWithSamePrefix
✔️ testMap
✔️ testFileNotModified ✔️ testFileModified ✔️ testFileModified ✔️ testFileNotModified ✔️ testFileModified ✔️ testFileNotModified
✔️ toCompletableFuture_shouldCompleteExceptionally_channelFutureCompletedAfter ✔️ toCompletableFuture_shouldCompleteSuccessfully_channelFutureCompletedAfter ✔️ toCompletableFuture_shouldCompleteSuccessfully_channelFutureCompletedBefore ✔️ toCompletableFuture_shouldCompleteExceptionally_channelFutureCompletedBefore ✔️ toCompletableFuture_shouldRequireNonNullArgument
✔️ testMultipleTryAcquire ✔️ testRateLimiterWithPermitUpdater ✔️ testTryAcquire ✔️ testTryAcquireNoPermits ✔️ testClose ✔️ testResetRate ✔️ testMultipleAcquire ✔️ testAcquire ✔️ testInvalidRenewTime ✔️ testRateLimiterWithFunction ✔️ testAcquireBlock
✔️ testCreateInstanceNoNoArgConstructor ✔️ testCreateInstanceConstructorThrowsException ✔️ testCreateInstanceAbstractClass ✔️ testCreateTypedInstanceUnassignableClass ✔️ testCreateInstanceClassNotFound ✔️ testCreateTypedInstanceConstructorThrowsException ✔️ testClassExists ✔️ testCreateTypedInstanceAbstractClass ✔️ testCreateTypedInstanceClassNotFound ✔️ testCreateTypedInstanceNoNoArgConstructor ✔️ testLoadClass ✔️ testClassInJarImplementsIface
✔️ testParseRelativeTime
✔️ testRedirectUrlWithServerStarted
✔️ testAuthorizationWithAnonymousUser ✔️ testAuthorization
✔️ testPulsarFunctionState ✔️ testMultipleAddress ✔️ testPulsarFunctionBKCleanup
✔️ testFunctionsCreation
✔️ testAuthorization
✔️ replayableProxyContentProviderTest
✔️ testAuthenticatedProxyAsNonAdmin
✔️ testFunctionWorkerRedirect
✔️ test
✔️ testTlsSyncProducerAndConsumer
✔️ testAuthentication
✔️ testInboundConnection
✔️ testSimpleProduceAndConsume
✔️ testForwardAuthData
✔️ testProxyToEndsInSlash ✔️ testStreaming ✔️ testLongPath ✔️ testLongPathInProxyTo ✔️ testPathEndsInSlash ✔️ testPathNotSpecified ✔️ testTryingToUseExistingPath ✔️ testMultipleRedirect ✔️ testSingleRedirect ✔️ testRedirectNotSpecified
✔️ testProducerFailed ✔️ testPartitions ✔️ testProducer
✔️ testPartitions ✔️ testProducerFailed ✔️ testProducer
✔️ testLookup
✔️ testRegexSubscription ✔️ testProducerConsumer ✔️ testProducer ✔️ testPartitions ✔️ testProtocolVersionAdvertisement
✔️ testIncorrectRoles
✔️ testChangeLogLevel ✔️ testConnectionsStats ✔️ testTopicStats
✔️ testPartitions ✔️ testRegexSubscription ✔️ testProtocolVersionAdvertisement ✔️ testGetSchema ✔️ testProducer ✔️ testProducerConsumer
✔️ testProducer ✔️ testPartitions
✔️ testServiceStartup
✔️ testProxyAuthorization
✔️ tlsCiphersAndProtocols ✔️ testTlsHostVerificationProxyToClient ✔️ tlsCiphersAndProtocols ✔️ testProxyAuthorization ✔️ tlsCiphersAndProtocols ✔️ testTlsHostVerificationProxyToBroker ✔️ tlsCiphersAndProtocols ✔️ tlsCiphersAndProtocols ✔️ tlsCiphersAndProtocols ✔️ testTlsHostVerificationProxyToBroker ✔️ tlsCiphersAndProtocols ✔️ testTlsHostVerificationProxyToClient ✔️ tlsCiphersAndProtocols
✔️ testDiscoveryService
✔️ testAuthWithRandoCert ✔️ testAuthenticatedProxyAsAdmin ✔️ testAuthenticatedProxyAsNonAdmin
✔️ testUnauthenticatedProxy ✔️ testVipStatus
✔️ testMainRunBookieNoConfig ✔️ testLoadConfigWithException ✔️ testMainWithNoArgument ✔️ testLoadBalancerConfig ✔️ testGlobalZooKeeperConfig ✔️ testMainRunBookieRecoveryNoConfig ✔️ testLoadConfig ✔️ testMainEnableRunBookieThroughBrokerConfig ✔️ testMainRunBookieAndAutoRecoveryNoConfig
✔️ testConsumerCompatibilityCheckCanReadLastTest ✔️ testConsumerWithNotCompatibilitySchema ✔️ testProducerSendWithOldSchemaAndConsumerCanRead ✔️ testConsumerCompatibilityCheckCanReadLastTest ✔️ testProducerSendWithOldSchemaAndConsumerCanRead ✔️ testSchemaComparison ✔️ testConsumerCompatibilityCheckCanReadLastTest ✔️ testConsumerCompatibilityReadAllCheckTest ✔️ testConsumerWithNotCompatibilitySchema ✔️ testIsAutoUpdateSchema ✔️ testProducerSendWithOldSchemaAndConsumerCanRead ✔️ testConsumerCompatibilityReadAllCheckTest ✔️ testIsAutoUpdateSchema ✔️ testProducerSendWithOldSchemaAndConsumerCanRead ✔️ testConsumerWithNotCompatibilitySchema ✔️ testIsAutoUpdateSchema ✔️ testProducerSendWithOldSchemaAndConsumerCanRead ✔️ testConsumerWithNotCompatibilitySchema ✔️ testProducerSendWithOldSchemaAndConsumerCanRead ✔️ testIsAutoUpdateSchema ✔️ testIsAutoUpdateSchema ✔️ testConsumerCompatibilityCheckCanReadLastTest ✔️ testIsAutoUpdateSchema
✔️ test
✔️ testIsUsingAvroSchemaParser ✔️ testBytesSchemaDeserialize ✔️ testMultiTopicSetSchemaProvider
✔️ testServiceException ✔️ testTopicInternalStats
✔️ shouldFailIfEnumParameterIsMissing ✔️ testEnumValuesProvider ✔️ testEnumValuesProvider ✔️ shouldDetermineEnumValuesFromMethod ✔️ shouldContainAllEnumValues ✔️ testEnumValuesProvider
✔️ shouldNotDoAnythingWhenThereIsBeforeAndAfterMethod ✖️ shouldNotDoAnythingWhenThereIsBeforeAndAfterMethod ✖️ shouldNotDoAnythingWhenThereIsBeforeAndAfterMethod ✖️ shouldNotDoAnythingWhenThereIsBeforeAndAfterMethod ✖️ shouldNotDoAnythingWhenThereIsBeforeAndAfterMethod
✖️ shouldCallSetupBeforeRetrying ✔️ shouldCallSetupBeforeRetrying ✖️ shouldCallSetupBeforeRetrying ✖️ shouldCallSetupBeforeRetrying ✖️ shouldCallSetupBeforeRetrying
✔️ shouldCallSetupOnce1 ✔️ shouldCallSetupOnce3 ✔️ shouldCallSetupOnce2
✔️ testHelp ✔️ testThreadDump
✔️ testBooleanFormat ✔️ testDoubleFormat ✔️ testLongFormat ✔️ testString
✔️ testLists ✔️ testNamedObjects ✔️ testNestedObjects ✔️ testNamedLists ✔️ testPairs ✔️ testObjects
✔️ unauthenticatedSocketTest ✔️ authenticatedSocketTest ✔️ statsTest ✔️ anonymousSocketTest
✔️ test
✔️ configTest ✔️ configTest
✔️ socketTest
✔️ socketTest
✔️ anonymousSocketTest ✔️ authenticatedSocketTest ✔️ statsTest ✔️ unauthenticatedSocketTest