MCPcopy Create free account

hub / github.com/coffeewar/enode-master / functions

Functions1,671 in github.com/coffeewar/enode-master

⨍ Functions 1,671◇ Types & classes 339
↓ 115 callersMethodgetMessage
()
enode/src/main/java/com/qianzhui/enode/infrastructure/IProcessingMessage.java:7
↓ 91 callersMethodget
(Class<T> aggregateRootType, Object aggregateRootId)
enode/src/main/java/com/qianzhui/enode/domain/IRepository.java:7
↓ 76 callersMethodid
()
enode/src/main/java/com/qianzhui/enode/infrastructure/IMessage.java:9
↓ 72 callersMethodappend
往数据传输模块中添加信息， @param ctx 数据信息 @return 返回true代表添加成功，返回false代表数据被抛弃
enode/src/main/java/com/qianzhui/enode/rocketmq/trace/core/dispatch/AsyncDispatcher.java:21
↓ 72 callersMethodregister
===================
enode/src/main/java/com/qianzhui/enode/common/container/IObjectContainer.java:41
↓ 61 callersMethodadd
(IAggregateRoot aggregateRoot)
enode/src/main/java/com/qianzhui/enode/commanding/ICommandContext.java:9
↓ 61 callersMethodsize
()
enode/src/main/java/com/qianzhui/enode/rocketmq/trace/core/dispatch/impl/AsyncTraceDispatcher.java:79
↓ 60 callersMethodgetName
()
enode/src/main/java/com/qianzhui/enode/common/scheduling/ScheduleService.java:96
↓ 48 callersMethodresolve
(Class<TService> serviceType)
enode/src/main/java/com/qianzhui/enode/common/container/IObjectContainer.java:67
↓ 37 callersMethodgetAggregateRootId
Represents the associated aggregate root string id.
enode/src/main/java/com/qianzhui/enode/commanding/ICommand.java:13
↓ 34 callersMethodgetLog
()
enode/src/main/java/com/qianzhui/enode/common/logging/ENodeLogger.java:20
↓ 31 callersMethodnotNull
(T argument, String argumentName)
enode/src/main/java/com/qianzhui/enode/common/utilities/Ensure.java:7
↓ 30 callersMethodgetConsumerGroup
()
enode/src/main/java/com/qianzhui/enode/common/rocketmq/consumer/CompletableDefaultMQPushConsumer.java:232
↓ 28 callersMethodgetValue
()
enode/src/main/java/com/qianzhui/enode/rocketmq/CommandReplyType.java:17
↓ 27 callersMethodversion
()
enode/src/main/java/com/qianzhui/enode/domain/IAggregateRoot.java:14
↓ 26 callersMethodgetKey
(ICommand command)
enode/src/main/java/com/qianzhui/enode/commanding/ICommandKeyProvider.java:7
↓ 23 callersMethodgetInstance
()
enode/src/main/java/com/qianzhui/enode/ENode.java:93
↓ 23 callersMethodgetName
()
enode/src/main/java/com/qianzhui/enode/infrastructure/impl/AbstractSequenceProcessingMessageHandler.java:21
↓ 22 callersMethodapply
()
enode/src/main/java/com/qianzhui/enode/common/function/Func.java:7
↓ 21 callersMethodcomplete
()
enode/src/main/java/com/qianzhui/enode/infrastructure/IProcessingMessage.java:9
↓ 21 callersMethodgetTopic
()
enode/src/main/java/com/qianzhui/enode/rocketmq/TopicTagData.java:19
↓ 20 callersMethodget
(Class<T> aggregateRootType, Object id)
enode/src/main/java/com/qianzhui/enode/commanding/ICommandContext.java:11
↓ 20 callersMethodgetBytes
(short v)
enode/src/main/java/com/qianzhui/enode/common/utilities/BitConverter.java:11
↓ 20 callersMethodparseChannelRemoteAddr
(final Channel channel)
enode-remoting/src/main/java/com/qianzhui/enode/remoting/common/RemotingHelper.java:152
↓ 19 callersMethodgetMessageQueue
()
enode/src/main/java/com/qianzhui/enode/common/rocketmq/impl/consumer/CompletableConsumeMessageConcurrentlyService.java:199
↓ 19 callersMethodgetProcessingCommand
()
enode/src/main/java/com/qianzhui/enode/eventing/EventCommittingContext.java:31
↓ 19 callersMethodgetSetting
()
enode/src/main/java/com/qianzhui/enode/ENode.java:125
↓ 18 callersMethodequals
(Object o)
enode/src/main/java/com/qianzhui/enode/rocketmq/TopicTagData.java:35
↓ 18 callersMethodgetEventStream
()
enode/src/main/java/com/qianzhui/enode/eventing/EventCommittingContext.java:27
↓ 18 callersMethodgetOptionValue
(String key)
enode/src/main/java/com/qianzhui/enode/configurations/OptionSetting.java:27
↓ 18 callersMethodhasComponent
(int componentsFlag, int checkComponent)
enode/src/main/java/com/qianzhui/enode/ENode.java:533
↓ 18 callersMethodoverride
(Class implementationType, String serviceName, LifeStyle life)
enode/src/main/java/com/qianzhui/enode/common/container/IObjectContainer.java:16
↓ 17 callersMethodaggregateRootId
()
enode/src/main/java/com/qianzhui/enode/eventing/IDomainEvent.java:9
↓ 17 callersMethodequals
(Object obj)
enode/src/main/java/com/qianzhui/enode/rocketmq/client/ons/SessionCredentials.java:124
↓ 17 callersMethodshutdown
关闭服务
enode/src/main/java/com/qianzhui/enode/rocketmq/client/Producer.java:21
↓ 17 callersMethodtryAsyncActionRecursively
========== TryAsyncActionRecursively =========
enode/src/main/java/com/qianzhui/enode/common/io/IOHelper.java:54
↓ 16 callersMethoduniqueId
()
enode/src/main/java/com/qianzhui/enode/domain/IAggregateRoot.java:12
↓ 15 callersMethodgetData
()
enode/src/main/java/com/qianzhui/enode/common/io/AsyncTaskResult.java:46
↓ 15 callersMethodgetInnerObject
()
enode/src/main/java/com/qianzhui/enode/infrastructure/IObjectProxy.java:7
↓ 15 callersMethodgetSequence
()
enode/src/main/java/com/qianzhui/enode/commanding/ProcessingCommand.java:36
↓ 15 callersMethodgetTypeName
()
enode/src/main/java/com/qianzhui/enode/infrastructure/IMessage.java:23
↓ 15 callersMethodstart
启动服务
enode/src/main/java/com/qianzhui/enode/rocketmq/client/Producer.java:15
↓ 14 callersMethodcompleteCommand
(ProcessingCommand processingCommand, CommandStatus commandStatus, String resultType, String result)
enode/src/main/java/com/qianzhui/enode/commanding/impl/DefaultProcessingCommandHandler.java:430
↓ 14 callersMethodgetKeys
()
enode/src/main/java/com/qianzhui/enode/rocketmq/trace/core/common/OnsTraceBean.java:68
↓ 14 callersMethodtoString
()
enode-remoting/src/main/java/com/qianzhui/enode/remoting/netty/NettyEvent.java:44
↓ 14 callersMethodtoString
()
enode/src/main/java/com/qianzhui/enode/common/utilities/ObjectId.java:151
↓ 14 callersMethodupdate
(QueryRunner queryRunner, Connection connection)
enode/src/main/java/com/qianzhui/enode/infrastructure/impl/AbstractAsyncDenormalizer.java:112
↓ 13 callersMethodequals
(Object o)
enode/src/main/java/com/qianzhui/enode/configurations/StringKeyValuePair.java:23
↓ 13 callersMethodgetTraceBeans
()
enode/src/main/java/com/qianzhui/enode/rocketmq/trace/core/common/OnsTraceContext.java:57
↓ 13 callersMethodserialize
(List<IDomainEvent> evnts)
enode/src/main/java/com/qianzhui/enode/eventing/IEventSerializer.java:10
↓ 12 callersMethodcloseChannel
(final String addr, final Channel channel)
enode-remoting/src/main/java/com/qianzhui/enode/remoting/netty/NettyRemotingClient.java:151
↓ 12 callersMethoddeserialize
(Map<String, String> data, Class<TEvent> domainEventType)
enode/src/main/java/com/qianzhui/enode/eventing/IEventSerializer.java:12
↓ 12 callersMethodgetMsgs
()
enode/src/main/java/com/qianzhui/enode/common/rocketmq/impl/consumer/CompletableConsumeMessageConcurrentlyService.java:189
↓ 12 callersMethodgetSubscriptionInner
()
enode/src/main/java/com/qianzhui/enode/common/rocketmq/impl/consumer/CompletableDefaultMQPushConsumerImpl.java:270
↓ 12 callersMethodtoString
()
enode/src/main/java/com/qianzhui/enode/rocketmq/client/ons/SessionCredentials.java:168
↓ 11 callersMethodclear
()
enode/src/main/java/com/qianzhui/enode/commanding/ITrackingContext.java:13
↓ 11 callersMethodgetTopic
()
enode/src/main/java/com/qianzhui/enode/rocketmq/trace/core/common/OnsTraceBean.java:44
↓ 10 callersMethodaggregateRootTypeName
()
enode/src/main/java/com/qianzhui/enode/infrastructure/ISequenceMessage.java:11
↓ 10 callersMethodgetBody
()
enode-remoting/src/main/java/com/qianzhui/enode/remoting/protocol/RemotingCommand.java:391
↓ 10 callersMethodgetCanonicalName
(Class clazz)
enode-remoting/src/main/java/com/qianzhui/enode/remoting/protocol/RemotingCommand.java:197
↓ 10 callersMethodgetRoutingKey
()
enode/src/main/java/com/qianzhui/enode/infrastructure/IMessage.java:21
↓ 10 callersMethodregisterInstance
(Class<TService> serviceType, TImplementer instance, String serviceName)
enode/src/main/java/com/qianzhui/enode/common/container/IObjectContainer.java:59
↓ 10 callersMethodstop
Stop background tasks.
enode/src/main/java/com/qianzhui/enode/domain/IMemoryCache.java:40
↓ 9 callersMethodaggregateRootStringId
()
enode/src/main/java/com/qianzhui/enode/infrastructure/ISequenceMessage.java:7
↓ 9 callersMethoderrorMessage
(final String msg, final String url)
enode/src/main/java/com/qianzhui/enode/rocketmq/client/ons/FAQ.java:19
↓ 9 callersMethodgetActiveThreadCount
()
enode/src/main/java/com/qianzhui/enode/jmx/ForkJoinPoolMBean.java:8
↓ 9 callersMethodgetCommandId
()
enode/src/main/java/com/qianzhui/enode/rocketmq/domainevent/EventStreamMessage.java:59
↓ 9 callersMethodgetContextInfo
(Func<String> func)
enode/src/main/java/com/qianzhui/enode/common/io/IOHelper.java:249
↓ 9 callersMethodgetMessageModel
()
enode/src/main/java/com/qianzhui/enode/common/rocketmq/consumer/CompletableDefaultMQPushConsumer.java:277
↓ 9 callersMethodgetRegionId
()
enode/src/main/java/com/qianzhui/enode/rocketmq/trace/core/common/OnsTraceContext.java:67
↓ 9 callersMethodputNettyEvent
Put a netty event to the executor. @param event Netty event instance.
enode-remoting/src/main/java/com/qianzhui/enode/remoting/netty/NettyRemotingAbstract.java:92
↓ 9 callersMethodversion
()
enode/src/main/java/com/qianzhui/enode/infrastructure/ISequenceMessage.java:15
↓ 8 callersMethodappend
(DomainEventStream eventStream)
enode/src/main/java/com/qianzhui/enode/eventing/IEventStore.java:18
↓ 8 callersMethodexecutePullRequestLater
(final PullRequest pullRequest, final long timeDelay)
enode/src/main/java/com/qianzhui/enode/common/rocketmq/impl/consumer/CompletableDefaultMQPushConsumerImpl.java:528
↓ 8 callersMethodgetAllSubscribeTopics
()
enode/src/main/java/com/qianzhui/enode/rocketmq/ITopicProvider.java:11
↓ 8 callersMethodgetCause
()
enode-remoting/src/main/java/com/qianzhui/enode/remoting/netty/ResponseFuture.java:98
↓ 8 callersMethodgetChannel
()
enode-remoting/src/main/java/com/qianzhui/enode/remoting/netty/NettyRemotingClient.java:405
↓ 8 callersMethodgetFindStatus
()
enode/src/main/java/com/qianzhui/enode/commanding/impl/DefaultProcessingCommandHandler.java:413
↓ 8 callersMethodgetMsgId
()
enode/src/main/java/com/qianzhui/enode/rocketmq/trace/core/common/OnsTraceBean.java:52
↓ 8 callersMethodgetScanExpiredAggregateIntervalMilliseconds
()
enode/src/main/java/com/qianzhui/enode/configurations/ConfigurationSetting.java:51
↓ 8 callersMethodset
Set an aggregate to memory cache. @param aggregateRoot
enode/src/main/java/com/qianzhui/enode/domain/IMemoryCache.java:22
↓ 8 callersMethodsetSuccess
(boolean success)
enode/src/main/java/com/qianzhui/enode/rocketmq/trace/core/common/OnsTraceContext.java:122
↓ 7 callersMethodaggregateRootId
()
enode/src/main/java/com/qianzhui/enode/eventing/DomainEventStream.java:59
↓ 7 callersMethodcommandId
()
enode/src/main/java/com/qianzhui/enode/eventing/DomainEventStream.java:43
↓ 7 callersMethodgetAccessKey
()
enode/src/main/java/com/qianzhui/enode/rocketmq/client/ons/SessionCredentials.java:61
↓ 7 callersMethodgetCorePoolSize
()
enode/src/main/java/com/qianzhui/enode/common/rocketmq/impl/consumer/CompletableConsumeMessageConcurrentlyService.java:372
↓ 7 callersMethodgetErrorMessage
()
enode/src/main/java/com/qianzhui/enode/common/io/AsyncTaskResult.java:42
↓ 7 callersMethodgetValue
()
enode/src/main/java/com/qianzhui/enode/configurations/StringKeyValuePair.java:19
↓ 7 callersMethodhandleAsync
(IMessage message1, IMessage message2, IMessage message3)
enode/src/main/java/com/qianzhui/enode/infrastructure/IMessageHandlerProxy3.java:11
↓ 7 callersMethodhasAnyComponents
(int componentsFlag, int checkComponents)
enode/src/main/java/com/qianzhui/enode/ENode.java:537
↓ 7 callersMethodisSuccess
()
enode/src/main/java/com/qianzhui/enode/rocketmq/trace/core/common/OnsTraceContext.java:117
↓ 7 callersMethodregisterMessageListener
(final MessageListenerConcurrently messageListener)
enode/src/main/java/com/qianzhui/enode/rocketmq/client/Consumer.java:14
↓ 7 callersMethodsetKeys
(String keys)
enode/src/main/java/com/qianzhui/enode/rocketmq/trace/core/common/OnsTraceBean.java:72
↓ 7 callersMethodstart
Start background tasks.
enode/src/main/java/com/qianzhui/enode/domain/IMemoryCache.java:35
↓ 6 callersMethodbuildIntanceName
()
enode/src/main/java/com/qianzhui/enode/rocketmq/client/ons/ONSClientInitializer.java:53
↓ 6 callersMethodcloseChannel
(Channel channel)
enode-remoting/src/main/java/com/qianzhui/enode/remoting/common/RemotingUtil.java:187
↓ 6 callersMethodgetCommandExecuteContext
()
enode/src/main/java/com/qianzhui/enode/commanding/ProcessingCommand.java:48
↓ 6 callersMethodgetConsumeThreadMax
()
enode/src/main/java/com/qianzhui/enode/common/rocketmq/consumer/CompletableDefaultMQPushConsumer.java:242
↓ 6 callersMethodgetHandlerTypeName
()
enode/src/main/java/com/qianzhui/enode/infrastructure/MessageHandleRecord.java:25
↓ 6 callersMethodgetMessageListenerInner
()
enode/src/main/java/com/qianzhui/enode/common/rocketmq/impl/consumer/CompletableDefaultMQPushConsumerImpl.java:899
next →1–100 of 1,671, ranked by callers