Functions — github.com/coffeewar/enode-master

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

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

⨍ Functions 1,671◇ Types & classes 339

↓ 2 callersMethodgetMessageId

()

enode/src/main/java/com/qianzhui/enode/infrastructure/MessageHandleRecord.java:17

↓ 2 callersMethodgetMessageId3

()

enode/src/main/java/com/qianzhui/enode/infrastructure/ThreeMessageHandleRecord.java:37

↓ 2 callersMethodgetMessageParameterIndex

(List<Class<?>> methodParameterTypes, IMessage message)

enode/src/main/java/com/qianzhui/enode/infrastructure/impl/MessageHandlerProxy3.java:60

↓ 2 callersMethodgetMessages

()

enode/src/main/java/com/qianzhui/enode/infrastructure/impl/DefaultMessageDispatcher.java:284

↓ 2 callersMethodgetMethod

()

enode/src/main/java/com/qianzhui/enode/infrastructure/MethodInvocation.java:9

↓ 2 callersMethodgetMsgType

()

enode/src/main/java/com/qianzhui/enode/rocketmq/trace/core/common/OnsTraceBean.java:28

↓ 2 callersMethodgetNext

()

enode/src/main/java/com/qianzhui/enode/eventing/EventCommittingContext.java:43

↓ 2 callersMethodgetObjectContainer

()

enode/src/main/java/com/qianzhui/enode/infrastructure/impl/AbstractHandlerProvider.java:36

↓ 2 callersMethodgetOffsetMsgId

()

enode/src/main/java/com/qianzhui/enode/rocketmq/trace/core/common/OnsTraceBean.java:36

↓ 2 callersMethodgetOnsChannel

()

enode/src/main/java/com/qianzhui/enode/rocketmq/client/ons/SessionCredentials.java:101

↓ 2 callersMethodgetPublishedVersionAsync

(String processorName, String aggregateRootTypeName, String aggregateRootId)

enode/src/main/java/com/qianzhui/enode/infrastructure/IPublishedVersionStore.java:14

↓ 2 callersMethodgetStoreHost

()

enode/src/main/java/com/qianzhui/enode/rocketmq/trace/core/common/OnsTraceBean.java:76

↓ 2 callersMethodgetSubscription

()

enode/src/main/java/com/qianzhui/enode/common/rocketmq/consumer/CompletableDefaultMQPushConsumer.java:317

↓ 2 callersMethodgetSuperGenericInterface

(Class implementerType, Class toResolve)

enode/src/main/java/com/qianzhui/enode/infrastructure/TypeUtils.java:22

↓ 2 callersMethodgetTitle

()

samples/notesample/commands/src/main/java/com/qianzhui/enodesamples/notesample/commands/CreateNoteCommand.java:16

↓ 2 callersMethodgetTransData

()

enode/src/main/java/com/qianzhui/enode/rocketmq/trace/core/common/OnsTraceTransferBean.java:16

↓ 2 callersMethodgetTypes

()

enode/src/main/java/com/qianzhui/enode/infrastructure/impl/ManyType.java:23

↓ 2 callersMethodgetUniqueId

()

enode/src/main/java/com/qianzhui/enode/rocketmq/publishableexceptions/PublishableExceptionMessage.java:17

↓ 2 callersMethodgetVersion

()

enode/src/main/java/com/qianzhui/enode/eventing/impl/StreamRecord.java:45

↓ 2 callersMethodhandleAsync

(ICommand command)

enode/src/main/java/com/qianzhui/enode/commanding/ICommandAsyncHandlerProxy.java:14

↓ 2 callersMethodhandleCommand

(ProcessingCommand processingCommand, ICommandHandlerProxy commandHandler)

enode/src/main/java/com/qianzhui/enode/commanding/impl/DefaultProcessingCommandHandler.java:103

↓ 2 callersMethodhandleEvent

(IDomainEvent domainEvent)

enode/src/main/java/com/qianzhui/enode/domain/AggregateRoot.java:67

↓ 2 callersMethodhandleFirstEventDuplicationAsync

(EventCommittingContext context)

enode/src/main/java/com/qianzhui/enode/eventing/impl/DefaultEventService.java:230

↓ 2 callersMethodhasHook

()

enode/src/main/java/com/qianzhui/enode/common/rocketmq/impl/consumer/CompletableDefaultMQPushConsumerImpl.java:105

↓ 2 callersMethodhashCode

()

enode/src/main/java/com/qianzhui/enode/rocketmq/TopicTagData.java:47

↓ 2 callersMethodheaderEncode

()

enode-remoting/src/main/java/com/qianzhui/enode/remoting/protocol/RemotingCommand.java:276

↓ 2 callersMethodhookName

()

enode/src/main/java/com/qianzhui/enode/rocketmq/trace/core/OnsClientSendMessageHookImpl.java:28

↓ 2 callersMethodinit

(Properties properties)

enode/src/main/java/com/qianzhui/enode/rocketmq/client/MQClientInitializer.java:22

↓ 2 callersMethodinit

(Properties properties)

enode/src/main/java/com/qianzhui/enode/rocketmq/client/ons/ONSClientInitializer.java:36

↓ 2 callersMethodinvokeAsyncImpl

(final Channel channel, final RemotingCommand request, final long timeoutMillis,

enode-remoting/src/main/java/com/qianzhui/enode/remoting/netty/NettyRemotingAbstract.java:292

↓ 2 callersMethodinvokeOnewayImpl

(final Channel channel, final RemotingCommand request, final long timeoutMillis)

enode-remoting/src/main/java/com/qianzhui/enode/remoting/netty/NettyRemotingAbstract.java:344

↓ 2 callersMethodinvokeSyncImpl

(final Channel channel, final RemotingCommand request, final long ti

enode-remoting/src/main/java/com/qianzhui/enode/remoting/netty/NettyRemotingAbstract.java:253

↓ 2 callersMethodisInterfaceOrObjectClass

(Class type)

enode/src/main/java/com/qianzhui/enode/domain/impl/DefaultAggregateRootInternalHandlerProvider.java:55

↓ 2 callersMethodisLinuxPlatform

()

enode-remoting/src/main/java/com/qianzhui/enode/remoting/common/RemotingUtil.java:86

↓ 2 callersMethodisOnewayRPC

()

enode-remoting/src/main/java/com/qianzhui/enode/remoting/protocol/RemotingCommand.java:340

↓ 2 callersMethodisUnitMode

()

enode/src/main/java/com/qianzhui/enode/common/rocketmq/impl/consumer/CompletableDefaultMQPushConsumerImpl.java:994

↓ 2 callersMethodlogCommandExecuteException

(ProcessingCommand processingCommand, ICommandHandlerProxy commandHandler, Exception exception)

enode/src/main/java/com/qianzhui/enode/commanding/impl/DefaultProcessingCommandHandler.java:280

↓ 2 callersMethodmakeSureStateOK

()

enode/src/main/java/com/qianzhui/enode/common/rocketmq/impl/consumer/CompletableDefaultMQPushConsumerImpl.java:543

↓ 2 callersMethodmarkResponseType

()

enode-remoting/src/main/java/com/qianzhui/enode/remoting/protocol/RemotingCommand.java:322

↓ 2 callersMethodonChildDispatchingFinished

(Object childDispatching)

enode/src/main/java/com/qianzhui/enode/infrastructure/impl/DefaultMessageDispatcher.java:239

↓ 2 callersMethodpersistEventOneByOne

(List<EventCommittingContext> contextList)

enode/src/main/java/com/qianzhui/enode/eventing/impl/DefaultEventService.java:135

↓ 2 callersMethodpositive

(int number, String argumentName)

enode/src/main/java/com/qianzhui/enode/common/utilities/Ensure.java:17

↓ 2 callersMethodprocessMessageReceived

Entry of incoming command processing. Note: The incoming remoting command may be <ul> <li>An inquiry request from a remote pe

enode-remoting/src/main/java/com/qianzhui/enode/remoting/netty/NettyRemotingAbstract.java:112

↓ 2 callersMethodpublishDomainEventAsync

Publish the given domain event stream async. @param processingCommand @param eventStream

enode/src/main/java/com/qianzhui/enode/eventing/IEventService.java:30

↓ 2 callersMethodqueryAggregateEvents

(String aggregateRootId, String aggregateRootTypeName, int minVersion, int maxVersion)

enode/src/main/java/com/qianzhui/enode/eventing/IEventStore.java:14

↓ 2 callersMethodreconsumeLater

()

enode/src/main/java/com/qianzhui/enode/common/rocketmq/consumer/listener/CompletableConsumeConcurrentlyContext.java:37

↓ 2 callersMethodregister

(Class aggregateRootType, Class type)

enode/src/main/java/com/qianzhui/enode/domain/impl/DefaultAggregateRootInternalHandlerProvider.java:59

↓ 2 callersMethodregisterProcessor

(final int requestCode, final NettyRequestProcessor processor)

enode-remoting/src/main/java/com/qianzhui/enode/remoting/RemotingClient.java:28

↓ 2 callersMethodregisterProperties

(Properties properties)

enode/src/main/java/com/qianzhui/enode/common/container/IObjectContainer.java:65

↓ 2 callersMethodrelease

()

enode-remoting/src/main/java/com/qianzhui/enode/remoting/common/SemaphoreReleaseOnlyOnce.java:30

↓ 2 callersMethodremoveShutdownHook

()

enode/src/main/java/com/qianzhui/enode/rocketmq/trace/core/dispatch/impl/AsyncArrayDispatcher.java:150

↓ 2 callersMethodreplayEvents

(List<DomainEventStream> eventStreams)

enode/src/main/java/com/qianzhui/enode/domain/IAggregateRoot.java:20

↓ 2 callersMethodreset

()

enode/src/main/java/com/qianzhui/enode/common/threading/ManualResetEvent.java:47

↓ 2 callersMethodresetRetryTopic

(final List<MessageExt> msgs)

enode/src/main/java/com/qianzhui/enode/common/rocketmq/impl/consumer/CompletableConsumeMessageConcurrentlyService.java:439

↓ 2 callersMethodresolve

(Class<TService> serviceType)

enode/src/main/java/com/qianzhui/enode/common/container/ObjectContainer.java:149

↓ 2 callersMethodresolveNamed

(Class<TService> serviceType, String serviceName)

enode/src/main/java/com/qianzhui/enode/common/container/IObjectContainer.java:73

↓ 2 callersMethodrestoreFromSnapshot

(Class<T> aggregateRootType, String aggregateRootId)

enode/src/main/java/com/qianzhui/enode/domain/IAggregateSnapshotter.java:7

↓ 2 callersMethodscanResponseTable

This method is periodically invoked to scan and expire deprecated request.

enode-remoting/src/main/java/com/qianzhui/enode/remoting/netty/NettyRemotingAbstract.java:229

↓ 2 callersMethodscheduleMessage

(X processingMessage)

enode/src/main/java/com/qianzhui/enode/infrastructure/IProcessingMessageScheduler.java:7

↓ 2 callersMethodsendReply

(short replyType, Object replyData, String replyAddress)

enode/src/main/java/com/qianzhui/enode/rocketmq/SendReplyService.java:51

↓ 2 callersMethodsendTraceDataByMQ

发送数据的接口 @param keySet 本批次包含的keyset @param data 本批次的轨迹数据

enode/src/main/java/com/qianzhui/enode/rocketmq/trace/core/dispatch/impl/AsyncTraceAppender.java:136

↓ 2 callersMethodsendTraceDataByMQ

发送数据的接口 @param keySet 本批次包含的keyset @param data 本批次的轨迹数据

enode/src/main/java/com/qianzhui/enode/rocketmq/trace/core/dispatch/impl/AsyncArrayDispatcher.java:255

↓ 2 callersMethodsequence

()

enode/src/main/java/com/qianzhui/enode/infrastructure/IMessage.java:17

↓ 2 callersMethodserializeTo

(Map<String, String> serializableInfo)

enode/src/main/java/com/qianzhui/enode/infrastructure/IPublishableException.java:9

↓ 2 callersMethodsetAggregateRootId

(TAggregateRootId aggregateRootId)

enode/src/main/java/com/qianzhui/enode/eventing/IDomainEvent.java:11

↓ 2 callersMethodsetContainer

(IObjectContainer container)

enode/src/main/java/com/qianzhui/enode/common/container/ObjectContainer.java:15

↓ 2 callersMethodsetFlag

(int flag)

enode-remoting/src/main/java/com/qianzhui/enode/remoting/protocol/RemotingCommand.java:379

↓ 2 callersMethodsetId

(String id)

enode/src/main/java/com/qianzhui/enode/infrastructure/IMessage.java:11

↓ 2 callersMethodsetMailbox

(ProcessingMessageMailbox<X, Y> mailbox)

enode/src/main/java/com/qianzhui/enode/infrastructure/IProcessingMessage.java:8

↓ 2 callersMethodsetMessageModel

(MessageModel messageModel)

enode/src/main/java/com/qianzhui/enode/common/rocketmq/consumer/CompletableDefaultMQPushConsumer.java:282

↓ 2 callersMethodsetMsgType

(MessageType msgType)

enode/src/main/java/com/qianzhui/enode/rocketmq/trace/core/common/OnsTraceBean.java:32

↓ 2 callersMethodsetOffsetMsgId

(String offsetMsgId)

enode/src/main/java/com/qianzhui/enode/rocketmq/trace/core/common/OnsTraceBean.java:40

↓ 2 callersMethodsetRetryTimes

(int retryTimes)

enode/src/main/java/com/qianzhui/enode/rocketmq/trace/core/common/OnsTraceBean.java:104

↓ 2 callersMethodsetSequence

(int sequence)

enode/src/main/java/com/qianzhui/enode/infrastructure/IMessage.java:19

↓ 2 callersMethodsetStoreHost

(String storeHost)

enode/src/main/java/com/qianzhui/enode/rocketmq/trace/core/common/OnsTraceBean.java:80

↓ 2 callersMethodsetStoreTime

(long storeTime)

enode/src/main/java/com/qianzhui/enode/rocketmq/trace/core/common/OnsTraceBean.java:96

↓ 2 callersMethodsetTimestamp

(Date timestamp)

enode/src/main/java/com/qianzhui/enode/infrastructure/IMessage.java:15

↓ 2 callersMethodsetTopic

(String topic)

enode/src/main/java/com/qianzhui/enode/rocketmq/TopicTagData.java:23

↓ 2 callersMethodsetVersion

(int version)

enode/src/main/java/com/qianzhui/enode/infrastructure/ISequenceMessage.java:17

↓ 2 callersMethodshutdown

()

enode-remoting/src/main/java/com/qianzhui/enode/remoting/RemotingService.java:8

↓ 2 callersMethodshutdown

关闭轨迹Hook

enode/src/main/java/com/qianzhui/enode/rocketmq/trace/core/dispatch/AsyncDispatcher.java:32

↓ 2 callersMethodsign

(byte[] data, byte[] key, SigningAlgorithm algorithm)

enode/src/main/java/com/qianzhui/enode/rocketmq/client/ons/OnsAuthSigner.java:42

↓ 2 callersMethodsign

(String data, String key)

enode/src/main/java/com/qianzhui/enode/rocketmq/client/ons/SpasSigner.java:20

↓ 2 callersMethodsignAndBase64Encode

(String data, String key, SigningAlgorithm algorithm, Charset charset)

enode/src/main/java/com/qianzhui/enode/rocketmq/client/ons/OnsAuthSigner.java:30

↓ 2 callersMethodsubmitConsumeRequest

(// final List<MessageExt> msgs, //

enode/src/main/java/com/qianzhui/enode/common/rocketmq/impl/consumer/CompletableConsumeMessageConcurrentlyService.java:306

↓ 2 callersMethodtoString

()

enode-remoting/src/main/java/com/qianzhui/enode/remoting/protocol/RemotingCommand.java:414

↓ 2 callersMethodtryActionRecursively

========== TryActionRecursively =========

enode/src/main/java/com/qianzhui/enode/common/io/IOHelper.java:24

↓ 2 callersMethodtryIOFunc

(Func<T> func, String funcName)

enode/src/main/java/com/qianzhui/enode/common/io/IOHelper.java:285

↓ 2 callersMethodunsubscribe

(final String topic)

enode/src/main/java/com/qianzhui/enode/rocketmq/client/Consumer.java:20

↓ 2 callersMethoduseEpoll

()

enode-remoting/src/main/java/com/qianzhui/enode/remoting/netty/NettyRemotingServer.java:116

↓ 2 callersMethoduseRocketMQ

(Properties producerSetting, Properties consumerSetting,

enode/src/main/java/com/qianzhui/enode/ENode.java:369

↓ 2 callersMethodversion

()

enode/src/main/java/com/qianzhui/enode/domain/AggregateRoot.java:112

↓ 2 callersMethodwaitOne

()

enode/src/main/java/com/qianzhui/enode/common/threading/ManualResetEvent.java:14

↓ 1 callersMethodConcatContexts

(List<EventCommittingContext> contextList)

enode/src/main/java/com/qianzhui/enode/eventing/impl/DefaultEventService.java:306

↓ 1 callersMethodacceptChanges

(int newVersion)

enode/src/main/java/com/qianzhui/enode/domain/IAggregateRoot.java:18

↓ 1 callersMethodaddLockKey

(String lockKey)

enode/src/main/java/com/qianzhui/enode/infrastructure/impl/mysql/MysqlLockService.java:68

↓ 1 callersMethodaddTask

(CompletableFuture<AsyncTaskResult<EventAppendResult>> task)

enode/src/main/java/com/qianzhui/enode/eventing/impl/InMemoryEventStore.java:87

↓ 1 callersMethodaddToWaitingList

()

enode/src/main/java/com/qianzhui/enode/infrastructure/ISequenceProcessingMessage.java:7

↓ 1 callersMethodaddWaitingForRetryMessage

(X waitingMessage)

enode/src/main/java/com/qianzhui/enode/infrastructure/ProcessingMessageMailbox.java:42

↓ 1 callersMethodappendAsync

(DomainEventStream eventStream)

enode/src/main/java/com/qianzhui/enode/eventing/impl/InMemoryEventStore.java:113

← previous next →301–400 of 1,671, ranked by callers