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
MethodCommandResultProcessor
(int listenPort, IJsonSerializer jsonSerializer)
enode/src/main/java/com/qianzhui/enode/rocketmq/command/CommandResultProcessor.java:46
MethodCommandService
(IJsonSerializer jsonSerializer, ITopicProvider<ICommand> commandTopicProvider,
enode/src/main/java/com/qianzhui/enode/rocketmq/command/CommandService.java:39
MethodCommandTaskCompletionSource
(CommandReturnType commandReturnType, CompletableFuture<AsyncTaskResult<CommandResult>> taskCompletionSource)
enode/src/main/java/com/qianzhui/enode/rocketmq/command/CommandResultProcessor.java:166
MethodCompletableConsumeConcurrentlyContext
(MessageQueue messageQueue, CompletableFuture<ConsumeConcurrentlyStatus> statusFuture)
enode/src/main/java/com/qianzhui/enode/common/rocketmq/consumer/listener/CompletableConsumeConcurrentlyContext.java:28
MethodCompletableConsumeMessageConcurrentlyService
(DefaultMQPushConsumerImpl defaultMQPushConsumerImpl,
enode/src/main/java/com/qianzhui/enode/common/rocketmq/impl/consumer/CompletableConsumeMessageConcurrentlyService.java:48
MethodCompletableDefaultMQPushConsumer
()
enode/src/main/java/com/qianzhui/enode/common/rocketmq/consumer/CompletableDefaultMQPushConsumer.java:118
MethodCompletableDefaultMQPushConsumerImpl
(CompletableDefaultMQPushConsumer defaultMQPushConsumer, RPCHook rpcHook)
enode/src/main/java/com/qianzhui/enode/common/rocketmq/impl/consumer/CompletableDefaultMQPushConsumerImpl.java:98
MethodConfigurationSetting
()
enode/src/main/java/com/qianzhui/enode/configurations/ConfigurationSetting.java:34
MethodConsumeRequest
(List<MessageExt> msgs, ProcessQueue processQueue, MessageQueue messageQueue)
enode/src/main/java/com/qianzhui/enode/common/rocketmq/impl/consumer/CompletableConsumeMessageConcurrentlyService.java:91
MethodCreateNoteCommand
(String aggregateRootId, String title)
samples/notesample/commands/src/main/java/com/qianzhui/enodesamples/notesample/commands/CreateNoteCommand.java:11
MethodDefaultAggregateSnapshotter
(IAggregateRepositoryProvider aggregateRepositoryProvider)
enode/src/main/java/com/qianzhui/enode/domain/impl/DefaultAggregateSnapshotter.java:16
MethodDefaultApplicationMessageProcessor
( IProcessingMessageScheduler<ProcessingApplicationMessage, IApplicationMessage> processingMessage
enode/src/main/java/com/qianzhui/enode/infrastructure/impl/DefaultApplicationMessageProcessor.java:17
MethodDefaultCommandAsyncHandlerProvider
(IObjectContainer objectContainer)
enode/src/main/java/com/qianzhui/enode/commanding/impl/DefaultCommandAsyncHandlerProvider.java:16
MethodDefaultCommandHandlerProvider
(IObjectContainer objectContainer)
enode/src/main/java/com/qianzhui/enode/commanding/impl/DefaultCommandHandlerProvider.java:16
MethodDefaultCommandProcessor
(IScheduleService scheduleService, IProcessingCommandHandler handler)
enode/src/main/java/com/qianzhui/enode/commanding/impl/DefaultCommandProcessor.java:32
MethodDefaultDBConfigurationSetting
()
enode/src/main/java/com/qianzhui/enode/configurations/DefaultDBConfigurationSetting.java:60
MethodDefaultDomainEventProcessor
( IProcessingMessageScheduler<ProcessingDomainEventStreamMessage, DomainEventStreamMessage> proces
enode/src/main/java/com/qianzhui/enode/infrastructure/impl/DefaultDomainEventProcessor.java:15
MethodDefaultEventSerializer
(ITypeNameProvider typeNameProvider, IJsonSerializer jsonSerializer)
enode/src/main/java/com/qianzhui/enode/eventing/impl/DefaultEventSerializer.java:18
MethodDefaultEventService
( IScheduleService scheduleService, IMemoryCache memoryCache, IEventStore
enode/src/main/java/com/qianzhui/enode/eventing/impl/DefaultEventService.java:39
MethodDefaultMemoryCache
(IScheduleService scheduleService, ITypeNameProvider typeNameProvider, IAggregateStorage aggregateStorage)
enode/src/main/java/com/qianzhui/enode/domain/impl/DefaultMemoryCache.java:34
MethodDefaultMessageDispatcher
( ITypeNameProvider typeNameProvider, IMessageHandlerProvider handlerProvider,
enode/src/main/java/com/qianzhui/enode/infrastructure/impl/DefaultMessageDispatcher.java:33
MethodDefaultMessageHandlerProvider
(IObjectContainer objectContainer)
enode/src/main/java/com/qianzhui/enode/infrastructure/impl/DefaultMessageHandlerProvider.java:18
MethodDefaultMessageProcessor
(IProcessingMessageScheduler<X, Y> processingMessageScheduler, IProcessingM
enode/src/main/java/com/qianzhui/enode/infrastructure/impl/DefaultMessageProcessor.java:30
MethodDefaultProcessingCommandHandler
( IJsonSerializer jsonSerializer, IEventStore eventStore, ICommandHandlerP
enode/src/main/java/com/qianzhui/enode/commanding/impl/DefaultProcessingCommandHandler.java:39
MethodDefaultProcessingMessageHandler
(IMessageDispatcher dispatcher)
enode/src/main/java/com/qianzhui/enode/infrastructure/impl/DefaultProcessingMessageHandler.java:18
MethodDefaultProcessingMessageScheduler
(IProcessingMessageHandler<X, Y> messageHandler)
enode/src/main/java/com/qianzhui/enode/infrastructure/impl/DefaultProcessingMessageScheduler.java:14
MethodDefaultPublishableExceptionProcessor
( IProcessingMessageScheduler<ProcessingPublishableExceptionMessage, IPublishableException> proces
enode/src/main/java/com/qianzhui/enode/infrastructure/impl/DefaultPublishableExceptionProcessor.java:15
MethodDefaultRepository
(IMemoryCache memoryCache, IAggregateStorage aggregateRootStorage)
enode/src/main/java/com/qianzhui/enode/domain/impl/DefaultRepository.java:17
MethodDefaultThreeMessageHandlerProvider
(IObjectContainer objectContainer)
enode/src/main/java/com/qianzhui/enode/infrastructure/impl/DefaultThreeMessageHandlerProvider.java:20
MethodDefaultTwoMessageHandlerProvider
(IObjectContainer objectContainer)
enode/src/main/java/com/qianzhui/enode/infrastructure/impl/DefaultTwoMessageHandlerProvider.java:20
MethodDomainEventConsumer
(RocketMQConsumer rocketMQConsumer, IJsonSerializer jsonSerializer, IEventSeria
enode/src/main/java/com/qianzhui/enode/rocketmq/domainevent/DomainEventConsumer.java:32
MethodDomainEventPublisher
(Producer producer, IJsonSerializer jsonSerializer, ITopicProvider<IDomainEven
enode/src/main/java/com/qianzhui/enode/rocketmq/domainevent/DomainEventPublisher.java:35
MethodDomainEventStream
(String commandId, String aggregateRootId, String aggregateRootTypeName, int version, Date timestamp, List<IDo
enode/src/main/java/com/qianzhui/enode/eventing/DomainEventStream.java:18
MethodDomainEventStreamMessage
()
enode/src/main/java/com/qianzhui/enode/eventing/DomainEventStreamMessage.java:20
MethodDomainEventStreamMessageHandler
(IPublishedVersionStore publishedVersionStore, IMessageDispatcher dispatcher, IOHelper ioHelper)
enode/src/main/java/com/qianzhui/enode/eventing/impl/DomainEventStreamMessageHandler.java:21
MethodDomainEventStreamProcessContext
(DomainEventConsumer eventConsumer, DomainEventStreamMessage domainEventStreamMessage,
enode/src/main/java/com/qianzhui/enode/rocketmq/domainevent/DomainEventConsumer.java:102
MethodENode
(ConfigurationSetting setting, String... packages)
enode/src/main/java/com/qianzhui/enode/ENode.java:97
MethodEventAppendResult
(int status)
enode/src/main/java/com/qianzhui/enode/eventing/EventAppendResult.java:16
MethodEventCommittingContext
(IAggregateRoot aggregateRoot, DomainEventStream eventStream, ProcessingCommand processingCommand)
enode/src/main/java/com/qianzhui/enode/eventing/EventCommittingContext.java:17
MethodEventMailBox
(String aggregateRootId, int batchSize, Consumer<List<EventCommittingContext>> handleMessageAction)
enode/src/main/java/com/qianzhui/enode/eventing/impl/EventMailBox.java:33
MethodEventSourcingAggregateStorage
( IAggregateRootFactory aggregateRootFactory, IEventStore eventStore, IPub
enode/src/main/java/com/qianzhui/enode/domain/impl/EventSourcingAggregateStorage.java:37
MethodGenericTypeLiteral
(Type type)
enode/src/main/java/com/qianzhui/enode/common/container/GenericTypeLiteral.java:13
MethodHandledCommand
()
enode/src/main/java/com/qianzhui/enode/commanding/HandledCommand.java:13
MethodHandlerFindResult
(HandlerFindStatus findStatus)
enode/src/main/java/com/qianzhui/enode/commanding/impl/DefaultProcessingCommandHandler.java:404
MethodIORuntimeException
()
enode/src/main/java/com/qianzhui/enode/common/io/IORuntimeException.java:9
MethodInMemoryEventStore
()
enode/src/main/java/com/qianzhui/enode/eventing/impl/InMemoryEventStore.java:27
MethodInsertExecuter
(String sql, Object[] params)
enode/src/main/java/com/qianzhui/enode/infrastructure/impl/AbstractAsyncDenormalizer.java:154
MethodMQClientInitializer
()
enode/src/main/java/com/qianzhui/enode/rocketmq/client/MQClientInitializer.java:19
MethodManualResetEvent
(boolean initialState)
enode/src/main/java/com/qianzhui/enode/common/threading/ManualResetEvent.java:10
MethodManyType
(List<Class> types)
enode/src/main/java/com/qianzhui/enode/infrastructure/impl/ManyType.java:15
MethodMessage
()
enode/src/main/java/com/qianzhui/enode/infrastructure/Message.java:15
MethodMessageHandlerProxy1
(IObjectContainer objectContainer, Class handlerType, IMessageHandler handler, MethodHandle methodHandle, Meth
enode/src/main/java/com/qianzhui/enode/infrastructure/impl/MessageHandlerProxy1.java:23
MethodMessageHandlerProxy2
(IObjectContainer objectContainer, Class handlerType, IMessageHandler handler, MethodHandle methodHandle, Meth
enode/src/main/java/com/qianzhui/enode/infrastructure/impl/MessageHandlerProxy2.java:24
MethodMessageHandlerProxy3
(IObjectContainer objectContainer, Class handlerType, IMessageHandler handler, MethodHandle methodHandle, Meth
enode/src/main/java/com/qianzhui/enode/infrastructure/impl/MessageHandlerProxy3.java:27
MethodMixUtils
()
enode/src/main/java/com/qianzhui/enode/rocketmq/trace/core/utils/MixUtils.java:14
MethodMultiMessageDisptaching
(List<? extends IMessage> messages, List<? extends IObjectProxy> handlers, RootDisptaching rootDispatching, IT
enode/src/main/java/com/qianzhui/enode/infrastructure/impl/DefaultMessageDispatcher.java:288
MethodMysqlEventStore
(DataSource ds, OptionSetting optionSetting, IObjectContainer objectContainer)
enode/src/main/java/com/qianzhui/enode/eventing/impl/MysqlEventStore.java:52
MethodMysqlLockService
(DataSource ds, OptionSetting optionSetting)
enode/src/main/java/com/qianzhui/enode/infrastructure/impl/mysql/MysqlLockService.java:47
MethodMysqlMessageHandleRecordStore
(DataSource ds, OptionSetting optionSetting)
enode/src/main/java/com/qianzhui/enode/infrastructure/impl/mysql/MysqlMessageHandleRecordStore.java:35
MethodMysqlPublishedVersionStore
(DataSource ds, OptionSetting optionSetting)
enode/src/main/java/com/qianzhui/enode/infrastructure/impl/mysql/MysqlPublishedVersionStore.java:36
MethodNativeMQConsumer
(Properties properties)
enode/src/main/java/com/qianzhui/enode/rocketmq/client/impl/NativeMQConsumer.java:17
MethodNativeMQProducer
(Properties properties)
enode/src/main/java/com/qianzhui/enode/rocketmq/client/impl/NativeMQProducer.java:16
MethodNettyDecoder
()
enode-remoting/src/main/java/com/qianzhui/enode/remoting/netty/NettyDecoder.java:36
MethodNettyEvent
(NettyEventType type, String remoteAddr, Channel channel)
enode-remoting/src/main/java/com/qianzhui/enode/remoting/netty/NettyEvent.java:26
MethodNettyRemotingAbstract
Constructor, specifying capacity of one-way and asynchronous semaphores. @param permitsOneway Number of permits for one-way requests. @param permitsA
enode-remoting/src/main/java/com/qianzhui/enode/remoting/netty/NettyRemotingAbstract.java:75
MethodNettyRemotingClient
(final NettyClientConfig nettyClientConfig)
enode-remoting/src/main/java/com/qianzhui/enode/remoting/netty/NettyRemotingClient.java:56
MethodNettyRemotingServer
(final NettyServerConfig nettyServerConfig)
enode-remoting/src/main/java/com/qianzhui/enode/remoting/netty/NettyRemotingServer.java:55
MethodNote
()
samples/notesample/domain/src/main/java/com/qianzhui/enodesamples/notesample/domain/Note.java:15
MethodNoteCreated
(String title)
samples/notesample/domain/src/main/java/com/qianzhui/enodesamples/notesample/domain/NoteCreated.java:11
MethodNoteEventHandler
()
samples/notesample/quickstart/src/main/java/com/qianzhui/enodesamples/quickstart/eventhandlers/NoteEventHandler.java:16
MethodNoteTitleChanged
(String title)
samples/notesample/domain/src/main/java/com/qianzhui/enodesamples/notesample/domain/NoteTitleChanged.java:11
MethodONSClientInitializer
()
enode/src/main/java/com/qianzhui/enode/rocketmq/client/ons/ONSClientInitializer.java:32
MethodONSConsumerImpl
(Properties properties)
enode/src/main/java/com/qianzhui/enode/rocketmq/client/ons/ONSConsumerImpl.java:26
MethodONSProducerImpl
(final Properties properties)
enode/src/main/java/com/qianzhui/enode/rocketmq/client/ons/ONSProducerImpl.java:98
MethodObjectId
(byte[] bytes)
enode/src/main/java/com/qianzhui/enode/common/utilities/ObjectId.java:35
MethodOnsClientSendMessageHookImpl
(AsyncDispatcher localDispatcher)
enode/src/main/java/com/qianzhui/enode/rocketmq/trace/core/OnsClientSendMessageHookImpl.java:24
MethodOnsConsumeMessageHookImpl
(AsyncDispatcher localDispatcher)
enode/src/main/java/com/qianzhui/enode/rocketmq/trace/core/utils/OnsConsumeMessageHookImpl.java:25
MethodOnsTraceBean
()
enode/src/main/java/com/qianzhui/enode/rocketmq/trace/core/common/OnsTraceBean.java:23
MethodOnsTraceConstants
()
enode/src/main/java/com/qianzhui/enode/rocketmq/trace/core/common/OnsTraceConstants.java:22
MethodOnsTraceTransferBean
()
enode/src/main/java/com/qianzhui/enode/rocketmq/trace/core/common/OnsTraceTransferBean.java:13
MethodOnsTraceType
()
enode/src/main/java/com/qianzhui/enode/rocketmq/trace/core/common/OnsTraceType.java:11
MethodOptionSetting
(StringKeyValuePair... options)
enode/src/main/java/com/qianzhui/enode/configurations/OptionSetting.java:12
MethodProcessingApplicationMessage
(IApplicationMessage message, IMessageProcessContext processContext)
enode/src/main/java/com/qianzhui/enode/infrastructure/ProcessingApplicationMessage.java:12
MethodProcessingCommand
(ICommand command, ICommandExecuteContext commandExecuteContext, Map<String, String> items)
enode/src/main/java/com/qianzhui/enode/commanding/ProcessingCommand.java:18
MethodProcessingCommandMailbox
(String aggregateRootId, IProcessingCommandHandler messageHandler)
enode/src/main/java/com/qianzhui/enode/commanding/ProcessingCommandMailbox.java:46
MethodProcessingDomainEventStreamMessage
(DomainEventStreamMessage message, IMessageProcessContext processContext)
enode/src/main/java/com/qianzhui/enode/infrastructure/ProcessingDomainEventStreamMessage.java:15
MethodProcessingMessageMailbox
(String routingKey, IProcessingMessageScheduler<X, Y> scheduler, IProcessingMessageHandler<X, Y> messageHandle
enode/src/main/java/com/qianzhui/enode/infrastructure/ProcessingMessageMailbox.java:27
MethodProcessingPublishableExceptionMessage
(IPublishableException message, IMessageProcessContext processContext)
enode/src/main/java/com/qianzhui/enode/infrastructure/ProcessingPublishableExceptionMessage.java:14
MethodPublishableException
()
enode/src/main/java/com/qianzhui/enode/infrastructure/PublishableException.java:18
MethodPublishableExceptionConsumer
(RocketMQConsumer consumer, IJsonSerializer jsonSerializer, ITopicProv
enode/src/main/java/com/qianzhui/enode/rocketmq/publishableexceptions/PublishableExceptionConsumer.java:27
MethodPublishableExceptionPublisher
(Producer producer, IJsonSerializer jsonSerializer, ITopicProvider<IP
enode/src/main/java/com/qianzhui/enode/rocketmq/publishableexceptions/PublishableExceptionPublisher.java:34
MethodQueueMessageDispatching
(DefaultMessageDispatcher dispatcher, RootDisptaching rootDispatching, List<? extends IMessage> messages)
enode/src/main/java/com/qianzhui/enode/infrastructure/impl/DefaultMessageDispatcher.java:253
MethodQueuedHandler
(List<T> handlers, Action2<QueuedHandler<T>, T> dispatchToNextHandler)
enode/src/main/java/com/qianzhui/enode/infrastructure/impl/DefaultMessageDispatcher.java:335
MethodRemotingCommand
()
enode-remoting/src/main/java/com/qianzhui/enode/remoting/protocol/RemotingCommand.java:57
MethodRemotingCommandException
(String message)
enode-remoting/src/main/java/com/qianzhui/enode/remoting/exception/RemotingCommandException.java:9
MethodRemotingConnectException
(String addr)
enode-remoting/src/main/java/com/qianzhui/enode/remoting/exception/RemotingConnectException.java:23
MethodRemotingException
(String message)
enode-remoting/src/main/java/com/qianzhui/enode/remoting/exception/RemotingException.java:10
MethodRemotingSendRequestException
(String addr)
enode-remoting/src/main/java/com/qianzhui/enode/remoting/exception/RemotingSendRequestException.java:23
MethodRemotingTimeoutException
(String message)
enode-remoting/src/main/java/com/qianzhui/enode/remoting/exception/RemotingTimeoutException.java:23
MethodRemotingTooMuchRequestException
(String message)
enode-remoting/src/main/java/com/qianzhui/enode/remoting/exception/RemotingTooMuchRequestException.java:23
← previousnext →801–900 of 1,671, ranked by callers