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 callersMethodsetResponseCommand

(RemotingCommand responseCommand)

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

↓ 1 callersMethodsetSerializableInfo

(Map<String, String> serializableInfo)

enode/src/main/java/com/qianzhui/enode/rocketmq/publishableexceptions/PublishableExceptionMessage.java:61

↓ 1 callersMethodsetServerChannelMaxIdleTimeSeconds

(int serverChannelMaxIdleTimeSeconds)

enode-remoting/src/main/java/com/qianzhui/enode/remoting/netty/NettyServerConfig.java:93

↓ 1 callersMethodsetStatus

(String status)

enode/src/main/java/com/qianzhui/enode/rocketmq/client/ons/AuthenticationException.java:44

↓ 1 callersMethodsetStopped

(boolean stopped)

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

↓ 1 callersMethodsetTimestamp

(Date timestamp)

enode/src/main/java/com/qianzhui/enode/rocketmq/publishableexceptions/PublishableExceptionMessage.java:53

↓ 1 callersMethodsetTimestamp

(Date timestamp)

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

↓ 1 callersMethodsetTransData

(String transData)

enode/src/main/java/com/qianzhui/enode/rocketmq/trace/core/common/OnsTraceTransferBean.java:20

↓ 1 callersMethodsetUniqueId

(String uniqueId)

enode/src/main/java/com/qianzhui/enode/rocketmq/publishableexceptions/PublishableExceptionMessage.java:21

↓ 1 callersMethodsetVersion

(int version)

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

↓ 1 callersMethodsetmQClientFactory

(MQClientInstance mQClientFactory)

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

↓ 1 callersMethodshutdown

()

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

↓ 1 callersMethodshutdown

()

enode/src/main/java/com/qianzhui/enode/rocketmq/RocketMQConsumer.java:42

↓ 1 callersMethodshutdown

()

enode/src/main/java/com/qianzhui/enode/rocketmq/client/ons/ONSProducerImpl.java:143

↓ 1 callersMethodshutdown

()

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

↓ 1 callersMethodshutdown

()

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

↓ 1 callersMethodshutdown

()

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

↓ 1 callersMethodshutdown

()

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

↓ 1 callersMethodshutdown

()

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

↓ 1 callersMethodstart

()

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

↓ 1 callersMethodstart

()

enode/src/main/java/com/qianzhui/enode/rocketmq/RocketMQConsumer.java:38

↓ 1 callersMethodstart

()

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

↓ 1 callersMethodstart

()

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

↓ 1 callersMethodstart

()

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

↓ 1 callersMethodstart

()

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

↓ 1 callersMethodstartAgent

()

enode/src/main/java/com/qianzhui/enode/jmx/ENodeJMXAgent.java:11

↓ 1 callersMethodstartDelayedTask

(Duration duration, Action action)

enode/src/main/java/com/qianzhui/enode/common/function/DelayedTask.java:23

↓ 1 callersMethodstartDelayedTaskFuture

(Duration duration, Func<T> action)

enode/src/main/java/com/qianzhui/enode/common/function/DelayedTask.java:15

↓ 1 callersMethodstartENodeComponents

()

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

↓ 1 callersMethodstartRocketMQComponents

()

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

↓ 1 callersMethodstopENodeComponents

()

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

↓ 1 callersMethodstring2SocketAddress

(final String addr)

enode-remoting/src/main/java/com/qianzhui/enode/remoting/common/RemotingHelper.java:54

↓ 1 callersMethodstring2SocketAddress

(final String addr)

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

↓ 1 callersMethodsubmitConsumeRequestLater

(// final List<MessageExt> msgs, //

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

↓ 1 callersMethodsubscribe

(String topic, String subExpression)

enode/src/main/java/com/qianzhui/enode/rocketmq/RocketMQConsumer.java:34

↓ 1 callersMethodsubscriptions

()

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

↓ 1 callersMethodtimestamp

()

enode/src/main/java/com/qianzhui/enode/eventing/DomainEventStream.java:83

↓ 1 callersMethodtoByteArray

()

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

↓ 1 callersMethodtoHexString

(byte[] bytes)

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

↓ 1 callersMethodtoString

()

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

↓ 1 callersMethodtryEnter

()

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

↓ 1 callersMethodtryEnter

()

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

↓ 1 callersMethodtryEnter

()

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

↓ 1 callersMethodtryEnterEditing

()

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

↓ 1 callersMethodtryExecuteWaitingMessage

(X currentCompletedMessage)

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

↓ 1 callersMethodtryGetFromSnapshot

(String aggregateRootId, Class<T> aggregateRootType)

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

↓ 1 callersMethodtryToRepublishEventAsync

(EventCommittingContext context)

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

↓ 1 callersMethodunpack

(byte[] bytes)

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

↓ 1 callersMethodupdatePublishedVersionAsync

(String processorName, String aggregateRootTypeName, String aggregateRootId, int publishedVersion)

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

↓ 1 callersMethodupdatePublishedVersionAsync

(X processingMessage)

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

↓ 1 callersMethodupdateTopicSubscribeInfoWhenSubscriptionChanged

()

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

↓ 1 callersMethoduseGuice

()

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

↓ 1 callersMethoduseMysqlComponents

(DataSource ds)

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

↓ 1 callersMethoduseMysqlEventStore

(DataSource ds, OptionSetting optionSetting)

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

↓ 1 callersMethoduseMysqlLockService

(DataSource ds, OptionSetting optionSetting)

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

↓ 1 callersMethoduseMysqlPublishedVersionStore

(DataSource ds, OptionSetting optionSetting)

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

↓ 1 callersMethoduseNativeRocketMQ

(Properties producerSetting, Properties consumerSetting,

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

↓ 1 callersMethoduseONS

(Properties producerSetting, Properties consumerSetting, int l

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

↓ 1 callersMethodverifyEvent

(DomainEventStream eventStream)

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

↓ 1 callersMethodwaitResponse

(final long timeoutMillis)

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

MethodAbstractAsyncDenormalizer

(DataSource ds)

enode/src/main/java/com/qianzhui/enode/infrastructure/impl/AbstractAsyncDenormalizer.java:24

MethodAbstractConsumer

(Properties properties, MQClientInitializer mqClientInitializer)

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

MethodAbstractDenormalizer

(DataSource denormalizerDatasource)

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

MethodAbstractProducer

(Properties properties, MQClientInitializer mqClientInitializer)

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

MethodAbstractQueryRunnerExecuter

(String sql, Object[] params)

enode/src/main/java/com/qianzhui/enode/infrastructure/impl/AbstractAsyncDenormalizer.java:119

MethodAbstractSequenceProcessingMessageHandler

(IPublishedVersionStore publishedVersionStore, IOHelper ioHelper)

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

MethodAbstractTaskExecutionContext

(String actionName, Action1<TAsyncResult> successAction, Func<String> contextInfoFunc,

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

MethodAggregateCacheInfo

(IAggregateRoot aggregateRoot)

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

MethodAggregateInfo

()

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

MethodAggregateRepositoryProxy

(IAggregateRepository<TAggregateRoot> aggregateRepository)

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

MethodAggregateRoot

()

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

MethodAggregateRootAlreadyExistException

(Object id, Class type)

enode/src/main/java/com/qianzhui/enode/commanding/AggregateRootAlreadyExistException.java:9

MethodApplicationDataMessage

(String applicationMessageData, String applicationMessageType)

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

MethodApplicationMessageConsumer

(RocketMQConsumer consumer, IJsonSerializer jsonSerializer, ITopicProvid

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

MethodApplicationMessagePublisher

(Producer producer, IJsonSerializer jsonSerializer, ITopicProvider<IApp

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

MethodArraySegment

(T[] array)

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

MethodAsyncAppenderRequest

(final List<OnsTraceContext> contextList)

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

MethodAsyncArrayDispatcher

(Properties properties)

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

MethodAsyncTaskExecutionContext

(String actionName, Func<CompletableFuture<TAsyncResult>> asyncAction, Action1<TAsyncResult> successAction,

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

MethodAsyncTaskResult

(AsyncTaskStatus status)

enode/src/main/java/com/qianzhui/enode/common/io/AsyncTaskResult.java:16

MethodAsyncTraceAppender

构造消息类型的轨迹数据发送器 @param properties 参数属性 @throws MQClientException

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

MethodAsyncTraceDispatcher

(Properties properties)

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

MethodAuthenticationException

(String status, int code)

enode/src/main/java/com/qianzhui/enode/rocketmq/client/ons/AuthenticationException.java:13

MethodBatchAppendFuture

()

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

MethodBatchExecuter

(String sql, Object[][] params, boolean ignoreDuplicate)

enode/src/main/java/com/qianzhui/enode/infrastructure/impl/AbstractAsyncDenormalizer.java:178

MethodByteArraySegment

(byte[] array)

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

MethodChangeNoteTitleCommand

(String aggregateRootId, String title)

samples/notesample/commands/src/main/java/com/qianzhui/enodesamples/notesample/commands/ChangeNoteTitleCommand.java:11

MethodChannelWrapper

(ChannelFuture channelFuture)

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

MethodClientRPCHook

(SessionCredentials sessionCredentials)

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

MethodCommand

()

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

MethodCommandAddResult

(int status)

enode/src/main/java/com/qianzhui/enode/commanding/CommandAddResult.java:15

MethodCommandAsyncHandlerProxy

(IObjectContainer objectContainer, Class commandHandlerType, ICommandAsyncHandler commandHandler, MethodHandle

enode/src/main/java/com/qianzhui/enode/commanding/impl/CommandAsyncHandlerProxy.java:26

MethodCommandConsumer

(RocketMQConsumer consumer, IJsonSerializer jsonSerializer, ITypeNameProvider typeNameProvider,

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

MethodCommandExecuteContext

(IRepository repository, IAggregateStorage aggregateRootStorage, MessageExt queueMessage, CompletableConsumeCo

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

MethodCommandExecuteTimeoutException

()

enode/src/main/java/com/qianzhui/enode/commanding/CommandExecuteTimeoutException.java:8

MethodCommandHandlerProxy

(IObjectContainer objectContainer, Class commandHandlerType, ICommandHandler commandHandler, MethodHandle meth

enode/src/main/java/com/qianzhui/enode/commanding/impl/CommandHandlerProxy.java:23

MethodCommandMessage

(String commandData, String replyAddress, String commandType)

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

MethodCommandRecord

()

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

MethodCommandReplyType

(short value)

enode/src/main/java/com/qianzhui/enode/rocketmq/CommandReplyType.java:13

MethodCommandResult

()

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

← previous next →701–800 of 1,671, ranked by callers