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

Methoddeserialize

(Map<String, String> data, Class<TEvent> domainEventType)

enode/src/main/java/com/qianzhui/enode/eventing/impl/DefaultEventSerializer.java:37

Methoddeserialize

(String aSerialization, final Class<T> aType)

enode/src/main/java/com/qianzhui/enode/common/serializing/IJsonSerializer.java:9

Methoddisconnect

(ChannelHandlerContext ctx, ChannelPromise promise)

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

MethoddispatchMessageAsync

(IMessage message)

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

MethoddispatchMessagesAsync

(List<? extends IMessage> messages)

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

MethoddispatchProcessingMessageAsync

(ProcessingDomainEventStreamMessage processingMessage)

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

MethoddispatchThreeMessageToHandlerAsync

(MultiMessageDisptaching multiMessageDispatching, IMessageHandlerProxy3 handlerProxy, QueuedHandler<IMessageHa

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

MethoddispatchTwoMessageToHandlerAsync

(MultiMessageDisptaching multiMessageDispatching, IMessageHandlerProxy2 handlerProxy, QueuedHandler<IMessageHa

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

MethoddoAfterResponse

(String remoteAddr, RemotingCommand request, RemotingCommand response)

enode/src/main/java/com/qianzhui/enode/rocketmq/client/ons/ClientRPCHook.java:31

MethoddoBeforeRequest

(String remoteAddr, RemotingCommand request)

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

MethoddoRebalance

()

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

MethodearliestMsgStoreTime

(MessageQueue mq)

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

MethodearliestMsgStoreTime

(MessageQueue mq)

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

MethodeatException

(Action action)

enode/src/main/java/com/qianzhui/enode/common/utilities/Helper.java:10

Methodencode

()

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

Methodequal

(int expected, int actual, String argumentName)

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

MethodexceptionCaught

(ChannelHandlerContext ctx, Throwable cause)

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

MethodexceptionCaught

(ChannelHandlerContext ctx, Throwable cause)

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

Methodexecute

(ICommand command, int timeoutMillis)

enode/src/main/java/com/qianzhui/enode/commanding/ICommandService.java:18

Methodexecute

(ICommand command, int timeoutMillis)

enode/src/main/java/com/qianzhui/enode/commanding/impl/NotImplementedCommandService.java:30

Methodexecute

(ICommand command, int timeoutMillis)

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

MethodexecuteAsync

(String sql, Object... params)

enode/src/main/java/com/qianzhui/enode/infrastructure/impl/AbstractDenormalizer.java:21

MethodexecuteAsync

(ICommand command)

enode/src/main/java/com/qianzhui/enode/commanding/impl/NotImplementedCommandService.java:40

MethodexecuteInLock

(String lockKey, Action action)

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

MethodexecuteInLock

(String lockKey, Action action)

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

MethodexecuteInvokeCallback

()

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

MethodfetchNameServerAddr

()

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

MethodfetchSubscribeMessageQueues

(String topic)

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

MethodfetchSubscribeMessageQueues

(String topic)

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

MethodfindAsync

(String aggregateRootId, int version)

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

MethodfindAsync

(String aggregateRootId, int version)

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

Methodflush

实际写数据操作

enode/src/main/java/com/qianzhui/enode/rocketmq/trace/core/dispatch/AsyncAppender.java:17

Methodflush

实际批量发送数据

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

MethodfromJson

(String json, Class<T> classOfT)

enode/src/main/java/com/qianzhui/enode/rocketmq/trace/core/utils/MixUtils.java:86

Methodget

(Class<T> aggregateRootType, String aggregateRootId)

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

Methodget

(String aggregateRootId)

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

Methodget

Get an aggregate from memory cache. @param aggregateRootId @param aggregateRootType @param <T> @return

enode/src/main/java/com/qianzhui/enode/domain/IMemoryCache.java:15

Methodget

(String aggregateRootId)

enode/src/main/java/com/qianzhui/enode/domain/impl/AggregateRepositoryProxy.java:21

Methodget

(Class<T> aggregateRootType, String aggregateRootId)

enode/src/main/java/com/qianzhui/enode/domain/impl/SnapshotOnlyAggregateStorage.java:20

Methodget

(Class<T> aggregateRootType, String aggregateRootId)

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

Methodget

(Class<T> aggregateRootType, Object aggregateRootId)

enode/src/main/java/com/qianzhui/enode/domain/impl/DefaultRepository.java:23

Methodget

(Object aggregateRootId, Class aggregateRootType)

enode/src/main/java/com/qianzhui/enode/domain/impl/DefaultMemoryCache.java:44

Methodget

(Class<T> aggregateRootType, Object id)

enode/src/main/java/com/qianzhui/enode/rocketmq/command/CommandConsumer.java:145

MethodgetAction

()

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

MethodgetActiveThreadCount

()

enode/src/main/java/com/qianzhui/enode/jmx/ForkJoinPool.java:12

MethodgetAggregateRootId

()

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

MethodgetAggregateRootId

()

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

MethodgetAggregateRootId

()

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

MethodgetAggregateRootId

()

enode/src/main/java/com/qianzhui/enode/commanding/HandledCommand.java:35

MethodgetAggregateRootId

()

enode/src/main/java/com/qianzhui/enode/commanding/CommandResult.java:42

MethodgetAggregateRootId

()

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

MethodgetAggregateRootId

()

enode/src/main/java/com/qianzhui/enode/commanding/impl/CommandRecord.java:35

MethodgetAggregateRootId

()

enode/src/main/java/com/qianzhui/enode/rocketmq/domainevent/DomainEventHandledMessage.java:19

MethodgetAggregateRootId

()

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

MethodgetAggregateRootTypeName

()

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

MethodgetAggregateRootTypeName

()

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

MethodgetAllSubscribeTopics

()

samples/notesample/quickstart/src/main/java/com/qianzhui/enodesamples/quickstart/providers/EventTopicProvider.java:19

MethodgetAllSubscribeTopics

()

samples/notesample/quickstart/src/main/java/com/qianzhui/enodesamples/quickstart/providers/CommandTopicProvider.java:19

MethodgetAllSubscribeTopics

()

samples/notesample/quickstart/src/main/java/com/qianzhui/enodesamples/quickstart/providers/ExceptionTopicProvider.java:19

MethodgetAllSubscribeTopics

()

enode/src/main/java/com/qianzhui/enode/rocketmq/AbstractTopicProvider.java:19

MethodgetAllTypes

()

enode/src/main/java/com/qianzhui/enode/rocketmq/AbstractTopicProvider.java:24

MethodgetArray

()

enode/src/main/java/com/qianzhui/enode/common/extensions/ByteArraySegment.java:34

MethodgetArray

()

enode/src/main/java/com/qianzhui/enode/common/extensions/ArraySegment.java:33

MethodgetChanges

()

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

MethodgetChannelEventListener

()

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

MethodgetChannelEventListener

()

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

MethodgetChannelNotActiveInterval

()

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

MethodgetClientCallbackExecutorThreads

()

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

MethodgetClientHost

()

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

MethodgetCommandId

()

enode/src/main/java/com/qianzhui/enode/commanding/HandledCommand.java:31

MethodgetCommandId

()

enode/src/main/java/com/qianzhui/enode/commanding/CommandResult.java:38

MethodgetCommandId

()

enode/src/main/java/com/qianzhui/enode/commanding/impl/CommandRecord.java:27

MethodgetCommandId

()

enode/src/main/java/com/qianzhui/enode/eventing/DomainEventStreamMessage.java:44

MethodgetCommandId

()

enode/src/main/java/com/qianzhui/enode/rocketmq/domainevent/DomainEventHandledMessage.java:11

MethodgetCommandTableCommandIdUniqueIndexName

()

enode/src/main/java/com/qianzhui/enode/configurations/DefaultDBConfigurationSetting.java:139

MethodgetCommandTableName

()

enode/src/main/java/com/qianzhui/enode/configurations/DefaultDBConfigurationSetting.java:83

MethodgetCommonPoolParallelism

()

enode/src/main/java/com/qianzhui/enode/jmx/ForkJoinPool.java:17

MethodgetConnectionString

()

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

MethodgetConsumeMessageService

()

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

MethodgetConsumer

()

enode/src/main/java/com/qianzhui/enode/rocketmq/applicationmessage/ApplicationMessageConsumer.java:80

MethodgetConsumer

()

enode/src/main/java/com/qianzhui/enode/rocketmq/command/CommandConsumer.java:41

MethodgetConsumer

()

enode/src/main/java/com/qianzhui/enode/rocketmq/publishableexceptions/PublishableExceptionConsumer.java:84

MethodgetContextCode

()

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

MethodgetCount

()

enode/src/main/java/com/qianzhui/enode/common/extensions/ByteArraySegment.java:42

MethodgetCount

()

enode/src/main/java/com/qianzhui/enode/common/extensions/ArraySegment.java:41

MethodgetCreatedOn

()

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

MethodgetCreatedOn

()

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

MethodgetCreatedOn

()

enode/src/main/java/com/qianzhui/enode/commanding/impl/CommandRecord.java:59

MethodgetCreationTime

()

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

MethodgetEnqueueTimestamp

()

enode/src/main/java/com/qianzhui/enode/commanding/ProcessingCommand.java:56

MethodgetEvents

()

enode/src/main/java/com/qianzhui/enode/eventing/DomainEventStreamMessage.java:60

MethodgetHandlerProxyImplementationType

()

enode/src/main/java/com/qianzhui/enode/infrastructure/impl/DefaultTwoMessageHandlerProvider.java:35

MethodgetHandlerProxyImplementationType

()

enode/src/main/java/com/qianzhui/enode/infrastructure/impl/DefaultThreeMessageHandlerProvider.java:35

MethodgetHandlerProxyImplementationType

()

enode/src/main/java/com/qianzhui/enode/infrastructure/impl/DefaultMessageHandlerProvider.java:33

MethodgetHandlerProxyImplementationType

()

enode/src/main/java/com/qianzhui/enode/commanding/impl/DefaultCommandAsyncHandlerProvider.java:31

MethodgetHandlerProxyImplementationType

()

enode/src/main/java/com/qianzhui/enode/commanding/impl/DefaultCommandHandlerProvider.java:31

MethodgetHandlerType

()

enode/src/main/java/com/qianzhui/enode/infrastructure/impl/DefaultTwoMessageHandlerProvider.java:25

MethodgetHandlerType

()

enode/src/main/java/com/qianzhui/enode/infrastructure/impl/DefaultThreeMessageHandlerProvider.java:25

MethodgetHandlerType

()

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

MethodgetHandlerType

()

enode/src/main/java/com/qianzhui/enode/commanding/impl/DefaultCommandAsyncHandlerProvider.java:21

← previous next →1,001–1,100 of 1,671, ranked by callers