MCPcopy Create free account

hub / github.com/ctripcorp/hermes / functions

Functions4,501 in github.com/ctripcorp/hermes

⨍ Functions 4,501◇ Types & classes 841
↓ 23 callersMethodgetLeasesMapping
()
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/commons/LeaseHolder.java:36
↓ 23 callersMethodisBlank
<p> Checks if a String is whitespace, empty ("") or null. </p> <pre> StringUtils.isBlank(null) = true StringUtils.isBlank("") = true Stri
hermes-core/src/main/java/com/ctrip/hermes/core/utils/StringUtils.java:64
↓ 23 callersMethodisTopicMatch
(String topicPattern, String topic)
hermes-core/src/main/java/com/ctrip/hermes/core/meta/internal/DefaultMetaService.java:131
↓ 23 callersMethodstart
()
hermes-consumer/src/main/java/com/ctrip/hermes/consumer/engine/bootstrap/strategy/ConsumerTask.java:9
↓ 22 callersMethodgetPort
()
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/meta/MetaInfo.java:28
↓ 22 callersMethodgetPriorityInt
()
hermes-core/src/main/java/com/ctrip/hermes/core/bo/Tpp.java:46
↓ 22 callersMethodgetRemoteIp
()
hermes-core/src/main/java/com/ctrip/hermes/core/transport/command/processor/CommandProcessorContext.java:30
↓ 22 callersMethodlogElapse
(String type, String name, long startTimestamp, int count, List<Pair<String, String>> datas, String sta
hermes-core/src/main/java/com/ctrip/hermes/core/utils/CatUtil.java:31
↓ 21 callersMethodclear
()
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/broker/BrokerAssignmentHolder.java:224
↓ 21 callersMethodonMessage
(List<ConsumerMessage<T>> msgs)
hermes-consumer/src/main/java/com/ctrip/hermes/consumer/api/MessageListener.java:9
↓ 21 callersMethodstop
()
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/MessageQueue.java:38
↓ 20 callersMethodisExpired
()
hermes-core/src/main/java/com/ctrip/hermes/core/lease/Lease.java:41
↓ 20 callersMethodisNotEmpty
(Collection<?> collection)
hermes-core/src/main/java/com/ctrip/hermes/core/utils/CollectionUtil.java:23
↓ 20 callersMethodsetId
(long id)
hermes-core/src/main/java/com/ctrip/hermes/core/lease/Lease.java:25
↓ 20 callersMethodstartMultipleMetaServers
(int number)
hermes-metaserver/src/test/java/com/ctrip/hermes/metaserver/fulltest/MetaServerBaseTest.java:180
↓ 19 callersMethodcorrelate
(Command req)
hermes-core/src/main/java/com/ctrip/hermes/core/transport/command/AbstractCommand.java:64
↓ 19 callersMethodlookup
(Class<T> clazz)
hermes-broker/src/test/java/com/ctrip/hermes/core/utils/PlexusComponentLocator.java:13
↓ 19 callersMethodmakeMessages
(int partition, boolean priority, String body, long offset)
hermes-consumer/src/test/java/com/ctrip/hermes/consumer/pull/DefaultPullConsumerHolderTest.java:587
↓ 19 callersMethodstartsWith
<p> Check if a String starts with a specified prefix. </p> <p> <code>null</code>s are handled without exceptions. Two <code>null</code> references ar
hermes-core/src/main/java/com/ctrip/hermes/core/utils/StringUtils.java:247
↓ 19 callersMethodvalueOf
(byte version)
hermes-core/src/main/java/com/ctrip/hermes/core/message/codec/MessageCodecVersion.java:41
↓ 18 callersMethodbrokerActionsWhenReceivedSendMessageCmd
(Answer<?>... answers)
hermes-producer/src/test/java/com/ctrip/hermes/producer/integration/BaseProducerIntegrationTest.java:168
↓ 18 callersMethodbuild
()
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/storage/mysql/cache/PageCacheBuilder.java:66
↓ 18 callersMethodgetCause
()
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/commons/CompositeException.java:70
↓ 18 callersMethodgetOnMessageEndTimeMillis
()
hermes-core/src/main/java/com/ctrip/hermes/core/bo/AckContext.java:39
↓ 18 callersMethodgetOnMessageStartTimeMillis
()
hermes-core/src/main/java/com/ctrip/hermes/core/bo/AckContext.java:35
↓ 18 callersMethodheartbeat
(String consumerName, long heartbeatTime, String ip)
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/consumer/ActiveConsumerList.java:20
↓ 18 callersMethodp
(int id)
hermes-metaserver/src/test/java/com/ctrip/hermes/metaserver/consumer/LeastAdjustmentOrderedConsumeConsumerPartitionAssigningStrategyTest.java:163
↓ 18 callersMethodtranslateToIntGroupId
(String topic, String groupId)
hermes-core/src/main/java/com/ctrip/hermes/core/meta/MetaService.java:48
↓ 17 callersMethodgetAssignment
(Key key)
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/commons/Assignment.java:20
↓ 17 callersMethodgetBrokerReceivedCmds
()
hermes-producer/src/test/java/com/ctrip/hermes/producer/integration/BaseProducerIntegrationTest.java:175
↓ 17 callersMethodgetMsgSeq
()
hermes-core/src/main/java/com/ctrip/hermes/core/bo/AckContext.java:19
↓ 17 callersMethodgetPartitions
()
hermes-core/src/main/java/com/ctrip/hermes/core/bo/ClientMeta.java:341
↓ 17 callersMethodgetPriority
()
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/storage/mysql/dal/TopicPartitionPriorityAware.java:5
↓ 17 callersMethodgetRefKey
()
hermes-core/src/main/java/com/ctrip/hermes/core/message/ConsumerMessage.java:21
↓ 17 callersMethodisSuccess
()
hermes-core/src/main/java/com/ctrip/hermes/core/bo/SendMessageResult.java:28
↓ 16 callersMethodequalsIgnoreCase
<p> Compares two Strings, returning <code>true</code> if they are equal ignoring the case. </p> <p> <code>null</code>s are handled without exceptions
hermes-core/src/main/java/com/ctrip/hermes/core/utils/StringUtils.java:217
↓ 16 callersMethodgetData
()
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/event/Event.java:28
↓ 16 callersMethodgetEndpoint
(String topic, int partition)
hermes-core/src/main/java/com/ctrip/hermes/core/transport/endpoint/EndpointManager.java:11
↓ 16 callersMethodgetNackedMsgs
()
hermes-core/src/main/java/com/ctrip/hermes/core/transport/command/v5/AckMessageCommandV5.java:204
↓ 16 callersMethodgetTime
()
hermes-core/src/main/java/com/ctrip/hermes/core/transport/command/QueryMessageOffsetByTimeCommand.java:39
↓ 16 callersMethodreadByte
()
hermes-core/src/main/java/com/ctrip/hermes/core/utils/HermesPrimitiveCodec.java:58
↓ 16 callersMethodwithRefKey
(String key)
hermes-producer/src/main/java/com/ctrip/hermes/producer/api/Producer.java:19
↓ 15 callersMethodcc
(String name)
hermes-metaserver/src/test/java/com/ctrip/hermes/metaserver/consumer/LeastAdjustmentOrderedConsumeConsumerPartitionAssigningStrategyTest.java:157
↓ 15 callersMethodcreateTopic
(String topicName, int partitionCount, String endpointType)
hermes-metaserver/src/test/java/com/ctrip/hermes/metaserver/broker/DefaultBrokerPartitionAssigningStrategyTest.java:258
↓ 15 callersMethodfindTopic
(String topicName, Meta meta)
hermes-core/src/main/java/com/ctrip/hermes/core/meta/internal/DefaultMetaService.java:83
↓ 15 callersMethodgetAckedMsgs
()
hermes-core/src/main/java/com/ctrip/hermes/core/transport/command/v5/AckMessageCommandV5.java:196
↓ 15 callersMethodgetEndpoints
()
hermes-core/src/main/java/com/ctrip/hermes/core/bo/ClientMeta.java:232
↓ 15 callersMethodgetHost
()
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/meta/MetaInfo.java:20
↓ 15 callersMethodgetMeta
()
hermes-core/src/main/java/com/ctrip/hermes/core/meta/internal/DefaultMetaService.java:65
↓ 15 callersMethodgetPropertiesHolder
()
hermes-core/src/main/java/com/ctrip/hermes/core/message/PropertiesHolderAware.java:5
↓ 15 callersMethodisNumeric
<p> Checks if the String contains only unicode digits. A decimal point is not a unicode digit and returns false. </p> <p> <code>null</code> will retu
hermes-env-provider/src/main/java/com/ctrip/hermes/env/provider/StringUtils.java:305
↓ 15 callersMethodm
(String consumer)
hermes-metaserver/src/test/java/com/ctrip/hermes/metaserver/consumer/LeastAdjustmentOrderedConsumeConsumerPartitionAssigningStrategyTest.java:151
↓ 15 callersMethodreaderIndexBack
(ByteBuf buf, int i)
hermes-core/src/main/java/com/ctrip/hermes/core/utils/HermesPrimitiveCodec.java:76
↓ 15 callersMethodsetPort
(int port)
hermes-metaserver/src/test/java/com/ctrip/hermes/metaserver/fulltest/LoadMocksListener.java:20
↓ 15 callersMethodtoString
()
hermes-kafka/src/test/java/com/ctrip/hermes/kafka/consumer/VisitEvent.java:36
↓ 15 callersMethodwriteAckToBroker
(AckMessageCommandV5 cmd)
hermes-consumer/src/main/java/com/ctrip/hermes/consumer/engine/ack/AckManager.java:22
↓ 15 callersMethodwriteNull
()
hermes-core/src/main/java/com/ctrip/hermes/core/utils/HermesPrimitiveCodec.java:409
↓ 14 callersMethodacquireLease
(String topic, int partition, String sessionId)
hermes-broker/src/main/java/com/ctrip/hermes/broker/lease/BrokerLeaseContainer.java:54
↓ 14 callersMethodassertRenewBrokerLeaseOnAll
(boolean expected, int brokerPort, String topic, int partition, long leaseId, String sessionId)
hermes-metaserver/src/test/java/com/ctrip/hermes/metaserver/fulltest/MetaServerBaseTest.java:387
↓ 14 callersMethodensurePath
(String path)
hermes-metaservice/src/main/java/com/ctrip/hermes/metaservice/service/ZookeeperService.java:13
↓ 14 callersMethodequals
(Object obj)
hermes-broker/src/main/java/com/ctrip/hermes/broker/ack/internal/EnumRange.java:40
↓ 14 callersMethodgetBornTime
()
hermes-consumer/src/main/java/com/ctrip/hermes/consumer/api/PulledBatch.java:23
↓ 14 callersMethodgetConsumerType
(String exchangeName, String identifier, String ip)
hermes-core/src/main/java/com/ctrip/hermes/core/cmessaging/DefaultCMessagingConfigService.java:108
↓ 14 callersMethodgetDurableProperties
()
hermes-core/src/main/java/com/ctrip/hermes/core/message/PropertiesHolder.java:53
↓ 14 callersMethodgetReceivedMessages
()
hermes-consumer/src/test/java/com/ctrip/hermes/consumer/integration/assist/TestMessageListener.java:67
↓ 14 callersMethodgetServers
(@QueryParam("clientTimeMillis") @DefaultValue("0") long clientTimeMillis, // @Context HttpServletRespo
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/rest/resource/MetaServerResource.java:49
↓ 14 callersMethodgetStorageType
()
hermes-core/src/main/java/com/ctrip/hermes/core/bo/ClientMeta.java:349
↓ 14 callersMethodgetTopics
()
hermes-core/src/main/java/com/ctrip/hermes/core/bo/ClientMeta.java:248
↓ 14 callersMethodgetVersion
()
hermes-core/src/main/java/com/ctrip/hermes/core/bo/ClientMeta.java:208
↓ 14 callersMethodisDone
()
hermes-kafka/src/main/java/com/ctrip/hermes/kafka/producer/KafkaFuture.java:46
↓ 14 callersMethodlog
(BizEvent event)
hermes-core/src/main/java/com/ctrip/hermes/core/log/BizLogger.java:5
↓ 14 callersMethodprint
(Object o)
hermes-example/src/test/java/setup/SQLRunner.java:197
↓ 14 callersMethodrecord
(int iter, int latency, int bytes, long time)
hermes-kafka/src/test/java/com/ctrip/hermes/kafka/perf/KafkaProducerPerf.java:129
↓ 14 callersMethodsetData
(ByteBuf data)
hermes-core/src/main/java/com/ctrip/hermes/core/message/TppConsumerMessageBatch.java:62
↓ 14 callersMethodsetHost
(String host)
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/meta/MetaInfo.java:24
↓ 14 callersMethodtoString
()
hermes-example/src/test/java/com/ctrip/hermes/example/ConsumerVerifier.java:361
↓ 13 callersMethodclose
()
hermes-core/src/main/java/com/ctrip/hermes/core/transport/endpoint/EndpointClient.java:13
↓ 13 callersMethodcontainsConsumerGroup
(String topicName, String groupId)
hermes-core/src/main/java/com/ctrip/hermes/core/meta/MetaService.java:58
↓ 13 callersMethodencode
(ProducerMessage<?> msg, ByteBuf buf)
hermes-core/src/main/java/com/ctrip/hermes/core/message/codec/MessageCodec.java:11
↓ 13 callersMethodgetId
()
hermes-core/src/main/java/com/ctrip/hermes/core/lease/Lease.java:29
↓ 13 callersMethodgetMessage
()
hermes-core/src/main/java/com/ctrip/hermes/core/result/SendResult.java:16
↓ 13 callersMethodisEnabled
()
hermes-env/src/main/java/com/ctrip/hermes/env/config/broker/MySQLCacheConfigProvider.java:13
↓ 13 callersMethodlookup
(Class<T> clazz)
hermes-producer/src/test/java/com/ctrip/hermes/core/utils/PlexusComponentLocator.java:13
↓ 13 callersMethodparseChannelRemoteAddr
(final Channel channel)
hermes-core/src/main/java/com/ctrip/hermes/core/transport/netty/NettyUtils.java:14
↓ 13 callersMethodserialize
(Object obj)
hermes-metaservice/src/main/java/com/ctrip/hermes/metaservice/zk/ZKSerializeUtils.java:12
↓ 13 callersMethodvalidate
(List<Topic> topics, String groupId)
hermes-consumer/src/main/java/com/ctrip/hermes/consumer/engine/DefaultEngine.java:71
↓ 13 callersMethodwithPriority
()
hermes-producer/src/main/java/com/ctrip/hermes/producer/api/Producer.java:25
↓ 12 callersMethodaddMessage
(ProducerMessage<?> msg, SettableFuture<SendResult> future)
hermes-core/src/main/java/com/ctrip/hermes/core/transport/command/SendMessageCommand.java:69
↓ 12 callersMethodassertClientContextEquals
(String clientName, String ip, long lastHeartbeatTime, ClientContext clientContext)
hermes-metaserver/src/test/java/com/ctrip/hermes/metaserver/TestHelper.java:16
↓ 12 callersMethodassertGetTopic
(MessageCache<TestValue> cache, String topic, int partition, long startOffsetExclusive, int batchSize)
hermes-broker/src/test/java/com/ctrip/hermes/broker/queue/storage/mysql/cache/DefaultMessageCacheTest.java:182
↓ 12 callersMethodassertProeprties
(Map<String, String> actual, List<Pair<String, String>> expects)
hermes-core/src/test/java/com/ctrip/hermes/core/message/codec/DefaultMessageCodecTest.java:271
↓ 12 callersMethodgetOffset
()
hermes-kafka/src/main/java/com/ctrip/hermes/kafka/producer/KafkaSendResult.java:23
↓ 12 callersMethodgetPartition
()
hermes-kafka/src/main/java/com/ctrip/hermes/kafka/producer/KafkaSendResult.java:27
↓ 12 callersMethodgetPort
()
hermes-core/src/main/java/com/ctrip/hermes/core/bo/HostPort.java:27
↓ 12 callersMethodgetTopic
()
hermes-core/src/main/java/com/ctrip/hermes/core/transport/command/MessageBatchWithRawData.java:41
↓ 12 callersMethodisAcquired
()
hermes-core/src/main/java/com/ctrip/hermes/core/lease/LeaseAcquireResponse.java:23
↓ 12 callersMethodisHermesProducerEnabled
(String exchangeName, String identifier, String ip)
hermes-core/src/main/java/com/ctrip/hermes/core/cmessaging/DefaultCMessagingConfigService.java:73
↓ 12 callersMethodlogEventPeriodically
(String type, String name)
hermes-core/src/main/java/com/ctrip/hermes/core/utils/CatUtil.java:51
↓ 12 callersMethodpageCount
()
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/storage/mysql/cache/PageCache.java:12
↓ 12 callersMethodreadBytes
()
hermes-core/src/main/java/com/ctrip/hermes/core/utils/HermesPrimitiveCodec.java:62
← previousnext →101–200 of 4,501, ranked by callers