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

↓ 6 callersMethodgetName

()

enode/src/main/java/com/qianzhui/enode/eventing/impl/DomainEventStreamMessageHandler.java:27

↓ 6 callersMethodgetNameServerAddr

()

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

↓ 6 callersMethodgetProcessQueue

()

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

↓ 6 callersMethodgetStatus

()

enode/src/main/java/com/qianzhui/enode/rocketmq/client/ons/AuthenticationException.java:40

↓ 6 callersMethodgetTableName

(String aggregateRootId)

enode/src/main/java/com/qianzhui/enode/eventing/impl/MysqlEventStore.java:303

↓ 6 callersMethodgetTags

()

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

↓ 6 callersMethodgetTimeStamp

()

enode/src/main/java/com/qianzhui/enode/rocketmq/trace/core/common/OnsTraceContext.java:87

↓ 6 callersMethodgetType

(String typeName)

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

↓ 6 callersMethodoverrideInstance

(Class<TService> serviceType, TImplementer instance, String serviceName)

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

↓ 6 callersMethodrelease

()

enode-remoting/src/main/java/com/qianzhui/enode/remoting/netty/ResponseFuture.java:57

↓ 6 callersMethodresetCommandMailBoxConsumingSequence

(EventCommittingContext context, long consumingSequence)

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

↓ 6 callersMethodsend

(final Message msg, final MessageQueueSelector selector, final Object arg)

enode/src/main/java/com/qianzhui/enode/rocketmq/client/Producer.java:23

↓ 6 callersMethodsetTraceBeans

(List<OnsTraceBean> traceBeans)

enode/src/main/java/com/qianzhui/enode/rocketmq/trace/core/common/OnsTraceContext.java:62

↓ 6 callersMethodsetTraceType

(OnsTraceType traceType)

enode/src/main/java/com/qianzhui/enode/rocketmq/trace/core/common/OnsTraceContext.java:82

↓ 5 callersMethodclose

(ChannelHandlerContext ctx, ChannelPromise promise)

enode-remoting/src/main/java/com/qianzhui/enode/remoting/netty/NettyRemotingClient.java:449

↓ 5 callersMethodequals

(Object obj)

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

↓ 5 callersMethodevents

()

enode/src/main/java/com/qianzhui/enode/eventing/DomainEventStream.java:75

↓ 5 callersMethodexceptionSimpleDesc

(final Throwable e)

enode-remoting/src/main/java/com/qianzhui/enode/remoting/common/RemotingHelper.java:38

↓ 5 callersMethodexecuteRetryAction

()

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

↓ 5 callersMethodgetConsumeThreadMin

()

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

↓ 5 callersMethodgetException

()

enode/src/main/java/com/qianzhui/enode/infrastructure/WrappedRuntimeException.java:26

↓ 5 callersMethodgetMessageListener

()

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

↓ 5 callersMethodgetSecretKey

()

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

↓ 5 callersMethodhandle

(MessageExt message, CompletableConsumeConcurrentlyContext context)

enode/src/main/java/com/qianzhui/enode/rocketmq/RocketMQMessageHandler.java:12

↓ 5 callersMethodisOK

()

enode-remoting/src/main/java/com/qianzhui/enode/remoting/netty/NettyRemotingClient.java:397

↓ 5 callersMethodonMessageHandled

(IMessage message)

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

↓ 5 callersMethodparseSocketAddressAddr

(SocketAddress socketAddress)

enode-remoting/src/main/java/com/qianzhui/enode/remoting/common/RemotingHelper.java:171

↓ 5 callersMethodsendMessageAsync

(Producer producer, Message message, String routingKey, String messageId, String version)

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

↓ 5 callersMethodsetGroupName

(String groupName)

enode/src/main/java/com/qianzhui/enode/rocketmq/trace/core/common/OnsTraceContext.java:102

↓ 5 callersMethodsetMsgId

(String msgId)

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

↓ 5 callersMethodsetOpaque

(int opaque)

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

↓ 5 callersMethodsetRegionId

(String regionId)

enode/src/main/java/com/qianzhui/enode/rocketmq/trace/core/common/OnsTraceContext.java:72

↓ 5 callersMethodsubscribe

(final String topic, final String subExpression)

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

↓ 5 callersMethodtoString

()

enode/src/main/java/com/qianzhui/enode/rocketmq/trace/core/common/OnsTraceContext.java:143

↓ 4 callersMethodaggregateRootTypeName

()

enode/src/main/java/com/qianzhui/enode/eventing/DomainEventStream.java:51

↓ 4 callersMethodcompleteCommand

(ProcessingCommand processingCommand, CommandResult commandResult)

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

↓ 4 callersMethodexecuteFailedAction

(String errorMessage)

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

↓ 4 callersMethodexecutePullRequestImmediately

(final PullRequest pullRequest)

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

↓ 4 callersMethodfindAsync

(String aggregateRootId, int version)

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

↓ 4 callersMethodgetAggregateRootMaxInactiveSeconds

()

enode/src/main/java/com/qianzhui/enode/configurations/ConfigurationSetting.java:59

↓ 4 callersMethodgetChannel

()

enode-remoting/src/main/java/com/qianzhui/enode/remoting/netty/NettyEvent.java:40

↓ 4 callersMethodgetConsumerStatsManager

()

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

↓ 4 callersMethodgetItems

()

enode/src/main/java/com/qianzhui/enode/rocketmq/domainevent/EventStreamMessage.java:75

↓ 4 callersMethodgetMessageId1

()

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

↓ 4 callersMethodgetMessageId2

()

enode/src/main/java/com/qianzhui/enode/infrastructure/TwoMessageHandleRecord.java:27

↓ 4 callersMethodgetOpaque

()

enode-remoting/src/main/java/com/qianzhui/enode/remoting/netty/ResponseFuture.java:114

↓ 4 callersMethodgetPublishTopic

(T source)

enode/src/main/java/com/qianzhui/enode/rocketmq/ITopicProvider.java:9

↓ 4 callersMethodgetPullInterval

()

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

↓ 4 callersMethodgetRemoteAddr

()

enode-remoting/src/main/java/com/qianzhui/enode/remoting/netty/NettyEvent.java:36

↓ 4 callersMethodgetServerSelectorThreads

()

enode-remoting/src/main/java/com/qianzhui/enode/remoting/netty/NettyServerConfig.java:57

↓ 4 callersMethodgetServiceState

()

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

↓ 4 callersMethodgetStartDeliverTime

()

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

↓ 4 callersMethodgetTag

()

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

↓ 4 callersMethodgetTaskCompletionSource

()

enode/src/main/java/com/qianzhui/enode/rocketmq/command/CommandResultProcessor.java:179

↓ 4 callersMethodgetTitle

()

samples/notesample/domain/src/main/java/com/qianzhui/enodesamples/notesample/domain/NoteCreated.java:15

↓ 4 callersMethodgetTraceType

()

enode/src/main/java/com/qianzhui/enode/rocketmq/trace/core/common/OnsTraceContext.java:77

↓ 4 callersMethodgetTransKey

()

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

↓ 4 callersMethodhandle

(ICommandContext context, ICommand command)

enode/src/main/java/com/qianzhui/enode/commanding/ICommandHandlerProxy.java:10

↓ 4 callersMethoditems

()

enode/src/main/java/com/qianzhui/enode/eventing/DomainEventStream.java:91

↓ 4 callersMethodnotifyMessageProcessed

()

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

↓ 4 callersMethodprocess

(ProcessingCommand processingCommand)

enode/src/main/java/com/qianzhui/enode/commanding/ICommandProcessor.java:7

↓ 4 callersMethodpublishAsync

(TMessage message)

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

↓ 4 callersMethodpublishDomainEventAsync

(ProcessingCommand processingCommand, DomainEventStream eventStream)

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

↓ 4 callersMethodregisterMessageHandler

(RocketMQMessageHandler handler)

enode/src/main/java/com/qianzhui/enode/rocketmq/RocketMQConsumer.java:30

↓ 4 callersMethodsetConsumerGroup

(String consumerGroup)

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

↓ 4 callersMethodsetCostTime

(int costTime)

enode/src/main/java/com/qianzhui/enode/rocketmq/trace/core/common/OnsTraceContext.java:112

↓ 4 callersMethodsetSendRequestOK

(boolean sendRequestOK)

enode-remoting/src/main/java/com/qianzhui/enode/remoting/netty/ResponseFuture.java:86

↓ 4 callersMethodsignAndBase64Encode

(String data, String key, SigningAlgorithm algorithm)

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

↓ 4 callersMethodstart

()

enode/src/main/java/com/qianzhui/enode/commanding/ICommandProcessor.java:9

↓ 4 callersMethodstart

初始化异步传输数据模块 @param workName 传输模块工作线程名称

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

↓ 4 callersMethodstartTask

(String name, Action action, int dueTime, int period)

enode/src/main/java/com/qianzhui/enode/common/scheduling/IScheduleService.java:9

↓ 4 callersMethodstopTask

(String name)

enode/src/main/java/com/qianzhui/enode/common/scheduling/IScheduleService.java:11

↓ 4 callersMethodtoString

(byte[] b)

enode/src/main/java/com/qianzhui/enode/common/utilities/BitConverter.java:40

↓ 4 callersMethodtryRun

()

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

↓ 4 callersMethodtryRun

()

enode/src/main/java/com/qianzhui/enode/eventing/impl/EventMailBox.java:48

↓ 4 callersMethodupdateContent

(Properties prop)

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

↓ 4 callersMethodwithin

(CompletableFuture<T> future, Duration duration)

enode/src/main/java/com/qianzhui/enode/common/utilities/CompletableFutureUtil.java:31

↓ 3 callersMethodaddExtField

(String key, String value)

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

↓ 3 callersMethodapplyEvent

(IDomainEvent<TAggregateRootId> domainEvent)

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

↓ 3 callersMethodbuildCommandMessage

(ICommand command, boolean needReply)

enode/src/main/java/com/qianzhui/enode/rocketmq/command/CommandService.java:167

↓ 3 callersMethodcommitRegisters

()

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

↓ 3 callersMethodcompleteCommand

(ProcessingCommand processingCommand, CommandResult commandResult)

enode/src/main/java/com/qianzhui/enode/commanding/ProcessingCommandMailbox.java:194

↓ 3 callersMethodcompleteMessage

(X processingMessage)

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

↓ 3 callersMethodcreateResponseCommand

(Class<? extends CommandCustomHeader> classHeader)

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

↓ 3 callersMethoddequeueHandler

()

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

↓ 3 callersMethoddispatchSingleMessageToHandlerAsync

(SingleMessageDispatching singleMessageDispatching, IMessageHandlerProxy1 handlerProxy,

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

↓ 3 callersMethodexecuteInvokeCallback

(final ResponseFuture responseFuture)

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

↓ 3 callersMethodexit

()

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

↓ 3 callersMethodexit

()

enode/src/main/java/com/qianzhui/enode/eventing/impl/EventMailBox.java:99

↓ 3 callersMethodgetAggregateRoot

()

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

↓ 3 callersMethodgetAggregateRootTypeName

()

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

↓ 3 callersMethodgetAndCreateChannel

(final String addr)

enode-remoting/src/main/java/com/qianzhui/enode/remoting/netty/NettyRemotingClient.java:263

↓ 3 callersMethodgetCode

gets and setters

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

↓ 3 callersMethodgetConnectTimeoutMillis

()

enode-remoting/src/main/java/com/qianzhui/enode/remoting/netty/NettyClientConfig.java:67

↓ 3 callersMethodgetConsumeConcurrentlyMaxSpan

()

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

↓ 3 callersMethodgetConsumeMessageBatchMaxSize

()

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

↓ 3 callersMethodgetConsumerStatsManager

()

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

↓ 3 callersMethodgetCreatedOn

()

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

↓ 3 callersMethodgetCurrentVersion

()

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

↓ 3 callersMethodgetDefaultDBConfigurationSetting

()

enode/src/main/java/com/qianzhui/enode/configurations/ConfigurationSetting.java:67

← previous next →101–200 of 1,671, ranked by callers