登录注册

Jar文件详情内容

aeron-all-1.24.0-sources.jar

所在目录：/io/aeron/aeron-all/1.24.0 查看aeron-all所有版本文件

组织ID:	io.aeron
项目ID:	aeron-all
版本:	1.24.0
最后修改时间:	2019-11-28 15:53:37
包类型:	java-source (源码)
大小:	988.30KB

Maven引入代码:	`<dependency> <groupId>io.aeron</groupId> <artifactId>aeron-all</artifactId> <version>1.24.0</version> <classifier>sources</classifier> <type>java-source</type> </dependency>`
Gradle引入代码:	`io.aeron:aeron-all:1.24.0`
下载Jar包:	aeron-all-1.24.0-sources.jar
Jar包内容:	展开复制 META-INF/MANIFEST.MF io/aeron/ErrorCode.java io/aeron/LogBuffersFactory.java io/aeron/ImageFragmentAssembler.java io/aeron/Image.java io/aeron/ReservedValueSupplier.java io/aeron/Publication.java io/aeron/security/CredentialsSupplier.java io/aeron/security/AuthenticatorSupplier.java io/aeron/security/DefaultAuthenticatorSupplier.java io/aeron/security/NullCredentialsSupplier.java io/aeron/security/SessionProxy.java io/aeron/security/Authenticator.java io/aeron/security/AuthenticationException.java io/aeron/security/package-info.java io/aeron/AvailableCounterHandler.java io/aeron/ChannelUri.java io/aeron/BufferBuilder.java io/aeron/protocol/SetupFlyweight.java io/aeron/protocol/NakFlyweight.java io/aeron/protocol/DataHeaderFlyweight.java io/aeron/protocol/HeaderFlyweight.java io/aeron/protocol/RttMeasurementFlyweight.java io/aeron/protocol/StatusMessageFlyweight.java io/aeron/protocol/package-info.java io/aeron/status/ChannelEndpointStatus.java io/aeron/status/HeartbeatTimestamp.java io/aeron/status/ReadableCounter.java io/aeron/status/package-info.java io/aeron/BufferBuilderUtil.java io/aeron/exceptions/ConcurrentConcludeException.java io/aeron/exceptions/ConductorServiceTimeoutException.java io/aeron/exceptions/ConfigurationException.java io/aeron/exceptions/ControlProtocolException.java io/aeron/exceptions/RegistrationException.java io/aeron/exceptions/AeronException.java io/aeron/exceptions/TimeoutException.java io/aeron/exceptions/ClientTimeoutException.java io/aeron/exceptions/ChannelEndpointException.java io/aeron/exceptions/package-info.java io/aeron/exceptions/DriverTimeoutException.java io/aeron/ExclusivePublication.java io/aeron/ClientConductor.java io/aeron/LogBuffers.java io/aeron/Counter.java io/aeron/DriverEventsAdapter.java io/aeron/ConcurrentPublication.java io/aeron/logbuffer/TermAppender.java io/aeron/logbuffer/FragmentHandler.java io/aeron/logbuffer/TermScanner.java io/aeron/logbuffer/ControlledFragmentHandler.java io/aeron/logbuffer/ExclusiveTermAppender.java io/aeron/logbuffer/TermGapFiller.java io/aeron/logbuffer/TermRebuilder.java io/aeron/logbuffer/TermGapScanner.java io/aeron/logbuffer/BufferClaim.java io/aeron/logbuffer/TermReader.java io/aeron/logbuffer/TermUnblocker.java io/aeron/logbuffer/RawBlockHandler.java io/aeron/logbuffer/BlockHandler.java io/aeron/logbuffer/FrameDescriptor.java io/aeron/logbuffer/LogBufferUnblocker.java io/aeron/logbuffer/TermBlockScanner.java io/aeron/logbuffer/Header.java io/aeron/logbuffer/package-info.java io/aeron/logbuffer/HeaderWriter.java io/aeron/logbuffer/LogBufferDescriptor.java io/aeron/CncFileDescriptor.java io/aeron/CommonContext.java io/aeron/DriverProxy.java io/aeron/MappedLogBuffersFactory.java io/aeron/UnavailableCounterHandler.java io/aeron/command/ImageBuffersReadyFlyweight.java io/aeron/command/ControlProtocolEvents.java io/aeron/command/CounterUpdateFlyweight.java io/aeron/command/CounterMessageFlyweight.java io/aeron/command/TerminateDriverFlyweight.java io/aeron/command/ErrorResponseFlyweight.java io/aeron/command/CorrelatedMessageFlyweight.java io/aeron/command/DestinationMessageFlyweight.java io/aeron/command/PublicationBuffersReadyFlyweight.java io/aeron/command/ClientTimeoutFlyweight.java io/aeron/command/RemoveMessageFlyweight.java io/aeron/command/SubscriptionMessageFlyweight.java io/aeron/command/PublicationMessageFlyweight.java io/aeron/command/ImageMessageFlyweight.java io/aeron/command/SubscriptionReadyFlyweight.java io/aeron/command/package-info.java io/aeron/command/OperationSucceededFlyweight.java io/aeron/DirectBufferVector.java io/aeron/UnavailableImageHandler.java io/aeron/FragmentAssembler.java io/aeron/Subscription.java io/aeron/ImageControlledFragmentAssembler.java io/aeron/Aeron.java io/aeron/package-info.java io/aeron/AvailableImageHandler.java io/aeron/ChannelUriStringBuilder.java io/aeron/ControlledFragmentAssembler.java io/aeron/DriverEventsListener.java debug-loss-10.properties low-latency.properties aeron-throughput.properties high-stream-count.properties aeron-ipc.properties io/aeron/driver/DefaultAllowTerminationValidator.java io/aeron/driver/CongestionControlSupplier.java io/aeron/driver/SubscriberPosition.java io/aeron/driver/StaticWindowCongestionControl.java io/aeron/driver/IpcPublication.java io/aeron/driver/MinMulticastFlowControl.java io/aeron/driver/DefaultSendChannelEndpointSupplier.java io/aeron/driver/FeedbackDelayGenerator.java io/aeron/driver/DriverConductor.java io/aeron/driver/OptimalMulticastDelayGenerator.java io/aeron/driver/Receiver.java io/aeron/driver/AeronClient.java io/aeron/driver/ThreadingMode.java io/aeron/driver/RetransmitHandler.java io/aeron/driver/LossDetector.java io/aeron/driver/SenderProxy.java io/aeron/driver/ext/CubicCongestionControl.java io/aeron/driver/ext/DebugSendChannelEndpoint.java io/aeron/driver/ext/CubicCongestionControlConfiguration.java io/aeron/driver/ext/RandomLossGenerator.java io/aeron/driver/ext/LossGenerator.java io/aeron/driver/ext/DebugReceiveChannelEndpointSupplier.java io/aeron/driver/ext/DebugSendChannelEndpointSupplier.java io/aeron/driver/ext/DebugChannelEndpointConfiguration.java io/aeron/driver/ext/DebugReceiveChannelEndpoint.java io/aeron/driver/ext/package-info.java io/aeron/driver/ext/CubicCongestionControlSupplier.java io/aeron/driver/DriverManagedResource.java io/aeron/driver/DefaultReceiveChannelEndpointSupplier.java io/aeron/driver/Configuration.java io/aeron/driver/Subscribable.java io/aeron/driver/DefaultCongestionControlSupplier.java io/aeron/driver/PreferredMulticastFlowControl.java io/aeron/driver/LossHandler.java io/aeron/driver/RetransmitSender.java io/aeron/driver/NetworkPublicationThreadLocals.java io/aeron/driver/DefaultMulticastFlowControlSupplier.java io/aeron/driver/FlowControl.java io/aeron/driver/FlowControlSupplier.java io/aeron/driver/status/SenderBpe.java io/aeron/driver/status/PerImageIndicator.java io/aeron/driver/status/PublisherLimit.java io/aeron/driver/status/SystemCounters.java io/aeron/driver/status/PublisherPos.java io/aeron/driver/status/SendChannelStatus.java io/aeron/driver/status/StatusUtil.java io/aeron/driver/status/SystemCounterDescriptor.java io/aeron/driver/status/SenderLimit.java io/aeron/driver/status/SenderPos.java io/aeron/driver/status/ClientHeartbeatTimestamp.java io/aeron/driver/status/ReceiveChannelStatus.java io/aeron/driver/status/ReceiverHwm.java io/aeron/driver/status/SubscriberPos.java io/aeron/driver/status/ReceiverPos.java io/aeron/driver/status/StreamCounter.java io/aeron/driver/status/package-info.java io/aeron/driver/TerminationValidator.java io/aeron/driver/exceptions/InvalidChannelException.java io/aeron/driver/exceptions/package-info.java io/aeron/driver/exceptions/UnknownSubscriptionException.java io/aeron/driver/exceptions/ActiveDriverException.java io/aeron/driver/PublicationParams.java io/aeron/driver/DataPacketDispatcher.java io/aeron/driver/MaxMulticastFlowControlSupplier.java io/aeron/driver/DefaultUnicastFlowControlSupplier.java io/aeron/driver/Sender.java io/aeron/driver/CongestionControl.java io/aeron/driver/MediaDriver.java io/aeron/driver/SubscriptionParams.java io/aeron/driver/SessionKey.java io/aeron/driver/StaticDelayGenerator.java io/aeron/driver/MinMulticastFlowControlSupplier.java io/aeron/driver/UnicastFlowControl.java io/aeron/driver/ReceiverProxy.java io/aeron/driver/PreferredMulticastFlowControlSupplier.java io/aeron/driver/CounterLink.java io/aeron/driver/DriverConductorProxy.java io/aeron/driver/SendChannelEndpointSupplier.java io/aeron/driver/PublicationLink.java io/aeron/driver/DefaultDenyTerminationValidator.java io/aeron/driver/SubscriptionLink.java io/aeron/driver/NetworkPublication.java io/aeron/driver/ReceiveChannelEndpointSupplier.java io/aeron/driver/ClientProxy.java io/aeron/driver/MaxMulticastFlowControl.java io/aeron/driver/package-info.java io/aeron/driver/PublicationImage.java io/aeron/driver/ClientCommandAdapter.java io/aeron/driver/reports/LossReportReader.java io/aeron/driver/reports/LossReportUtil.java io/aeron/driver/reports/LossReport.java io/aeron/driver/reports/package-info.java io/aeron/driver/buffer/LogFactory.java io/aeron/driver/buffer/MappedRawLog.java io/aeron/driver/buffer/RawLog.java io/aeron/driver/buffer/FileStoreLogFactory.java io/aeron/driver/buffer/package-info.java io/aeron/driver/media/InterfaceSearchAddress.java io/aeron/driver/media/ReceiveChannelEndpoint.java io/aeron/driver/media/NetworkUtil.java io/aeron/driver/media/MultiDestination.java io/aeron/driver/media/ControlTransportPoller.java io/aeron/driver/media/MultiRcvDestination.java io/aeron/driver/media/ImageConnection.java io/aeron/driver/media/ReceiveDestinationUdpTransport.java io/aeron/driver/media/UdpChannelTransport.java io/aeron/driver/media/SendChannelEndpoint.java io/aeron/driver/media/NetworkInterfaceShim.java io/aeron/driver/media/UdpChannel.java io/aeron/driver/media/SocketAddressParser.java io/aeron/driver/media/ReceiveChannelEndpointThreadLocals.java io/aeron/driver/media/DataTransportPoller.java io/aeron/driver/media/package-info.java io/aeron/driver/media/UdpTransportPoller.java io/aeron/driver/PendingSetupMessageFromSource.java aeron-archive-codecs.xml fpl/sbe.xsd aeron-archive-mark-codecs.xml io/aeron/archive/ArchiveMigrationPlanner.java io/aeron/archive/ControlSessionProxy.java io/aeron/archive/ListRecordingsSession.java io/aeron/archive/SessionWorker.java io/aeron/archive/ControlSessionDemuxer.java io/aeron/archive/ArchiveMarkFile.java io/aeron/archive/ListRecordingSubscriptionsSession.java io/aeron/archive/Catalog.java io/aeron/archive/ArchiveConductor.java io/aeron/archive/ArchiveMigration_0_1.java io/aeron/archive/ControlSession.java io/aeron/archive/MigrationUtils.java io/aeron/archive/ArchiveThreadingMode.java io/aeron/archive/RecordingSummary.java io/aeron/archive/SimpleFragmentHandler.java io/aeron/archive/ArchiveMigration_1_2.java io/aeron/archive/RecordingSession.java io/aeron/archive/status/RecordingPos.java io/aeron/archive/status/package-info.java io/aeron/archive/CatalogTool.java io/aeron/archive/ControlRequestDecoders.java io/aeron/archive/ReplaySession.java io/aeron/archive/ArchiveMigrationStep.java io/aeron/archive/ArchivingMediaDriver.java io/aeron/archive/CatalogView.java io/aeron/archive/ListRecordingsForUriSession.java io/aeron/archive/RecordingWriter.java io/aeron/archive/DedicatedModeArchiveConductor.java io/aeron/archive/Session.java io/aeron/archive/SharedModeArchiveConductor.java io/aeron/archive/AbstractListRecordingsSession.java io/aeron/archive/client/RecordingDescriptorPoller.java io/aeron/archive/client/RecordingEventsListener.java io/aeron/archive/client/ArchiveException.java io/aeron/archive/client/RecordingDescriptorConsumer.java io/aeron/archive/client/AeronArchive.java io/aeron/archive/client/RecordingSubscriptionDescriptorConsumer.java io/aeron/archive/client/ControlEventListener.java io/aeron/archive/client/RecordingSignalConsumer.java io/aeron/archive/client/ControlResponsePoller.java io/aeron/archive/client/RecordingEventsPoller.java io/aeron/archive/client/ArchiveProxy.java io/aeron/archive/client/RecordingSignalAdapter.java io/aeron/archive/client/ControlResponseAdapter.java io/aeron/archive/client/ReplayMerge.java io/aeron/archive/client/ControlResponseListener.java io/aeron/archive/client/RecordingEventsAdapter.java io/aeron/archive/client/package-info.java io/aeron/archive/client/RecordingSubscriptionDescriptorPoller.java io/aeron/archive/RecordingReader.java io/aeron/archive/ReplicationSession.java io/aeron/archive/ControlResponseProxy.java io/aeron/archive/package-info.java io/aeron/archive/Archive.java io/aeron/archive/RecordingEventsProxy.java io/aeron/archive/codecs/ChallengeEncoder.java io/aeron/archive/codecs/StopRecordingSubscriptionRequestEncoder.java io/aeron/archive/codecs/AttachSegmentsRequestDecoder.java io/aeron/archive/codecs/RecordingSignalEventDecoder.java io/aeron/archive/codecs/DeleteDetachedSegmentsRequestEncoder.java io/aeron/archive/codecs/ChallengeResponseEncoder.java io/aeron/archive/codecs/SourceLocation.java io/aeron/archive/codecs/BoundedReplayRequestDecoder.java io/aeron/archive/codecs/ListRecordingRequestDecoder.java io/aeron/archive/codecs/VarAsciiEncodingDecoder.java io/aeron/archive/codecs/RecordingSubscriptionDescriptorEncoder.java io/aeron/archive/codecs/RecordingDescriptorEncoder.java io/aeron/archive/codecs/KeepAliveRequestEncoder.java io/aeron/archive/codecs/MessageHeaderDecoder.java io/aeron/archive/codecs/RecordingDescriptorHeaderDecoder.java io/aeron/archive/codecs/ReplayRequestDecoder.java io/aeron/archive/codecs/StopReplayRequestEncoder.java io/aeron/archive/codecs/DetachSegmentsRequestDecoder.java io/aeron/archive/codecs/VarDataEncodingDecoder.java io/aeron/archive/codecs/AuthConnectRequestEncoder.java io/aeron/archive/codecs/PurgeSegmentsRequestEncoder.java io/aeron/archive/codecs/StopAllReplaysRequestDecoder.java io/aeron/archive/codecs/ControlResponseDecoder.java io/aeron/archive/codecs/FindLastMatchingRecordingRequestEncoder.java io/aeron/archive/codecs/StopRecordingRequestEncoder.java io/aeron/archive/codecs/StartRecordingRequestDecoder.java io/aeron/archive/codecs/MigrateSegmentsRequestEncoder.java io/aeron/archive/codecs/StopPositionRequestDecoder.java io/aeron/archive/codecs/RecordingProgressEncoder.java io/aeron/archive/codecs/RecordingSignal.java io/aeron/archive/codecs/mark/MarkFileHeaderEncoder.java io/aeron/archive/codecs/mark/VarAsciiEncodingDecoder.java io/aeron/archive/codecs/mark/MessageHeaderDecoder.java io/aeron/archive/codecs/mark/MarkFileHeaderDecoder.java io/aeron/archive/codecs/mark/MessageHeaderEncoder.java io/aeron/archive/codecs/mark/VarAsciiEncodingEncoder.java io/aeron/archive/codecs/mark/MetaAttribute.java io/aeron/archive/codecs/mark/package-info.java io/aeron/archive/codecs/StartPositionRequestEncoder.java io/aeron/archive/codecs/ConnectRequestDecoder.java io/aeron/archive/codecs/RecordingStartedDecoder.java io/aeron/archive/codecs/RecordingStoppedDecoder.java io/aeron/archive/codecs/ExtendRecordingRequestDecoder.java io/aeron/archive/codecs/TruncateRecordingRequestEncoder.java io/aeron/archive/codecs/ReplicateRequestEncoder.java io/aeron/archive/codecs/StopReplicationRequestDecoder.java io/aeron/archive/codecs/ListRecordingSubscriptionsRequestDecoder.java io/aeron/archive/codecs/CloseSessionRequestDecoder.java io/aeron/archive/codecs/ListRecordingsRequestDecoder.java io/aeron/archive/codecs/RecordingPositionRequestDecoder.java io/aeron/archive/codecs/ListRecordingsForUriRequestDecoder.java io/aeron/archive/codecs/CatalogHeaderEncoder.java io/aeron/archive/codecs/BoundedReplayRequestEncoder.java io/aeron/archive/codecs/ControlResponseCode.java io/aeron/archive/codecs/DeleteDetachedSegmentsRequestDecoder.java io/aeron/archive/codecs/ChallengeResponseDecoder.java io/aeron/archive/codecs/RecordingSignalEventEncoder.java io/aeron/archive/codecs/AttachSegmentsRequestEncoder.java io/aeron/archive/codecs/StopRecordingSubscriptionRequestDecoder.java io/aeron/archive/codecs/ChallengeDecoder.java io/aeron/archive/codecs/StopReplayRequestDecoder.java io/aeron/archive/codecs/ReplayRequestEncoder.java io/aeron/archive/codecs/RecordingDescriptorHeaderEncoder.java io/aeron/archive/codecs/MessageHeaderEncoder.java io/aeron/archive/codecs/KeepAliveRequestDecoder.java io/aeron/archive/codecs/RecordingDescriptorDecoder.java io/aeron/archive/codecs/RecordingSubscriptionDescriptorDecoder.java io/aeron/archive/codecs/VarAsciiEncodingEncoder.java io/aeron/archive/codecs/ListRecordingRequestEncoder.java io/aeron/archive/codecs/MigrateSegmentsRequestDecoder.java io/aeron/archive/codecs/MetaAttribute.java io/aeron/archive/codecs/StartRecordingRequestEncoder.java io/aeron/archive/codecs/StopRecordingRequestDecoder.java io/aeron/archive/codecs/FindLastMatchingRecordingRequestDecoder.java io/aeron/archive/codecs/ControlResponseEncoder.java io/aeron/archive/codecs/StopAllReplaysRequestEncoder.java io/aeron/archive/codecs/BooleanType.java io/aeron/archive/codecs/PurgeSegmentsRequestDecoder.java io/aeron/archive/codecs/AuthConnectRequestDecoder.java io/aeron/archive/codecs/VarDataEncodingEncoder.java io/aeron/archive/codecs/DetachSegmentsRequestEncoder.java io/aeron/archive/codecs/CatalogHeaderDecoder.java io/aeron/archive/codecs/ListRecordingsForUriRequestEncoder.java io/aeron/archive/codecs/RecordingPositionRequestEncoder.java io/aeron/archive/codecs/ListRecordingsRequestEncoder.java io/aeron/archive/codecs/CloseSessionRequestEncoder.java io/aeron/archive/codecs/ListRecordingSubscriptionsRequestEncoder.java io/aeron/archive/codecs/StopReplicationRequestEncoder.java io/aeron/archive/codecs/package-info.java io/aeron/archive/codecs/ReplicateRequestDecoder.java io/aeron/archive/codecs/TruncateRecordingRequestDecoder.java io/aeron/archive/codecs/ExtendRecordingRequestEncoder.java io/aeron/archive/codecs/RecordingStoppedEncoder.java io/aeron/archive/codecs/RecordingStartedEncoder.java io/aeron/archive/codecs/ConnectRequestEncoder.java io/aeron/archive/codecs/StartPositionRequestDecoder.java io/aeron/archive/codecs/RecordingProgressDecoder.java io/aeron/archive/codecs/StopPositionRequestEncoder.java fpl/sbe.xsd aeron-cluster-codecs.xml aeron-cluster-mark-codecs.xml io/aeron/cluster/NanosecondClusterClock.java io/aeron/cluster/ConsensusModuleSnapshotLoader.java io/aeron/cluster/LogReplay.java io/aeron/cluster/RecordingLog.java io/aeron/cluster/ConsensusModule.java io/aeron/cluster/ClusterSessionProxy.java io/aeron/cluster/MemberStatusAdapter.java io/aeron/cluster/ConsensusModuleSnapshotTaker.java io/aeron/cluster/MemberServiceAdapter.java io/aeron/cluster/ConsensusModuleAdapter.java io/aeron/cluster/ServiceAck.java io/aeron/cluster/MemberStatusPublisher.java io/aeron/cluster/TimerService.java io/aeron/cluster/ConsensusModuleAgent.java io/aeron/cluster/ClusterControl.java io/aeron/cluster/ClusteredMediaDriver.java io/aeron/cluster/MillisecondClusterClock.java io/aeron/cluster/ClusterSession.java io/aeron/cluster/EgressPublisher.java io/aeron/cluster/ClusterMember.java io/aeron/cluster/RecordingExtent.java io/aeron/cluster/ClusterTermination.java io/aeron/cluster/ClusterBackupAgent.java io/aeron/cluster/LogAdapter.java io/aeron/cluster/LogPublisher.java io/aeron/cluster/service/RecoveryState.java io/aeron/cluster/service/ActiveLogEvent.java io/aeron/cluster/service/ClusteredServiceAgent.java io/aeron/cluster/service/ClusteredServiceContainer.java io/aeron/cluster/service/ServiceSnapshotLoader.java io/aeron/cluster/service/SnapshotTaker.java io/aeron/cluster/service/ServiceSnapshotTaker.java io/aeron/cluster/service/Cluster.java io/aeron/cluster/service/ClientSession.java io/aeron/cluster/service/ConsensusModuleProxy.java io/aeron/cluster/service/ClusterNodeRole.java io/aeron/cluster/service/ClusteredService.java io/aeron/cluster/service/ClusterMarkFile.java io/aeron/cluster/service/ServiceAdapter.java io/aeron/cluster/service/BoundedLogAdapter.java io/aeron/cluster/service/package-info.java io/aeron/cluster/service/CommitPos.java io/aeron/cluster/ClusterBackup.java io/aeron/cluster/Election.java io/aeron/cluster/IngressAdapter.java io/aeron/cluster/client/EgressPoller.java io/aeron/cluster/client/ClusterClock.java io/aeron/cluster/client/IngressSessionDecorator.java io/aeron/cluster/client/ClusterException.java io/aeron/cluster/client/ControlledEgressListener.java io/aeron/cluster/client/AeronCluster.java io/aeron/cluster/client/EgressListener.java io/aeron/cluster/client/EgressAdapter.java io/aeron/cluster/client/package-info.java io/aeron/cluster/ServiceProxy.java io/aeron/cluster/DynamicJoin.java io/aeron/cluster/ClusterTool.java io/aeron/cluster/ClusterBackupMediaDriver.java io/aeron/cluster/package-info.java io/aeron/cluster/ClusterBackupEventsListener.java io/aeron/cluster/codecs/GroupSizeEncodingDecoder.java io/aeron/cluster/codecs/TerminationPositionEncoder.java io/aeron/cluster/codecs/ClientSessionDecoder.java io/aeron/cluster/codecs/JoinClusterDecoder.java io/aeron/cluster/codecs/ChallengeEncoder.java io/aeron/cluster/codecs/ScheduleTimerDecoder.java io/aeron/cluster/codecs/ClusterMembersExtendedResponseDecoder.java io/aeron/cluster/codecs/NewLeadershipTermEventDecoder.java io/aeron/cluster/codecs/RemoveMemberEncoder.java io/aeron/cluster/codecs/TerminationAckDecoder.java io/aeron/cluster/codecs/AddPassiveMemberEncoder.java io/aeron/cluster/codecs/CancelTimerEncoder.java io/aeron/cluster/codecs/ClusterMembersQueryEncoder.java io/aeron/cluster/codecs/ChallengeResponseEncoder.java io/aeron/cluster/codecs/ChangeType.java io/aeron/cluster/codecs/ServiceTerminationPositionDecoder.java io/aeron/cluster/codecs/CatchupPositionEncoder.java io/aeron/cluster/codecs/SnapshotMarkerEncoder.java io/aeron/cluster/codecs/RequestVoteDecoder.java io/aeron/cluster/codecs/MembershipChangeEventEncoder.java io/aeron/cluster/codecs/CloseSessionDecoder.java #内容未全部加载，请点击展开加载全部代码(NowJava.com)
依赖Jar:	无