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
MethodResponseFuture
(int opaque, long timeoutMillis, InvokeCallback invokeCallback, SemaphoreReleaseOnly
enode-remoting/src/main/java/com/qianzhui/enode/remoting/netty/ResponseFuture.java:41
MethodRocketMQClientException
()
enode/src/main/java/com/qianzhui/enode/rocketmq/client/RocketMQClientException.java:9
MethodRocketMQConsumer
(Consumer consumer)
enode/src/main/java/com/qianzhui/enode/rocketmq/RocketMQConsumer.java:22
MethodRocketMQMessageTypeCode
(int value)
enode/src/main/java/com/qianzhui/enode/rocketmq/RocketMQMessageTypeCode.java:15
MethodRocketMQProcessContext
(MessageExt queueMessage, CompletableConsumeConcurrentlyContext messageContext)
enode/src/main/java/com/qianzhui/enode/rocketmq/RocketMQProcessContext.java:14
MethodRootDisptaching
()
enode/src/main/java/com/qianzhui/enode/infrastructure/impl/DefaultMessageDispatcher.java:230
MethodScheduleService
()
enode/src/main/java/com/qianzhui/enode/common/scheduling/ScheduleService.java:25
MethodSemaphoreReleaseOnlyOnce
(Semaphore semaphore)
enode-remoting/src/main/java/com/qianzhui/enode/remoting/common/SemaphoreReleaseOnlyOnce.java:26
MethodSendQueueMessageService
(IOHelper _ioHelper)
enode/src/main/java/com/qianzhui/enode/rocketmq/SendQueueMessageService.java:27
MethodSendReplyContext
(short replyType, Object replyData, String replyAddress)
enode/src/main/java/com/qianzhui/enode/rocketmq/SendReplyService.java:74
MethodSendReplyService
(IJsonSerializer jsonSerializer)
enode/src/main/java/com/qianzhui/enode/rocketmq/SendReplyService.java:28
MethodServiceThread
()
enode-remoting/src/main/java/com/qianzhui/enode/remoting/common/ServiceThread.java:33
MethodSessionCredentials
()
enode/src/main/java/com/qianzhui/enode/rocketmq/client/ons/SessionCredentials.java:28
MethodSingleMessageDispatching
(IMessage message, QueueMessageDispatching queueMessageDispatching, List<? extends IObjectProxy> handlers, ITy
enode/src/main/java/com/qianzhui/enode/infrastructure/impl/DefaultMessageDispatcher.java:311
MethodSnapshotOnlyAggregateStorage
(IAggregateSnapshotter aggregateSnapshotter)
enode/src/main/java/com/qianzhui/enode/domain/impl/SnapshotOnlyAggregateStorage.java:15
MethodSpasException
(String message, Throwable t)
enode/src/main/java/com/qianzhui/enode/rocketmq/client/ons/SpasException.java:12
MethodStreamRecord
()
enode/src/main/java/com/qianzhui/enode/eventing/impl/StreamRecord.java:16
MethodStringKeyValuePair
(String key, String value)
enode/src/main/java/com/qianzhui/enode/configurations/StringKeyValuePair.java:10
MethodSyncTaskExecutionContext
(String actionName, Func<TAsyncResult> action, Action1<TAsyncResult> successAction,
enode/src/main/java/com/qianzhui/enode/common/io/IOHelper.java:83
MethodTaskCallback
(String taskName)
enode/src/main/java/com/qianzhui/enode/common/scheduling/ScheduleService.java:57
MethodTimerBasedTask
(String name, Action action, ScheduledFuture scheduledFuture, int dueTime, int period, boolean stopped)
enode/src/main/java/com/qianzhui/enode/common/scheduling/ScheduleService.java:87
MethodTopicTagData
()
enode/src/main/java/com/qianzhui/enode/rocketmq/TopicTagData.java:10
MethodUpdateExecuter
(String sql, Object[] params)
enode/src/main/java/com/qianzhui/enode/infrastructure/impl/AbstractAsyncDenormalizer.java:148
MethodWhenImpl
(Class<ExpectType> expectExceptionType, WrappedExceptionParser<OrigType> parser)
enode/src/main/java/com/qianzhui/enode/infrastructure/WrappedExceptionParser.java:52
MethodWorker
(String actionName, Action action)
enode/src/main/java/com/qianzhui/enode/common/scheduling/Worker.java:23
MethodWrappedExceptionParser
(T e)
enode/src/main/java/com/qianzhui/enode/infrastructure/WrappedExceptionParser.java:24
MethodWrappedRuntimeException
(Exception e)
enode/src/main/java/com/qianzhui/enode/infrastructure/WrappedRuntimeException.java:16
MethodacceptChanges
(int newVersion)
enode/src/main/java/com/qianzhui/enode/domain/AggregateRoot.java:125
MethodactionName
()
enode/src/main/java/com/qianzhui/enode/common/scheduling/Worker.java:19
Methodadd
(IAggregateRoot aggregateRoot)
enode/src/main/java/com/qianzhui/enode/rocketmq/command/CommandConsumer.java:132
MethodaddLockKey
(String lockKey)
enode/src/main/java/com/qianzhui/enode/infrastructure/ILockService.java:9
MethodaddRecordAsync
(MessageHandleRecord record)
enode/src/main/java/com/qianzhui/enode/infrastructure/IMessageHandleRecordStore.java:11
MethodaddRecordAsync
(MessageHandleRecord record)
enode/src/main/java/com/qianzhui/enode/infrastructure/impl/inmemory/InMemoryMessageHandleRecordStore.java:21
MethodaddRecordAsync
(MessageHandleRecord record)
enode/src/main/java/com/qianzhui/enode/infrastructure/impl/mysql/MysqlMessageHandleRecordStore.java:55
MethodaddToWaitingList
()
enode/src/main/java/com/qianzhui/enode/infrastructure/ProcessingDomainEventStreamMessage.java:24
MethodadjustThreadPool
()
enode/src/main/java/com/qianzhui/enode/common/rocketmq/impl/consumer/CompletableDefaultMQPushConsumerImpl.java:1050
MethodaggregateRootId
()
enode/src/main/java/com/qianzhui/enode/infrastructure/SequenceMessage.java:13
MethodaggregateRootStringId
()
enode/src/main/java/com/qianzhui/enode/infrastructure/SequenceMessage.java:22
MethodaggregateRootTypeName
()
enode/src/main/java/com/qianzhui/enode/infrastructure/SequenceMessage.java:30
Methodappend
(DomainEventStream eventStream)
enode/src/main/java/com/qianzhui/enode/eventing/impl/MysqlEventStore.java:218
Methodappend
(DomainEventStream eventStream)
enode/src/main/java/com/qianzhui/enode/eventing/impl/InMemoryEventStore.java:59
Methodappend
编码数据上下文到缓冲区 @param context
enode/src/main/java/com/qianzhui/enode/rocketmq/trace/core/dispatch/AsyncAppender.java:12
Methodappend
往消息缓冲区编码轨迹数据 @param context
enode/src/main/java/com/qianzhui/enode/rocketmq/trace/core/dispatch/impl/AsyncTraceAppender.java:86
Methodappend
队列满时直接丢弃数据，不阻塞业务线程，返回日志是否被接受
enode/src/main/java/com/qianzhui/enode/rocketmq/trace/core/dispatch/impl/AsyncTraceDispatcher.java:86
Methodappend
(final Object ctx)
enode/src/main/java/com/qianzhui/enode/rocketmq/trace/core/dispatch/impl/AsyncArrayDispatcher.java:95
Methodapply
(T1 obj1, T2 obj2)
enode/src/main/java/com/qianzhui/enode/common/function/Action2.java:7
Methodapply
(T1 obj1, T2 obj2, T3 obj3, T4 obj4)
enode/src/main/java/com/qianzhui/enode/common/function/Action4.java:7
Methodapply
()
enode/src/main/java/com/qianzhui/enode/common/function/Action.java:13
Methodapply
(T obj)
enode/src/main/java/com/qianzhui/enode/common/function/Action1.java:7
Methodapply
(T obj)
enode/src/main/java/com/qianzhui/enode/common/function/Func1.java:7
Methodapply
(T1 obj1, T2 obj2)
enode/src/main/java/com/qianzhui/enode/common/function/Func2.java:7
Methodapply
(T1 obj1, T2 obj2, T3 obj3)
enode/src/main/java/com/qianzhui/enode/common/function/Func3.java:7
Methodapply
(T1 obj1, T2 obj2, T3 obj3)
enode/src/main/java/com/qianzhui/enode/common/function/Action3.java:7
MethodapplyEvents
(IDomainEvent<TAggregateRootId>[] domainEvents)
enode/src/main/java/com/qianzhui/enode/domain/AggregateRoot.java:61
MethodbatchAppend
(List<DomainEventStream> eventStreams)
enode/src/main/java/com/qianzhui/enode/eventing/impl/MysqlEventStore.java:143
MethodbatchAppend
(List<DomainEventStream> eventStreams)
enode/src/main/java/com/qianzhui/enode/eventing/impl/InMemoryEventStore.java:54
MethodbatchAppendAsync
(List<DomainEventStream> eventStreams)
enode/src/main/java/com/qianzhui/enode/eventing/impl/InMemoryEventStore.java:64
MethodbatchStatement
(String sql, Object[][] params)
enode/src/main/java/com/qianzhui/enode/infrastructure/impl/AbstractAsyncDenormalizer.java:107
MethodbindAddress
()
enode-remoting/src/main/java/com/qianzhui/enode/remoting/netty/NettyRemotingServer.java:228
MethodbuildIntanceName
()
enode/src/main/java/com/qianzhui/enode/rocketmq/client/MQClientInitializer.java:48
MethodchannelActive
(ChannelHandlerContext ctx)
enode-remoting/src/main/java/com/qianzhui/enode/remoting/netty/NettyRemotingServer.java:276
MethodchannelInactive
(ChannelHandlerContext ctx)
enode-remoting/src/main/java/com/qianzhui/enode/remoting/netty/NettyRemotingServer.java:287
MethodchannelRead0
(ChannelHandlerContext ctx, RemotingCommand msg)
enode-remoting/src/main/java/com/qianzhui/enode/remoting/netty/NettyRemotingClient.java:416
MethodchannelRead0
(ChannelHandlerContext ctx, RemotingCommand msg)
enode-remoting/src/main/java/com/qianzhui/enode/remoting/netty/NettyRemotingServer.java:255
MethodchannelRegistered
(ChannelHandlerContext ctx)
enode-remoting/src/main/java/com/qianzhui/enode/remoting/netty/NettyRemotingServer.java:262
MethodchannelUnregistered
(ChannelHandlerContext ctx)
enode-remoting/src/main/java/com/qianzhui/enode/remoting/netty/NettyRemotingServer.java:269
MethodcheckCommandHandledFirst
()
enode/src/main/java/com/qianzhui/enode/commanding/ICommandAsyncHandlerProxy.java:16
MethodcheckCommandHandledFirst
()
enode/src/main/java/com/qianzhui/enode/commanding/impl/CommandAsyncHandlerProxy.java:45
MethodcleanInactiveAggregateRoot
()
enode/src/main/java/com/qianzhui/enode/domain/impl/DefaultMemoryCache.java:113
MethodcleanInactiveMailbox
()
enode/src/main/java/com/qianzhui/enode/infrastructure/impl/DefaultMessageProcessor.java:67
MethodcleanInactiveMailbox
()
enode/src/main/java/com/qianzhui/enode/commanding/impl/DefaultCommandProcessor.java:61
MethodcleanInactiveMailbox
()
enode/src/main/java/com/qianzhui/enode/eventing/impl/DefaultEventService.java:318
Methodclear
()
enode/src/main/java/com/qianzhui/enode/rocketmq/command/CommandConsumer.java:181
Methodclone
()
enode-remoting/src/main/java/com/qianzhui/enode/remoting/netty/NettyServerConfig.java:129
Methodcombine
(AsyncTaskResult r1, AsyncTaskResult r2)
enode/src/main/java/com/qianzhui/enode/rocketmq/command/CommandService.java:95
MethodcombineBytes
(byte[] b1, byte[] b2)
enode/src/main/java/com/qianzhui/enode/rocketmq/client/ons/ONSUtil.java:5
MethodcommitDomainEventAsync
(EventCommittingContext context)
enode/src/main/java/com/qianzhui/enode/eventing/impl/DefaultEventService.java:62
MethodcommitRegisters
()
enode/src/main/java/com/qianzhui/enode/common/container/AbstractContainer.java:22
MethodcommitRegisters
()
enode/src/main/java/com/qianzhui/enode/common/container/ObjectContainer.java:19
MethodcompareTo
(OnsTraceContext o)
enode/src/main/java/com/qianzhui/enode/rocketmq/trace/core/common/OnsTraceContext.java:137
Methodcomplete
()
enode/src/main/java/com/qianzhui/enode/infrastructure/ProcessingPublishableExceptionMessage.java:25
Methodcomplete
()
enode/src/main/java/com/qianzhui/enode/infrastructure/ProcessingDomainEventStreamMessage.java:29
Methodcomplete
()
enode/src/main/java/com/qianzhui/enode/infrastructure/ProcessingApplicationMessage.java:21
Methodcomplete
(CommandResult commandResult)
enode/src/main/java/com/qianzhui/enode/commanding/ProcessingCommand.java:24
MethodconsumeFromWhere
()
enode/src/main/java/com/qianzhui/enode/common/rocketmq/impl/consumer/CompletableDefaultMQPushConsumerImpl.java:216
MethodconsumeMessageDirectly
(MessageExt msg, String brokerName)
enode/src/main/java/com/qianzhui/enode/common/rocketmq/impl/consumer/CompletableConsumeMessageConcurrentlyService.java:378
MethodconsumeType
()
enode/src/main/java/com/qianzhui/enode/common/rocketmq/impl/consumer/CompletableDefaultMQPushConsumerImpl.java:210
MethodconsumerRunningInfo
()
enode/src/main/java/com/qianzhui/enode/common/rocketmq/impl/consumer/CompletableDefaultMQPushConsumerImpl.java:1068
MethodcreateAggregateRoot
(Class<T> aggregateRootType)
enode/src/main/java/com/qianzhui/enode/domain/impl/DefaultAggregateRootFactory.java:11
MethodcreateProducer
(Properties properties)
enode/src/main/java/com/qianzhui/enode/rocketmq/client/impl/DefaultRocketMQFactory.java:14
MethodcreateProducer
(Properties properties)
enode/src/main/java/com/qianzhui/enode/rocketmq/client/impl/NativeMQFactory.java:13
MethodcreateProducer
(Properties properties)
enode/src/main/java/com/qianzhui/enode/rocketmq/client/ons/ONSFactory.java:13
MethodcreatePushConsumer
(Properties properties)
enode/src/main/java/com/qianzhui/enode/rocketmq/client/impl/DefaultRocketMQFactory.java:19
MethodcreatePushConsumer
(Properties properties)
enode/src/main/java/com/qianzhui/enode/rocketmq/client/impl/NativeMQFactory.java:18
MethodcreatePushConsumer
(Properties properties)
enode/src/main/java/com/qianzhui/enode/rocketmq/client/ons/ONSFactory.java:18
MethodcreateTopic
(String key, String newTopic, int queueNum)
enode/src/main/java/com/qianzhui/enode/common/rocketmq/impl/consumer/CompletableDefaultMQPushConsumerImpl.java:142
MethodcreateTopic
(String key, String newTopic, int queueNum)
enode/src/main/java/com/qianzhui/enode/common/rocketmq/consumer/CompletableDefaultMQPushConsumer.java:141
Methoddecode
(ChannelHandlerContext ctx, ByteBuf in)
enode-remoting/src/main/java/com/qianzhui/enode/remoting/netty/NettyDecoder.java:40
MethoddecodeCommandCustomHeader
( Class<? extends CommandCustomHeader> classHeader)
enode-remoting/src/main/java/com/qianzhui/enode/remoting/protocol/RemotingCommand.java:127
MethoddecoderFromTraceDataString
从轨迹数据字符串中解析出traceContext列表 @param traceData @return
enode/src/main/java/com/qianzhui/enode/rocketmq/trace/core/common/OnsTraceDataEncoder.java:18
← previousnext →901–1,000 of 1,671, ranked by callers