MCPcopy Create free account

hub / github.com/ctripcorp/hermes / functions

Functions4,501 in github.com/ctripcorp/hermes

⨍ Functions 4,501◇ Types & classes 841
↓ 6 callersMethodload
()
hermes-core/src/main/java/com/ctrip/hermes/core/meta/internal/MetaLoader.java:7
↓ 6 callersMethodloadMeta
()
hermes-metaserver/src/test/java/com/ctrip/hermes/metaserver/fulltest/MetaServerBaseTest.java:600
↓ 6 callersMethodlogError
(LogEvent event)
hermes-core/src/main/java/com/ctrip/hermes/core/utils/CatLog4j2ErrorAppender.java:44
↓ 6 callersMethodmetaProxyActions4LeaseOperation
(Answer<?> acquireAnswer, Answer<?> renewAnswer)
hermes-consumer/src/test/java/com/ctrip/hermes/consumer/integration/BaseConsumerIntegrationTest.java:133
↓ 6 callersMethodpost
(final String path, final Map<String, String> requestParams, final Object payload)
hermes-core/src/main/java/com/ctrip/hermes/core/meta/remote/RemoteMetaProxy.java:213
↓ 6 callersMethodprintlnError
(Object o)
hermes-example/src/test/java/setup/SQLRunner.java:209
↓ 6 callersMethodreadBody
()
hermes-core/src/main/java/com/ctrip/hermes/core/message/PartialDecodedMessage.java:63
↓ 6 callersMethodreadStringStringMap
()
hermes-core/src/main/java/com/ctrip/hermes/core/utils/HermesPrimitiveCodec.java:341
↓ 6 callersMethodreset
()
hermes-core/src/main/java/com/ctrip/hermes/core/meta/manual/ManualConfigService.java:14
↓ 6 callersMethodsetBodyCodecType
(String bodyCodecType)
hermes-core/src/main/java/com/ctrip/hermes/core/message/PartialDecodedMessage.java:27
↓ 6 callersMethodsetBornTime
(long bornTime)
hermes-core/src/main/java/com/ctrip/hermes/core/message/PartialDecodedMessage.java:47
↓ 6 callersMethodsetCodecType
(String codecType)
hermes-core/src/main/java/com/ctrip/hermes/core/bo/ClientMeta.java:357
↓ 6 callersMethodsetCorrelationId
(long correlationId)
hermes-broker/src/main/java/com/ctrip/hermes/broker/longpolling/PullMessageTask.java:63
↓ 6 callersMethodsetDurableProperties
(ByteBuf durableProperties)
hermes-core/src/main/java/com/ctrip/hermes/core/message/PartialDecodedMessage.java:51
↓ 6 callersMethodsetExpireTime
(long expireTime)
hermes-core/src/main/java/com/ctrip/hermes/core/lease/Lease.java:33
↓ 6 callersMethodsetExpireTime
(long expireTime)
hermes-broker/src/main/java/com/ctrip/hermes/broker/longpolling/PullMessageTask.java:83
↓ 6 callersMethodsetKey
(String key)
hermes-core/src/main/java/com/ctrip/hermes/core/message/PartialDecodedMessage.java:43
↓ 6 callersMethodsetPartitionKey
(String partitionKey)
hermes-core/src/main/java/com/ctrip/hermes/core/message/ProducerMessage.java:99
↓ 6 callersMethodsetVersion
(Long version)
hermes-core/src/main/java/com/ctrip/hermes/core/bo/ClientMeta.java:212
↓ 6 callersMethodstart
(Subscriber subscriber)
hermes-consumer/src/main/java/com/ctrip/hermes/consumer/engine/Engine.java:7
↓ 6 callersMethodtoBytes
(ByteBuf buf)
hermes-core/src/main/java/com/ctrip/hermes/core/transport/command/Command.java:16
↓ 6 callersMethodtoString
()
hermes-core/src/main/java/com/ctrip/hermes/core/message/BaseConsumerMessage.java:153
↓ 6 callersMethodtransfer
(ByteBuf out)
hermes-core/src/main/java/com/ctrip/hermes/core/transport/TransferCallback.java:11
↓ 6 callersMethodvefifyAssign
(Map<Integer, Map<String, ClientContext>> assigns, String exp)
hermes-metaserver/src/test/java/com/ctrip/hermes/metaserver/consumer/LeastAdjustmentOrderedConsumeConsumerPartitionAssigningStrategyTest.java:18
↓ 6 callersMethodwaitTopicUntilReady
(String topic)
hermes-kafka/src/test/java/com/ctrip/hermes/kafka/server/MockKafkaCluster.java:64
↓ 6 callersMethodwriteStringStringMap
(Map<String, String> map)
hermes-core/src/main/java/com/ctrip/hermes/core/utils/HermesPrimitiveCodec.java:281
↓ 5 callersMethodaddAckMsg
(Tpp tpp, String groupId, boolean resend, long msgSeq, int remainingRetries, long onMessageStartTimeMil
hermes-core/src/main/java/com/ctrip/hermes/core/transport/command/AckMessageCommand.java:113
↓ 5 callersMethodaddBatch
(List<TppConsumerMessageBatch> batches, String topic, int partition, final List<Pair<MessageMeta, Parti
hermes-consumer/src/test/java/com/ctrip/hermes/consumer/integration/assist/PullMessageResultCreator.java:56
↓ 5 callersMethodaddBatches
(List<TppConsumerMessageBatch> batches)
hermes-core/src/main/java/com/ctrip/hermes/core/transport/command/PullMessageResultCommand.java:34
↓ 5 callersMethodaddDurableSysProperty
(String name, String value)
hermes-core/src/main/java/com/ctrip/hermes/core/message/ProducerMessage.java:127
↓ 5 callersMethodappendMessageAsync
(boolean isPriority, MessageBatchWithRawData batch, long expireTime)
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/MessageQueue.java:27
↓ 5 callersMethodassertAssignment
(Map<String, Assignment<Integer>> assignments, List<Topic> topics, List<ClientContext> brokers)
hermes-metaserver/src/test/java/com/ctrip/hermes/metaserver/broker/DefaultBrokerPartitionAssigningStrategyTest.java:186
↓ 5 callersMethodassertBrokerAssignmentRight
()
hermes-metaserver/src/test/java/com/ctrip/hermes/metaserver/fulltest/MetaServerBaseTest.java:277
↓ 5 callersMethodbecomeObserver
()
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/cluster/ClusterStateHolder.java:168
↓ 5 callersMethodbuildFetchResult
( // final Tpp tpp, final List<MessagePriority> msgs, final String filter)
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/storage/mysql/MySQLMessageQueueStorage.java:332
↓ 5 callersMethodcreateAssignments
( List<Pair<Pair<String, Integer>, ClientContext>> assignments)
hermes-metaserver/src/test/java/com/ctrip/hermes/metaserver/broker/DefaultBrokerPartitionAssigningStrategyTest.java:234
↓ 5 callersMethodcreateBrokers
(List<ClientContext> brokerContexts)
hermes-metaserver/src/test/java/com/ctrip/hermes/metaserver/broker/DefaultBrokerPartitionAssigningStrategyTest.java:271
↓ 5 callersMethodcreateServiceWithXml
(String fileName)
hermes-core/src/test/java/com/ctrip/hermes/core/cmessaging/DefaultCMessagingConfigServiceTest.java:95
↓ 5 callersMethodequals
<p> Compares two Strings, returning <code>true</code> if they are equal. </p> <p> <code>null</code>s are handled without exceptions. Two <code>null</
hermes-core/src/main/java/com/ctrip/hermes/core/utils/StringUtils.java:188
↓ 5 callersMethodfind
(long token)
hermes-consumer/src/main/java/com/ctrip/hermes/consumer/engine/notifier/ConsumerNotifier.java:20
↓ 5 callersMethodfindLastOffset
(Tpp tpp, int groupId)
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/storage/MessageQueueStorage.java:22
↓ 5 callersMethodgetAttachment
()
hermes-consumer/src/main/java/com/ctrip/hermes/consumer/engine/ack/DefaultAckHolder.java:133
↓ 5 callersMethodgetCallback
()
hermes-core/src/main/java/com/ctrip/hermes/core/message/ProducerMessage.java:151
↓ 5 callersMethodgetCodecType
()
hermes-core/src/main/java/com/ctrip/hermes/core/bo/ClientMeta.java:313
↓ 5 callersMethodgetCompressionAlgo
()
hermes-core/src/main/java/com/ctrip/hermes/core/message/payload/PayloadCodecFactory.java:85
↓ 5 callersMethodgetConnectionString
()
hermes-metaservice/src/main/java/com/ctrip/hermes/metaservice/zk/ZKClient.java:100
↓ 5 callersMethodgetConsumerConfig
(String topic)
hermes-env/src/main/java/com/ctrip/hermes/env/ClientEnvironment.java:10
↓ 5 callersMethodgetDatas
(long startOffset, int batchSize)
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/storage/mysql/cache/Page.java:68
↓ 5 callersMethodgetDurableProperties
()
hermes-core/src/main/java/com/ctrip/hermes/core/message/PartialDecodedMessage.java:83
↓ 5 callersMethodgetEnd
()
hermes-broker/src/main/java/com/ctrip/hermes/broker/ack/internal/ContinuousRange.java:18
↓ 5 callersMethodgetHandler
()
hermes-core/src/main/java/com/ctrip/hermes/core/message/codec/MessageCodecVersion.java:37
↓ 5 callersMethodgetIp
Gets the value of the 'ip' field.
hermes-kafka/src/test/java/com/ctrip/hermes/kafka/avro/AvroVisitEvent.java:56
↓ 5 callersMethodgetIp
Gets the value of the 'ip' field.
hermes-metaserver/src/test/java/com/ctrip/hermes/meta/avro/AvroVisitEvent.java:56
↓ 5 callersMethodgetKey
()
hermes-core/src/main/java/com/ctrip/hermes/core/message/PartialDecodedMessage.java:75
↓ 5 callersMethodgetListeningPort
()
hermes-env/src/main/java/com/ctrip/hermes/env/config/broker/BrokerConfigProvider.java:37
↓ 5 callersMethodgetSelectorOffset
()
hermes-core/src/main/java/com/ctrip/hermes/core/message/ProducerMessage.java:42
↓ 5 callersMethodgetTopic
()
hermes-core/src/main/java/com/ctrip/hermes/core/transport/command/v6/SendMessageCommandV6.java:89
↓ 5 callersMethodgetVersion
(ByteBuf buf)
hermes-core/src/main/java/com/ctrip/hermes/core/message/codec/DefaultMessageCodec.java:55
↓ 5 callersMethodgetVolatileProperties
()
hermes-core/src/main/java/com/ctrip/hermes/core/message/PartialDecodedMessage.java:87
↓ 5 callersMethodgetWebTarget
(int port)
hermes-metaserver/src/test/java/com/ctrip/hermes/metaserver/fulltest/MetaServerBaseTest.java:805
↓ 5 callersMethodhashCode
()
hermes-core/src/main/java/com/ctrip/hermes/core/meta/manual/ManualConfig.java:108
↓ 5 callersMethodisComplete
()
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/storage/mysql/cache/Page.java:139
↓ 5 callersMethodisConnected
()
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/cluster/ClusterStateHolder.java:244
↓ 5 callersMethodisConsuming
()
hermes-consumer/src/main/java/com/ctrip/hermes/consumer/DefaultConsumer.java:85
↓ 5 callersMethodisDone
()
hermes-consumer/src/main/java/com/ctrip/hermes/consumer/pull/RetriveSnapshot.java:122
↓ 5 callersMethodisLeaseAssigning
()
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/rest/resource/ManagementResource.java:141
↓ 5 callersMethodisPriorityMessageEnabled
()
hermes-core/src/main/java/com/ctrip/hermes/core/bo/ClientMeta.java:353
↓ 5 callersMethodmakeEndpoints
(EventBus eventBus, long version, ClusterStateHolder stateHolder, Map<String, Assignment<Integer>> brok
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/commons/EndpointMaker.java:57
↓ 5 callersMethodmerge
(Meta base, List<Server> newServers, Map<String, Map<Integer, Endpoint>> newPartition2Endpoint, List<Zo
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/meta/MetaMerger.java:25
↓ 5 callersMethodnext
(int batchSize, String filter, CallbackContext callbackCtx)
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/MessageQueueCursor.java:19
↓ 5 callersMethodnextOffset
(int delta)
hermes-core/src/main/java/com/ctrip/hermes/core/selector/OffsetGenerator.java:13
↓ 5 callersMethodreadChar
()
hermes-core/src/main/java/com/ctrip/hermes/core/utils/HermesPrimitiveCodec.java:161
↓ 5 callersMethodreadConfigFile
(String configPath)
hermes-env-provider/src/main/java/com/ctrip/hermes/env/provider/DefaultClientEnvironment.java:95
↓ 5 callersMethodreadEndpoint
()
hermes-core/src/main/java/com/ctrip/hermes/core/utils/HermesPrimitiveCodec.java:265
↓ 5 callersMethodrefreshMeta
()
hermes-metaservice/src/main/java/com/ctrip/hermes/metaservice/service/MetaService.java:15
↓ 5 callersMethodregister
(long token, Tpg tpg, int maxAckHolderSize)
hermes-consumer/src/main/java/com/ctrip/hermes/consumer/engine/ack/AckManager.java:12
↓ 5 callersMethodscanChanges
(long timeout, TimeUnit timeUnit)
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/consumer/ActiveConsumerListHolder.java:48
↓ 5 callersMethodsetBatchSize
(int batchSize)
hermes-broker/src/main/java/com/ctrip/hermes/broker/longpolling/PullMessageTask.java:75
↓ 5 callersMethodsetBornTime
(long bornTime)
hermes-core/src/main/java/com/ctrip/hermes/core/message/ProducerMessage.java:111
↓ 5 callersMethodsetChannel
(Channel channel)
hermes-broker/src/main/java/com/ctrip/hermes/broker/longpolling/PullMessageTask.java:79
↓ 5 callersMethodsetClientIp
(String clientIp)
hermes-broker/src/main/java/com/ctrip/hermes/broker/longpolling/PullMessageTask.java:51
↓ 5 callersMethodsetEndpointType
(String endpointType)
hermes-core/src/main/java/com/ctrip/hermes/core/bo/ClientMeta.java:369
↓ 5 callersMethodsetGroup
(String group)
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/commons/ClientContext.java:68
↓ 5 callersMethodsetIdc
(String idc)
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/commons/ClientContext.java:36
↓ 5 callersMethodsetMsgSeqNo
(int msgSeqNo)
hermes-core/src/main/java/com/ctrip/hermes/core/message/ProducerMessage.java:54
↓ 5 callersMethodsetPort
(int port)
hermes-core/src/main/java/com/ctrip/hermes/core/bo/HostPort.java:31
↓ 5 callersMethodsetPullCommandVersion
(int pullCommandVersion)
hermes-broker/src/main/java/com/ctrip/hermes/broker/longpolling/PullMessageTask.java:67
↓ 5 callersMethodsetTpg
(Tpg tpg)
hermes-broker/src/main/java/com/ctrip/hermes/broker/longpolling/PullMessageTask.java:55
↓ 5 callersMethodstart
()
hermes-broker/src/main/java/com/ctrip/hermes/broker/registry/BrokerRegistry.java:8
↓ 5 callersMethodupgradeVersion
()
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/event/Guard.java:20
↓ 5 callersMethodwriteChar
(char c)
hermes-core/src/main/java/com/ctrip/hermes/core/utils/HermesPrimitiveCodec.java:157
↓ 5 callersMethodwriteEndpoint
(Endpoint endpoint)
hermes-core/src/main/java/com/ctrip/hermes/core/utils/HermesPrimitiveCodec.java:253
↓ 4 callersMethodaddAckMsg
(boolean isPriority, boolean isResend, long msgSeq, int remainingRetries, long onMessageStartTimeMillis
hermes-core/src/main/java/com/ctrip/hermes/core/transport/command/v5/AckMessageCommandV5.java:154
↓ 4 callersMethodaddNackMsg
(boolean isPriority, boolean isResend, long msgSeq, int remainingRetries, long onMessageStartTimeMillis
hermes-core/src/main/java/com/ctrip/hermes/core/transport/command/v5/AckMessageCommandV5.java:175
↓ 4 callersMethodaddOffset
(Long offset, T ctx)
hermes-broker/src/main/java/com/ctrip/hermes/broker/ack/internal/EnumRange.java:20
↓ 4 callersMethodassign
(Map<String, ClientContext> brokers, List<Topic> topics, Map<String, Assignment<Integer>> originAssignm
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/broker/LeastAdjustmentBrokerPartitionAssigningStrategy.java:29
↓ 4 callersMethodbuild
()
hermes-kafka/src/test/java/com/ctrip/hermes/kafka/avro/AvroVisitEvent.java:236
↓ 4 callersMethodbuild
()
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/storage/mysql/cache/MessageCacheBuilder.java:84
↓ 4 callersMethodcollect
Attempt to fetch messages, wait until {@code expectedMessageCount} are got or timeout @param expectedMessageCount messages expected to fetc
hermes-consumer/src/main/java/com/ctrip/hermes/consumer/api/PullConsumerHolder.java:26
↓ 4 callersMethodcreateProducerMessage
(String topic, String body, String key, int seq, int partition, String partitionKey, long bornTime, boolean
hermes-core/src/test/java/com/ctrip/hermes/core/message/codec/DefaultMessageCodecTest.java:239
← previousnext →401–500 of 4,501, ranked by callers