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

↓ 1 callersMethodappendUncommittedEvent

(IDomainEvent<TAggregateRootId> domainEvent)

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

↓ 1 callersMethodappends

(DomainEventStream eventStream)

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

↓ 1 callersMethodbatchAppend

(List<DomainEventStream> eventStreams)

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

↓ 1 callersMethodbatchPersistEventAsync

(List<EventCommittingContext> committingContexts)

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

↓ 1 callersMethodbuildDomainEventStream

(IAggregateRoot aggregateRoot, List<IDomainEvent> changedEvents, ProcessingCommand processingCommand)

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

↓ 1 callersMethodbuildRocketMQMessageKey

(ICommand command)

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

↓ 1 callersMethodbuildRocketMQMessageKey

(DomainEventStreamMessage eventStreamMessage)

enode/src/main/java/com/qianzhui/enode/rocketmq/domainevent/DomainEventPublisher.java:76

↓ 1 callersMethodcalSignature

(String data, String key)

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

↓ 1 callersMethodcalSignature

(byte[] data, String secretKey)

enode/src/main/java/com/qianzhui/enode/rocketmq/client/ons/AuthUtil.java:41

↓ 1 callersMethodcalTotalLen

(int remark, int ext)

enode-remoting/src/main/java/com/qianzhui/enode/remoting/protocol/RemotingCommandSerialable.java:100

↓ 1 callersMethodchangeTitle

(String title)

samples/notesample/domain/src/main/java/com/qianzhui/enodesamples/notesample/domain/Note.java:24

↓ 1 callersMethodcheckConfig

()

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

↓ 1 callersMethodcheckFields

()

enode-remoting/src/main/java/com/qianzhui/enode/remoting/CommandCustomHeader.java:9

↓ 1 callersMethodclear

()

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

↓ 1 callersMethodcombineBytes

(byte[] b1, byte[] b2)

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

↓ 1 callersMethodcombineRequestContent

(RemotingCommand request, SortedMap<String, String> fieldsMap)

enode/src/main/java/com/qianzhui/enode/rocketmq/client/ons/AuthUtil.java:14

↓ 1 callersMethodcommitAggregateChanges

(ProcessingCommand processingCommand)

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

↓ 1 callersMethodcommitDomainEventAsync

Commit the given aggregate's domain events to the eventstore async and publish the domain events. @param context

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

↓ 1 callersMethodcomputeAccumulationTotal

()

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

↓ 1 callersMethodconnect

(SocketAddress remote)

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

↓ 1 callersMethodconnect

(ChannelHandlerContext ctx, SocketAddress remoteAddress, SocketAddress localAddress,

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

↓ 1 callersMethodconsumeMessageAfter

(ConsumeMessageContext context)

enode/src/main/java/com/qianzhui/enode/rocketmq/trace/core/utils/OnsConsumeMessageHookImpl.java:76

↓ 1 callersMethodconsumeMessageBefore

(ConsumeMessageContext context)

enode/src/main/java/com/qianzhui/enode/rocketmq/trace/core/utils/OnsConsumeMessageHookImpl.java:34

↓ 1 callersMethodconvertTo

(DomainEventStream eventStream)

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

↓ 1 callersMethodconvertToDomainEventStream

(EventStreamMessage message)

enode/src/main/java/com/qianzhui/enode/rocketmq/domainevent/DomainEventConsumer.java:83

↓ 1 callersMethodcopySubscription

()

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

↓ 1 callersMethodcreate

(String... packages)

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

↓ 1 callersMethodcreate

(T e)

enode/src/main/java/com/qianzhui/enode/infrastructure/WrappedExceptionParser.java:12

↓ 1 callersMethodcreateAggregateRoot

Create an empty aggregate root with the given type. @param aggregateRootType @param <T> @return

enode/src/main/java/com/qianzhui/enode/domain/IAggregateRootFactory.java:16

↓ 1 callersMethodcreateChannel

(final String addr)

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

↓ 1 callersMethodcreateEQueueMessage

(IApplicationMessage message)

enode/src/main/java/com/qianzhui/enode/rocketmq/applicationmessage/ApplicationMessagePublisher.java:60

↓ 1 callersMethodcreateEQueueMessage

(IPublishableException exception)

enode/src/main/java/com/qianzhui/enode/rocketmq/publishableexceptions/PublishableExceptionPublisher.java:57

↓ 1 callersMethodcreateEventMessage

(DomainEventStreamMessage eventStream)

enode/src/main/java/com/qianzhui/enode/rocketmq/domainevent/DomainEventPublisher.java:84

↓ 1 callersMethodcreateLogger

(final String loggerName)

enode/src/main/java/com/qianzhui/enode/common/logging/ENodeLogger.java:16

↓ 1 callersMethodcreateProducer

(final Properties properties)

enode/src/main/java/com/qianzhui/enode/rocketmq/client/RocketMQFactory.java:9

↓ 1 callersMethodcreatePushConsumer

(final Properties properties)

enode/src/main/java/com/qianzhui/enode/rocketmq/client/RocketMQFactory.java:11

↓ 1 callersMethodcreateRequestCommand

(int code, CommandCustomHeader customHeader)

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

↓ 1 callersMethodcreateRocketMQMessage

(DomainEventStreamMessage eventStream)

enode/src/main/java/com/qianzhui/enode/rocketmq/domainevent/DomainEventPublisher.java:61

↓ 1 callersMethoddecCorePoolSize

()

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

↓ 1 callersMethoddecodeHeader

(final byte[] headerArray)

enode-remoting/src/main/java/com/qianzhui/enode/remoting/protocol/RemotingCommandSerialable.java:116

↓ 1 callersMethoddispatchMessageAsync

(IMessage message)

enode/src/main/java/com/qianzhui/enode/infrastructure/IMessageDispatcher.java:12

↓ 1 callersMethoddispatchMessagesAsync

(List<? extends IMessage> messages)

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

↓ 1 callersMethoddispatchProcessingMessageAsync

(X processingMessage)

enode/src/main/java/com/qianzhui/enode/infrastructure/impl/AbstractSequenceProcessingMessageHandler.java:29

↓ 1 callersMethoddoAppend

(final DomainEventStream eventStream)

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

↓ 1 callersMethoddoDispatchProcessingMessageAsync

(X processingMessage)

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

↓ 1 callersMethoddoRetry

()

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

↓ 1 callersMethodelze

(Consumer<T> consumer)

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

↓ 1 callersMethodencode

(ChannelHandlerContext ctx, RemotingCommand remotingCommand, ByteBuf out)

enode-remoting/src/main/java/com/qianzhui/enode/remoting/netty/NettyEncoder.java:33

↓ 1 callersMethodencodeHeader

()

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

↓ 1 callersMethodencodeHeader

(RemotingCommand cmd)

enode-remoting/src/main/java/com/qianzhui/enode/remoting/protocol/RemotingCommandSerialable.java:15

↓ 1 callersMethodenqueueMessage

(X processingMessage)

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

↓ 1 callersMethodenqueueMessage

(ProcessingCommand message)

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

↓ 1 callersMethodenqueueMessage

(EventCommittingContext message)

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

↓ 1 callersMethodexecute

()

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

↓ 1 callersMethodexecute

()

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

↓ 1 callersMethodexecute

()

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

↓ 1 callersMethodexecuteHookAfter

(final ConsumeMessageContext context)

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

↓ 1 callersMethodexecuteHookBefore

(final ConsumeMessageContext context)

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

↓ 1 callersMethodexecuteSuccessAction

(TAsyncResult result)

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

↓ 1 callersMethodexecuteTaskLater

(final Runnable r, final long timeDelay)

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

↓ 1 callersMethodexit

()

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

↓ 1 callersMethodexitEditing

()

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

↓ 1 callersMethodfailAfter

(Duration duration)

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

↓ 1 callersMethodfetchNameServerAddr

()

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

↓ 1 callersMethodflush

强制调用写操作 @throws IOException

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

↓ 1 callersMethodflush

()

enode/src/main/java/com/qianzhui/enode/rocketmq/trace/core/dispatch/impl/AsyncTraceDispatcher.java:115

↓ 1 callersMethodflush

()

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

↓ 1 callersMethodflushData

实际批量发送数据

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

↓ 1 callersMethodgenerateNewId

()

enode/src/main/java/com/qianzhui/enode/common/utilities/ObjectId.java:81

↓ 1 callersMethodget

(String aggregateRootId)

enode/src/main/java/com/qianzhui/enode/domain/IAggregateRepositoryProxy.java:9

↓ 1 callersMethodget

(Type type)

enode/src/main/java/com/qianzhui/enode/common/container/GenericTypeLiteral.java:28

↓ 1 callersMethodgetAckIndex

()

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

↓ 1 callersMethodgetAdjustThreadPoolNumsThreshold

()

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

↓ 1 callersMethodgetAggregateRoot

()

enode/src/main/java/com/qianzhui/enode/domain/AggregateCacheInfo.java:19

↓ 1 callersMethodgetAggregateRootId

()

enode/src/main/java/com/qianzhui/enode/commanding/Command.java:24

↓ 1 callersMethodgetAggregateRootId

()

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

↓ 1 callersMethodgetAggregateRootTypeName

()

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

↓ 1 callersMethodgetApplicationMessageData

()

enode/src/main/java/com/qianzhui/enode/rocketmq/applicationmessage/ApplicationDataMessage.java:15

↓ 1 callersMethodgetApplicationMessageType

()

enode/src/main/java/com/qianzhui/enode/rocketmq/applicationmessage/ApplicationDataMessage.java:23

↓ 1 callersMethodgetBeginTimestamp

()

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

↓ 1 callersMethodgetBindingAddress

()

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

↓ 1 callersMethodgetBodyLength

()

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

↓ 1 callersMethodgetChannelEventListener

Custom channel event listener. @return custom channel event listener if defined; null otherwise.

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

↓ 1 callersMethodgetClientAsyncSemaphoreValue

()

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

↓ 1 callersMethodgetClientChannelMaxIdleTimeSeconds

()

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

↓ 1 callersMethodgetClientOnewaySemaphoreValue

()

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

↓ 1 callersMethodgetClientSocketRcvBufSize

()

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

↓ 1 callersMethodgetClientSocketSndBufSize

()

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

↓ 1 callersMethodgetClientWorkerThreads

()

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

↓ 1 callersMethodgetCommandData

()

enode/src/main/java/com/qianzhui/enode/rocketmq/command/CommandMessage.java:17

↓ 1 callersMethodgetCommandMailBoxPersistenceMaxBatchSize

()

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

↓ 1 callersMethodgetCommandType

()

enode/src/main/java/com/qianzhui/enode/rocketmq/command/CommandMessage.java:33

↓ 1 callersMethodgetCommonPoolParallelism

()

enode/src/main/java/com/qianzhui/enode/jmx/ForkJoinPoolMBean.java:9

↓ 1 callersMethodgetConsumeTimestamp

()

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

↓ 1 callersMethodgetContainer

()

enode/src/main/java/com/qianzhui/enode/common/container/AbstractContainer.java:18

↓ 1 callersMethodgetCurrentProcessId

()

enode/src/main/java/com/qianzhui/enode/common/utilities/ObjectId.java:171

↓ 1 callersMethodgetDefaultMQPushConsumer

()

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

↓ 1 callersMethodgetDefaultMQPushConsumerImpl

()

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

↓ 1 callersMethodgetDelayLevelWhenNextConsume

()

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

↓ 1 callersMethodgetDueTime

()

enode/src/main/java/com/qianzhui/enode/common/scheduling/ScheduleService.java:120

← previous next →401–500 of 1,671, ranked by callers