MCPcopy Create free account

hub / github.com/coffeewar/enode-master / types & classes

Types & classes339 in github.com/coffeewar/enode-master

⨍ Functions 1,671◇ Types & classes 339
ClassAbstractAsyncDenormalizer
Created by junbo_xu on 2016/9/22.
enode/src/main/java/com/qianzhui/enode/infrastructure/impl/AbstractAsyncDenormalizer.java:19
ClassAbstractConsumer
Created by junbo_xu on 2016/4/21.
enode/src/main/java/com/qianzhui/enode/rocketmq/client/AbstractConsumer.java:14
ClassAbstractContainer
Created by xujunbo on 17-9-29.
enode/src/main/java/com/qianzhui/enode/common/container/AbstractContainer.java:10
ClassAbstractDenormalizer
Created by junbo_xu on 2016/6/6.
enode/src/main/java/com/qianzhui/enode/infrastructure/impl/AbstractDenormalizer.java:14
ClassAbstractHandlerProvider
Created by junbo_xu on 2016/3/21.
enode/src/main/java/com/qianzhui/enode/infrastructure/impl/AbstractHandlerProvider.java:19
ClassAbstractProducer
Created by junbo_xu on 2016/4/20.
enode/src/main/java/com/qianzhui/enode/rocketmq/client/AbstractProducer.java:23
ClassAbstractQueryRunnerExecuter
enode/src/main/java/com/qianzhui/enode/infrastructure/impl/AbstractAsyncDenormalizer.java:115
ClassAbstractRPCHook
Created by xujunbo on 17-9-22.
enode/src/main/java/com/qianzhui/enode/rocketmq/client/ons/AbstractRPCHook.java:18
ClassAbstractSequenceProcessingMessageHandler
Created by junbo_xu on 2016/4/5.
enode/src/main/java/com/qianzhui/enode/infrastructure/impl/AbstractSequenceProcessingMessageHandler.java:15
ClassAbstractTaskExecutionContext
enode/src/main/java/com/qianzhui/enode/common/io/IOHelper.java:137
ClassAbstractTopicProvider
Created by junbo_xu on 2016/3/29.
enode/src/main/java/com/qianzhui/enode/rocketmq/AbstractTopicProvider.java:10
InterfaceAction
Created by junbo_xu on 2016/3/3.
enode/src/main/java/com/qianzhui/enode/common/function/Action.java:12
InterfaceAction1
Created by junbo_xu on 2016/3/3.
enode/src/main/java/com/qianzhui/enode/common/function/Action1.java:6
InterfaceAction2
Created by junbo_xu on 2016/3/3.
enode/src/main/java/com/qianzhui/enode/common/function/Action2.java:6
InterfaceAction3
Created by junbo_xu on 2016/3/3.
enode/src/main/java/com/qianzhui/enode/common/function/Action3.java:6
InterfaceAction4
Created by junbo_xu on 2016/3/3.
enode/src/main/java/com/qianzhui/enode/common/function/Action4.java:6
ClassAggregateCacheInfo
Created by junbo_xu on 2016/4/23.
enode/src/main/java/com/qianzhui/enode/domain/AggregateCacheInfo.java:6
ClassAggregateInfo
enode/src/main/java/com/qianzhui/enode/eventing/impl/InMemoryEventStore.java:169
ClassAggregateRepositoryProxy
Created by junbo_xu on 2016/4/1.
enode/src/main/java/com/qianzhui/enode/domain/impl/AggregateRepositoryProxy.java:10
ClassAggregateRoot
Created by junbo_xu on 2016/2/24.
enode/src/main/java/com/qianzhui/enode/domain/AggregateRoot.java:16
ClassAggregateRootAlreadyExistException
Created by junbo_xu on 2016/3/17.
enode/src/main/java/com/qianzhui/enode/commanding/AggregateRootAlreadyExistException.java:6
ClassApplicationDataMessage
Created by junbo_xu on 2016/6/3.
enode/src/main/java/com/qianzhui/enode/rocketmq/applicationmessage/ApplicationDataMessage.java:6
ClassApplicationMessage
Created by junbo_xu on 2016/4/6.
enode/src/main/java/com/qianzhui/enode/infrastructure/ApplicationMessage.java:6
ClassApplicationMessageConsumer
Created by junbo_xu on 2016/4/6.
enode/src/main/java/com/qianzhui/enode/rocketmq/applicationmessage/ApplicationMessageConsumer.java:20
ClassApplicationMessagePublisher
Created by junbo_xu on 2016/4/6.
enode/src/main/java/com/qianzhui/enode/rocketmq/applicationmessage/ApplicationMessagePublisher.java:23
ClassArraySegment
Created by junbo_xu on 2016/3/4.
enode/src/main/java/com/qianzhui/enode/common/extensions/ArraySegment.java:8
ClassAsyncAppender
Created by alvin on 16-3-7. 数据编码和发送模块
enode/src/main/java/com/qianzhui/enode/rocketmq/trace/core/dispatch/AsyncAppender.java:7
ClassAsyncAppenderRequest
enode/src/main/java/com/qianzhui/enode/rocketmq/trace/core/dispatch/impl/AsyncArrayDispatcher.java:186
ClassAsyncArrayDispatcher
Created by alvin on 16-8-25.
enode/src/main/java/com/qianzhui/enode/rocketmq/trace/core/dispatch/impl/AsyncArrayDispatcher.java:30
InterfaceAsyncDispatcher
异步传输数据模块
enode/src/main/java/com/qianzhui/enode/rocketmq/trace/core/dispatch/AsyncDispatcher.java:8
ClassAsyncRunnable
enode/src/main/java/com/qianzhui/enode/rocketmq/trace/core/dispatch/impl/AsyncTraceDispatcher.java:173
ClassAsyncRunnable
enode/src/main/java/com/qianzhui/enode/rocketmq/trace/core/dispatch/impl/AsyncArrayDispatcher.java:156
ClassAsyncTaskExecutionContext
enode/src/main/java/com/qianzhui/enode/common/io/IOHelper.java:105
ClassAsyncTaskResult
Created by junbo_xu on 2016/2/27.
enode/src/main/java/com/qianzhui/enode/common/io/AsyncTaskResult.java:6
EnumAsyncTaskStatus
Created by junbo_xu on 2016/2/27.
enode/src/main/java/com/qianzhui/enode/common/io/AsyncTaskStatus.java:6
ClassAsyncTraceAppender
Created by alvin on 16-3-7.
enode/src/main/java/com/qianzhui/enode/rocketmq/trace/core/dispatch/impl/AsyncTraceAppender.java:24
ClassAsyncTraceDispatcher
异步提交消息轨迹等数据
enode/src/main/java/com/qianzhui/enode/rocketmq/trace/core/dispatch/impl/AsyncTraceDispatcher.java:21
ClassAuthUtil
Created by xujunbo on 17-9-22.
enode/src/main/java/com/qianzhui/enode/rocketmq/client/ons/AuthUtil.java:13
ClassAuthenticationException
Created by xujunbo on 17-9-22.
enode/src/main/java/com/qianzhui/enode/rocketmq/client/ons/AuthenticationException.java:6
ClassBatchAppendFuture
enode/src/main/java/com/qianzhui/enode/eventing/impl/InMemoryEventStore.java:76
ClassBatchExecuter
enode/src/main/java/com/qianzhui/enode/infrastructure/impl/AbstractAsyncDenormalizer.java:172
ClassBitConverter
Created by junbo_xu on 2016/3/10.
enode/src/main/java/com/qianzhui/enode/common/utilities/BitConverter.java:8
ClassByteArraySegment
Created by junbo_xu on 2016/3/5.
enode/src/main/java/com/qianzhui/enode/common/extensions/ByteArraySegment.java:8
ClassChangeNoteTitleCommand
Created by junbo_xu on 2016/4/15.
samples/notesample/commands/src/main/java/com/qianzhui/enodesamples/notesample/commands/ChangeNoteTitleCommand.java:8
ClassChangeNoteTitleCommandHandler
Created by junbo_xu on 2016/4/15.
samples/notesample/commandhandlers/src/main/java/com/qianzhui/enodesamples/notesample/commandhandlers/ChangeNoteTitleCommandHandler.java:11
InterfaceChannelEventListener
enode-remoting/src/main/java/com/qianzhui/enode/remoting/ChannelEventListener.java:21
ClassChannelWrapper
enode-remoting/src/main/java/com/qianzhui/enode/remoting/netty/NettyRemotingClient.java:390
ClassClasspathPropertiesDatasourceFactory
Created by junbo_xu on 2016/6/6.
enode/src/main/java/com/qianzhui/enode/common/utilities/ClasspathPropertiesDatasourceFactory.java:12
ClassClientRPCHook
@auther lansheng.zj
enode/src/main/java/com/qianzhui/enode/rocketmq/client/ons/ClientRPCHook.java:10
ClassCommand
Created by junbo_xu on 2016/3/24.
enode/src/main/java/com/qianzhui/enode/commanding/Command.java:8
EnumCommandAddResult
Created by junbo_xu on 2016/3/19.
enode/src/main/java/com/qianzhui/enode/commanding/CommandAddResult.java:8
ClassCommandAsyncHandlerProxy
Created by junbo_xu on 2016/3/31.
enode/src/main/java/com/qianzhui/enode/commanding/impl/CommandAsyncHandlerProxy.java:18
ClassCommandConsumer
Created by junbo_xu on 2016/3/13.
enode/src/main/java/com/qianzhui/enode/rocketmq/command/CommandConsumer.java:29
InterfaceCommandCustomHeader
Created by xujunbo on 18-1-19.
enode-remoting/src/main/java/com/qianzhui/enode/remoting/CommandCustomHeader.java:8
ClassCommandExecuteContext
enode/src/main/java/com/qianzhui/enode/rocketmq/command/CommandConsumer.java:97
ClassCommandExecuteTimeoutException
Created by junbo_xu on 2016/4/23.
enode/src/main/java/com/qianzhui/enode/commanding/CommandExecuteTimeoutException.java:6
ClassCommandHandlerProxy
Created by junbo_xu on 2016/3/25.
enode/src/main/java/com/qianzhui/enode/commanding/impl/CommandHandlerProxy.java:16
ClassCommandKeyProvider
Created by junbo_xu on 2016/3/9.
enode/src/main/java/com/qianzhui/enode/rocketmq/command/CommandKeyProvider.java:9
ClassCommandMessage
Created by junbo_xu on 2016/3/9.
enode/src/main/java/com/qianzhui/enode/rocketmq/command/CommandMessage.java:6
ClassCommandRecord
Created by junbo_xu on 2016/4/21.
enode/src/main/java/com/qianzhui/enode/commanding/impl/CommandRecord.java:8
EnumCommandReplyType
Created by junbo_xu on 2016/3/13.
enode/src/main/java/com/qianzhui/enode/rocketmq/CommandReplyType.java:6
ClassCommandResult
Created by junbo_xu on 2016/2/27.
enode/src/main/java/com/qianzhui/enode/commanding/CommandResult.java:6
ClassCommandResultProcessor
Created by junbo_xu on 2016/3/8.
enode/src/main/java/com/qianzhui/enode/rocketmq/command/CommandResultProcessor.java:29
EnumCommandReturnType
Created by junbo_xu on 2016/2/27.
enode/src/main/java/com/qianzhui/enode/commanding/CommandReturnType.java:6
ClassCommandService
Created by junbo_xu on 2016/3/1.
enode/src/main/java/com/qianzhui/enode/rocketmq/command/CommandService.java:30
EnumCommandStatus
Created by junbo_xu on 2016/2/27.
enode/src/main/java/com/qianzhui/enode/commanding/CommandStatus.java:6
ClassCommandTaskCompletionSource
enode/src/main/java/com/qianzhui/enode/rocketmq/command/CommandResultProcessor.java:162
ClassCommandTopicProvider
Created by junbo_xu on 2016/4/15.
samples/notesample/quickstart/src/main/java/com/qianzhui/enodesamples/quickstart/providers/CommandTopicProvider.java:13
ClassCompletableConsumeConcurrentlyContext
Created by junbo_xu on 2016/7/1.
enode/src/main/java/com/qianzhui/enode/common/rocketmq/consumer/listener/CompletableConsumeConcurrentlyContext.java:11
ClassCompletableConsumeMessageConcurrentlyService
Created by junbo_xu on 2016/6/30.
enode/src/main/java/com/qianzhui/enode/common/rocketmq/impl/consumer/CompletableConsumeMessageConcurrentlyService.java:35
ClassCompletableDefaultMQPushConsumer
Created by junbo_xu on 2016/6/30.
enode/src/main/java/com/qianzhui/enode/common/rocketmq/consumer/CompletableDefaultMQPushConsumer.java:31
ClassCompletableDefaultMQPushConsumerImpl
Created by junbo_xu on 2016/6/30.
enode/src/main/java/com/qianzhui/enode/common/rocketmq/impl/consumer/CompletableDefaultMQPushConsumerImpl.java:56
ClassCompletableFutureUtil
Created by junbo_xu on 2016/7/5.
enode/src/main/java/com/qianzhui/enode/common/utilities/CompletableFutureUtil.java:12
InterfaceCompletableMessageListenerConcurrently
Created by junbo_xu on 2016/6/30.
enode/src/main/java/com/qianzhui/enode/common/rocketmq/consumer/listener/CompletableMessageListenerConcurrently.java:11
ClassConfiguration
Created by junbo_xu on 2016/2/25.
enode/src/main/java/com/qianzhui/enode/configurations/Configuration.java:6
ClassConfigurationSetting
Created by junbo_xu on 2016/4/5.
enode/src/main/java/com/qianzhui/enode/configurations/ConfigurationSetting.java:6
ClassConstants
Created by junbo_xu on 2016/4/6.
enode/src/main/java/com/qianzhui/enode/rocketmq/Constants.java:6
ClassConsumeRequest
enode/src/main/java/com/qianzhui/enode/common/rocketmq/impl/consumer/CompletableConsumeMessageConcurrentlyService.java:85
EnumConsumeReturnType
enode/src/main/java/com/qianzhui/enode/rocketmq/trace/core/utils/OnsConsumeMessageHookImpl.java:107
InterfaceConsumer
Created by junbo_xu on 2016/4/20.
enode/src/main/java/com/qianzhui/enode/rocketmq/client/Consumer.java:9
ClassCreateNoteCommand
Created by junbo_xu on 2016/4/15.
samples/notesample/commands/src/main/java/com/qianzhui/enodesamples/notesample/commands/CreateNoteCommand.java:8
ClassCreateNoteCommandHandler
Created by junbo_xu on 2016/4/15.
samples/notesample/commandhandlers/src/main/java/com/qianzhui/enodesamples/notesample/commandhandlers/CreateNoteCommandHandler.java:11
ClassDefaultAggregateRepositoryProvider
Created by junbo_xu on 2016/4/1.
enode/src/main/java/com/qianzhui/enode/domain/impl/DefaultAggregateRepositoryProvider.java:22
ClassDefaultAggregateRootFactory
Created by junbo_xu on 2016/4/1.
enode/src/main/java/com/qianzhui/enode/domain/impl/DefaultAggregateRootFactory.java:9
ClassDefaultAggregateRootInternalHandlerProvider
Created by junbo_xu on 2016/2/24.
enode/src/main/java/com/qianzhui/enode/domain/impl/DefaultAggregateRootInternalHandlerProvider.java:23
ClassDefaultAggregateSnapshotter
Created by junbo_xu on 2016/4/1.
enode/src/main/java/com/qianzhui/enode/domain/impl/DefaultAggregateSnapshotter.java:13
ClassDefaultApplicationMessageProcessor
Created by xujunbo on 16-12-12.
enode/src/main/java/com/qianzhui/enode/infrastructure/impl/DefaultApplicationMessageProcessor.java:15
ClassDefaultCommandAsyncHandlerProvider
Created by junbo_xu on 2016/3/31.
enode/src/main/java/com/qianzhui/enode/commanding/impl/DefaultCommandAsyncHandlerProvider.java:13
ClassDefaultCommandHandlerProvider
Created by junbo_xu on 2016/3/21.
enode/src/main/java/com/qianzhui/enode/commanding/impl/DefaultCommandHandlerProvider.java:13
ClassDefaultCommandProcessor
Created by junbo_xu on 2016/4/22.
enode/src/main/java/com/qianzhui/enode/commanding/impl/DefaultCommandProcessor.java:23
ClassDefaultCommandRoutingKeyProvider
Created by junbo_xu on 2016/3/2.
enode/src/main/java/com/qianzhui/enode/commanding/impl/DefaultCommandRoutingKeyProvider.java:9
ClassDefaultDBConfigurationSetting
Created by junbo_xu on 2016/4/23.
enode/src/main/java/com/qianzhui/enode/configurations/DefaultDBConfigurationSetting.java:6
ClassDefaultDomainEventProcessor
Created by xujunbo on 16-12-12.
enode/src/main/java/com/qianzhui/enode/infrastructure/impl/DefaultDomainEventProcessor.java:14
ClassDefaultEventSerializer
Created by junbo_xu on 2016/3/20.
enode/src/main/java/com/qianzhui/enode/eventing/impl/DefaultEventSerializer.java:14
ClassDefaultEventService
Created by junbo_xu on 2016/3/31.
enode/src/main/java/com/qianzhui/enode/eventing/impl/DefaultEventService.java:25
ClassDefaultMemoryCache
Created by junbo_xu on 2016/3/31.
enode/src/main/java/com/qianzhui/enode/domain/impl/DefaultMemoryCache.java:24
ClassDefaultMessageDispatcher
Created by junbo_xu on 2016/4/3.
enode/src/main/java/com/qianzhui/enode/infrastructure/impl/DefaultMessageDispatcher.java:24
ClassDefaultMessageHandlerProvider
Created by junbo_xu on 2016/3/31.
enode/src/main/java/com/qianzhui/enode/infrastructure/impl/DefaultMessageHandlerProvider.java:15
ClassDefaultMessageProcessor
Created by junbo_xu on 2016/3/19.
enode/src/main/java/com/qianzhui/enode/infrastructure/impl/DefaultMessageProcessor.java:19
ClassDefaultProcessingCommandHandler
Created by junbo_xu on 2016/3/19.
enode/src/main/java/com/qianzhui/enode/commanding/impl/DefaultProcessingCommandHandler.java:25
next →1–100 of 339, ranked by callers