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
↓ 1 callersMethodisWritable
()
enode-remoting/src/main/java/com/qianzhui/enode/remoting/netty/NettyRemotingClient.java:401
↓ 1 callersMethodlockKey
(Connection connection, String key)
enode/src/main/java/com/qianzhui/enode/infrastructure/impl/mysql/MysqlLockService.java:101
↓ 1 callersMethodmakeCustomHeaderToNet
()
enode-remoting/src/main/java/com/qianzhui/enode/remoting/protocol/RemotingCommand.java:282
↓ 1 callersMethodmapDeserialize
(byte[] bytes)
enode-remoting/src/main/java/com/qianzhui/enode/remoting/protocol/RemotingCommandSerialable.java:143
↓ 1 callersMethodmapSerialize
(HashMap<String, String> map)
enode-remoting/src/main/java/com/qianzhui/enode/remoting/protocol/RemotingCommandSerialable.java:59
↓ 1 callersMethodmarkOnewayRPC
()
enode-remoting/src/main/java/com/qianzhui/enode/remoting/protocol/RemotingCommand.java:335
↓ 1 callersMethodonChannelClose
(final String remoteAddr, final Channel channel)
enode-remoting/src/main/java/com/qianzhui/enode/remoting/ChannelEventListener.java:24
↓ 1 callersMethodonChannelConnect
(final String remoteAddr, final Channel channel)
enode-remoting/src/main/java/com/qianzhui/enode/remoting/ChannelEventListener.java:22
↓ 1 callersMethodonChannelException
(final String remoteAddr, final Channel channel)
enode-remoting/src/main/java/com/qianzhui/enode/remoting/ChannelEventListener.java:26
↓ 1 callersMethodonChannelIdle
(final String remoteAddr, final Channel channel)
enode-remoting/src/main/java/com/qianzhui/enode/remoting/ChannelEventListener.java:28
↓ 1 callersMethodonCommandExecuted
(CommandResult commandResult)
enode/src/main/java/com/qianzhui/enode/commanding/ICommandExecuteContext.java:7
↓ 1 callersMethodoperationComplete
(final ResponseFuture responseFuture)
enode-remoting/src/main/java/com/qianzhui/enode/remoting/InvokeCallback.java:23
↓ 1 callersMethodpack
(long timestamp, int machine, short pid, int increment)
enode/src/main/java/com/qianzhui/enode/common/utilities/ObjectId.java:98
↓ 1 callersMethodparseAddress
(SocketAddress address)
enode/src/main/java/com/qianzhui/enode/rocketmq/command/CommandService.java:211
↓ 1 callersMethodparseCheckCommandHandledFirst
()
enode/src/main/java/com/qianzhui/enode/commanding/impl/CommandAsyncHandlerProxy.java:58
↓ 1 callersMethodparseComponentLife
(Class type)
enode/src/main/java/com/qianzhui/enode/ENode.java:301
↓ 1 callersMethodparseComponentLife
(Class type)
enode/src/main/java/com/qianzhui/enode/infrastructure/impl/AbstractHandlerProvider.java:141
↓ 1 callersMethodparseRequestContent
(RemotingCommand request, String ak, String onsChannel)
enode/src/main/java/com/qianzhui/enode/rocketmq/client/ons/AbstractRPCHook.java:23
↓ 1 callersMethodpause
()
enode/src/main/java/com/qianzhui/enode/commanding/ProcessingCommandMailbox.java:74
↓ 1 callersMethodpersistConsumerOffset
()
enode/src/main/java/com/qianzhui/enode/common/rocketmq/impl/consumer/CompletableDefaultMQPushConsumerImpl.java:240
↓ 1 callersMethodpersistEvent
(EventCommittingContext context)
enode/src/main/java/com/qianzhui/enode/eventing/impl/DefaultEventService.java:140
↓ 1 callersMethodprocessConsumeResult
(// final ConsumeConcurrentlyStatus status, //
enode/src/main/java/com/qianzhui/enode/common/rocketmq/impl/consumer/CompletableConsumeMessageConcurrentlyService.java:221
↓ 1 callersMethodprocessDomainEventHandledMessage
(DomainEventHandledMessage message)
enode/src/main/java/com/qianzhui/enode/rocketmq/command/CommandResultProcessor.java:151
↓ 1 callersMethodprocessExecutedCommandMessage
(CommandResult commandResult)
enode/src/main/java/com/qianzhui/enode/rocketmq/command/CommandResultProcessor.java:130
↓ 1 callersMethodprocessFailedSendingCommand
(ICommand command)
enode/src/main/java/com/qianzhui/enode/rocketmq/command/CommandResultProcessor.java:73
↓ 1 callersMethodprocessIfNoEventsOfCommand
(ProcessingCommand processingCommand)
enode/src/main/java/com/qianzhui/enode/commanding/impl/DefaultProcessingCommandHandler.java:180
↓ 1 callersMethodprocessNextCompletedCommands
(long baseSequence)
enode/src/main/java/com/qianzhui/enode/commanding/ProcessingCommandMailbox.java:174
↓ 1 callersMethodprocessRequest
(ChannelHandlerContext ctx, RemotingCommand request)
enode-remoting/src/main/java/com/qianzhui/enode/remoting/netty/NettyRequestProcessor.java:26
↓ 1 callersMethodprocessRequestCommand
Process incoming request command issued by remote peer. @param ctx channel handler context. @param cmd request command.
enode-remoting/src/main/java/com/qianzhui/enode/remoting/netty/NettyRemotingAbstract.java:134
↓ 1 callersMethodprocessResponseCommand
Process response from remote peer to the previous issued requests. @param ctx channel handler context. @param cmd response command instance.
enode-remoting/src/main/java/com/qianzhui/enode/remoting/netty/NettyRemotingAbstract.java:194
↓ 1 callersMethodprocessTaskException
(Throwable exception)
enode/src/main/java/com/qianzhui/enode/common/io/IOHelper.java:258
↓ 1 callersMethodpublishDomainEventAsyncRecursively
(ProcessingCommand processingCommand, DomainEventStreamMessage eventStream)
enode/src/main/java/com/qianzhui/enode/eventing/impl/DefaultEventService.java:290
↓ 1 callersMethodpublishExceptionAsync
(ProcessingCommand processingCommand, IPublishableException exception)
enode/src/main/java/com/qianzhui/enode/commanding/impl/DefaultProcessingCommandHandler.java:253
↓ 1 callersMethodpublishMessageAsync
(ProcessingCommand processingCommand, IApplicationMessage message)
enode/src/main/java/com/qianzhui/enode/commanding/impl/DefaultProcessingCommandHandler.java:361
↓ 1 callersMethodqueryAggregateEvents
(String aggregateRootId, String aggregateRootTypeName, int minVersion, int maxVersion)
enode/src/main/java/com/qianzhui/enode/eventing/impl/InMemoryEventStore.java:40
↓ 1 callersMethodqueryAggregateEventsAsync
(String aggregateRootId, String aggregateRootTypeName, int minVersion, int maxVersion)
enode/src/main/java/com/qianzhui/enode/eventing/IEventStore.java:24
↓ 1 callersMethodreadCustomHeader
()
enode-remoting/src/main/java/com/qianzhui/enode/remoting/protocol/RemotingCommand.java:327
↓ 1 callersMethodrebuildAggregateRoot
(Class<T> aggregateRootType, List<DomainEventStream> eventStreams)
enode/src/main/java/com/qianzhui/enode/domain/impl/EventSourcingAggregateStorage.java:97
↓ 1 callersMethodrefreshAggregateFromEventStore
Refresh the aggregate memory cache by replaying events of event store. @param aggregateRootTypeName @param aggregateRootId
enode/src/main/java/com/qianzhui/enode/domain/IMemoryCache.java:30
↓ 1 callersMethodrefreshAggregateMemoryCache
(EventCommittingContext context)
enode/src/main/java/com/qianzhui/enode/eventing/impl/DefaultEventService.java:273
↓ 1 callersMethodrefreshAggregateMemoryCacheToLatestVersion
(String aggregateRootTypeName, String aggregateRootId)
enode/src/main/java/com/qianzhui/enode/eventing/impl/DefaultEventService.java:282
↓ 1 callersMethodregisterBusinessComponents
()
enode/src/main/java/com/qianzhui/enode/ENode.java:241
↓ 1 callersMethodregisterCommonComponents
()
enode/src/main/java/com/qianzhui/enode/ENode.java:141
↓ 1 callersMethodregisterConsumeMessageHook
(final ConsumeMessageHook hook)
enode/src/main/java/com/qianzhui/enode/common/rocketmq/impl/consumer/CompletableDefaultMQPushConsumerImpl.java:110
↓ 1 callersMethodregisterDefaultComponents
()
enode/src/main/java/com/qianzhui/enode/ENode.java:348
↓ 1 callersMethodregisterENodeComponents
()
enode/src/main/java/com/qianzhui/enode/ENode.java:151
↓ 1 callersMethodregisterENodeGenericComponentType
(Class type)
enode/src/main/java/com/qianzhui/enode/ENode.java:290
↓ 1 callersMethodregisterFilterMessageHook
(final FilterMessageHook hook)
enode/src/main/java/com/qianzhui/enode/common/rocketmq/impl/consumer/CompletableDefaultMQPushConsumerImpl.java:88
↓ 1 callersMethodregisterInternalHandler
(Class aggregateRootType, Class eventType, Method method)
enode/src/main/java/com/qianzhui/enode/domain/impl/DefaultAggregateRootInternalHandlerProvider.java:70
↓ 1 callersMethodregisterInternalHandlerWithSuperclass
(Class aggregateRootType, Class parentType)
enode/src/main/java/com/qianzhui/enode/domain/impl/DefaultAggregateRootInternalHandlerProvider.java:44
↓ 1 callersMethodregisterProcessingCommand
(ICommand command, CommandReturnType commandReturnType, CompletableFuture<AsyncTaskResult<CommandResult>> task
enode/src/main/java/com/qianzhui/enode/rocketmq/command/CommandResultProcessor.java:65
↓ 1 callersMethodregisterShutDownHook
()
enode/src/main/java/com/qianzhui/enode/rocketmq/trace/core/dispatch/impl/AsyncArrayDispatcher.java:128
↓ 1 callersMethodregisterShutdownHook
()
enode/src/main/java/com/qianzhui/enode/rocketmq/trace/core/dispatch/impl/AsyncTraceDispatcher.java:145
↓ 1 callersMethodrejectRequest
()
enode-remoting/src/main/java/com/qianzhui/enode/remoting/netty/NettyRequestProcessor.java:29
↓ 1 callersMethodremoveShutDownHook
()
enode/src/main/java/com/qianzhui/enode/rocketmq/trace/core/dispatch/impl/AsyncTraceDispatcher.java:167
↓ 1 callersMethodrepublishUnpublishedEvent
(DomainEventStreamMessage eventStreamMessage)
enode/src/main/java/com/qianzhui/enode/domain/impl/EventSourcingAggregateStorage.java:140
↓ 1 callersMethodrepublishUnpublishedEvents
(IAggregateRoot aggregateRoot, int publishedVersion)
enode/src/main/java/com/qianzhui/enode/domain/impl/EventSourcingAggregateStorage.java:124
↓ 1 callersMethodresetConsumingSequence
(long consumingSequence)
enode/src/main/java/com/qianzhui/enode/commanding/ProcessingCommandMailbox.java:93
↓ 1 callersMethodrestoreFrom
(Map<String, String> serializableInfo)
enode/src/main/java/com/qianzhui/enode/infrastructure/IPublishableException.java:11
↓ 1 callersMethodresult
()
enode/src/main/java/com/qianzhui/enode/eventing/impl/InMemoryEventStore.java:108
↓ 1 callersMethodresume
()
enode/src/main/java/com/qianzhui/enode/commanding/ProcessingCommandMailbox.java:86
↓ 1 callersMethodscanAssemblyTypes
()
enode/src/main/java/com/qianzhui/enode/ENode.java:541
↓ 1 callersMethodscheduleMailbox
(ProcessingMessageMailbox<X, Y> mailbox)
enode/src/main/java/com/qianzhui/enode/infrastructure/IProcessingMessageScheduler.java:9
↓ 1 callersMethodsearchOffset
(MessageQueue mq, long timestamp)
enode/src/main/java/com/qianzhui/enode/common/rocketmq/impl/consumer/CompletableDefaultMQPushConsumerImpl.java:569
↓ 1 callersMethodsend
(ICommand command)
enode/src/main/java/com/qianzhui/enode/commanding/ICommandService.java:16
↓ 1 callersMethodsendMessage
(Producer producer, Message message, String routingKey, String messageId, String version)
enode/src/main/java/com/qianzhui/enode/rocketmq/SendQueueMessageService.java:32
↓ 1 callersMethodsendMessageBack
(final MessageExt msg, final CompletableConsumeConcurrentlyContext context)
enode/src/main/java/com/qianzhui/enode/common/rocketmq/impl/consumer/CompletableConsumeMessageConcurrentlyService.java:205
↓ 1 callersMethodsendTraceData
往消息缓冲区编码轨迹数据 @param contextList
enode/src/main/java/com/qianzhui/enode/rocketmq/trace/core/dispatch/impl/AsyncArrayDispatcher.java:207
↓ 1 callersMethodserialize
(Object obj)
enode/src/main/java/com/qianzhui/enode/common/serializing/IJsonSerializer.java:7
↓ 1 callersMethodsetAggregateRoot
(IAggregateRoot aggregateRoot)
enode/src/main/java/com/qianzhui/enode/domain/AggregateCacheInfo.java:23
↓ 1 callersMethodsetAggregateRootId
(String aggregateRootId)
enode/src/main/java/com/qianzhui/enode/rocketmq/publishableexceptions/PublishableExceptionMessage.java:29
↓ 1 callersMethodsetAggregateRootId
(String aggregateRootId)
enode/src/main/java/com/qianzhui/enode/rocketmq/domainevent/DomainEventHandledMessage.java:23
↓ 1 callersMethodsetAggregateRootId
(String aggregateRootId)
enode/src/main/java/com/qianzhui/enode/rocketmq/domainevent/EventStreamMessage.java:31
↓ 1 callersMethodsetAggregateRootStringId
(String aggregateRootStringId)
enode/src/main/java/com/qianzhui/enode/infrastructure/ISequenceMessage.java:9
↓ 1 callersMethodsetAggregateRootTypeName
(String aggregateRootTypeName)
enode/src/main/java/com/qianzhui/enode/rocketmq/publishableexceptions/PublishableExceptionMessage.java:37
↓ 1 callersMethodsetAggregateRootTypeName
(String aggregateRootTypeName)
enode/src/main/java/com/qianzhui/enode/rocketmq/domainevent/EventStreamMessage.java:39
↓ 1 callersMethodsetAllocateMessageQueueStrategy
(AllocateMessageQueueStrategy allocateMessageQueueStrategy)
enode/src/main/java/com/qianzhui/enode/common/rocketmq/consumer/CompletableDefaultMQPushConsumer.java:197
↓ 1 callersMethodsetBody
(byte[] body)
enode-remoting/src/main/java/com/qianzhui/enode/remoting/protocol/RemotingCommand.java:395
↓ 1 callersMethodsetCause
(Throwable cause)
enode-remoting/src/main/java/com/qianzhui/enode/remoting/netty/ResponseFuture.java:102
↓ 1 callersMethodsetClientChannelMaxIdleTimeSeconds
(int clientChannelMaxIdleTimeSeconds)
enode-remoting/src/main/java/com/qianzhui/enode/remoting/netty/NettyClientConfig.java:103
↓ 1 callersMethodsetCommandId
(String commandId)
enode/src/main/java/com/qianzhui/enode/rocketmq/domainevent/DomainEventHandledMessage.java:15
↓ 1 callersMethodsetCommandId
(String commandId)
enode/src/main/java/com/qianzhui/enode/rocketmq/domainevent/EventStreamMessage.java:63
↓ 1 callersMethodsetCommandResult
(String commandResult)
enode/src/main/java/com/qianzhui/enode/rocketmq/domainevent/DomainEventHandledMessage.java:31
↓ 1 callersMethodsetConsumeThreadMax
(int consumeThreadMax)
enode/src/main/java/com/qianzhui/enode/common/rocketmq/consumer/CompletableDefaultMQPushConsumer.java:247
↓ 1 callersMethodsetConsumeThreadMin
(int consumeThreadMin)
enode/src/main/java/com/qianzhui/enode/common/rocketmq/consumer/CompletableDefaultMQPushConsumer.java:257
↓ 1 callersMethodsetContextCode
(final int contextCode)
enode/src/main/java/com/qianzhui/enode/rocketmq/trace/core/common/OnsTraceContext.java:53
↓ 1 callersMethodsetCurrentVersion
(int currentVersion)
enode/src/main/java/com/qianzhui/enode/eventing/impl/InMemoryEventStore.java:195
↓ 1 callersMethodsetEnqueueTime
(Date enqueueTime)
enode/src/main/java/com/qianzhui/enode/commanding/ProcessingCommand.java:60
↓ 1 callersMethodsetEventMailBox
(EventMailBox eventMailBox)
enode/src/main/java/com/qianzhui/enode/eventing/EventCommittingContext.java:39
↓ 1 callersMethodsetEvents
(Map<String, String> events)
enode/src/main/java/com/qianzhui/enode/rocketmq/domainevent/EventStreamMessage.java:71
↓ 1 callersMethodsetExceptionType
(String exceptionType)
enode/src/main/java/com/qianzhui/enode/rocketmq/publishableexceptions/PublishableExceptionMessage.java:45
↓ 1 callersMethodsetExtFields
(HashMap<String, String> extFields)
enode-remoting/src/main/java/com/qianzhui/enode/remoting/protocol/RemotingCommand.java:403
↓ 1 callersMethodsetId
(String id)
enode/src/main/java/com/qianzhui/enode/rocketmq/domainevent/EventStreamMessage.java:23
↓ 1 callersMethodsetItems
(Map<String, String> items)
enode/src/main/java/com/qianzhui/enode/eventing/DomainEventStream.java:95
↓ 1 callersMethodsetItems
(Map<String, String> items)
enode/src/main/java/com/qianzhui/enode/rocketmq/domainevent/EventStreamMessage.java:79
↓ 1 callersMethodsetLastUpdateTimeMillis
(long lastUpdateTimeMillis)
enode/src/main/java/com/qianzhui/enode/domain/AggregateCacheInfo.java:31
↓ 1 callersMethodsetListenPort
(int listenPort)
enode-remoting/src/main/java/com/qianzhui/enode/remoting/netty/NettyServerConfig.java:45
↓ 1 callersMethodsetMessageListener
(MessageListener messageListener)
enode/src/main/java/com/qianzhui/enode/common/rocketmq/consumer/CompletableDefaultMQPushConsumer.java:272
↓ 1 callersMethodsetNext
(EventCommittingContext next)
enode/src/main/java/com/qianzhui/enode/eventing/EventCommittingContext.java:47
↓ 1 callersMethodsetProcessingCommandHandler
Set the command executor for command retring. @param processingCommandHandler
enode/src/main/java/com/qianzhui/enode/eventing/IEventService.java:15
← previousnext →601–700 of 1,671, ranked by callers