Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/ctripcorp/hermes
/ functions
Functions
4,501 in github.com/ctripcorp/hermes
⨍
Functions
4,501
◇
Types & classes
841
↓ 755 callers
Method
get
(String name)
hermes-core/src/main/java/com/ctrip/hermes/core/pipeline/PipelineContext.java:11
↓ 529 callers
Method
put
(Object msg)
hermes-core/src/main/java/com/ctrip/hermes/core/pipeline/Pipeline.java:5
↓ 415 callers
Method
size
()
hermes-core/src/main/java/com/ctrip/hermes/core/message/TppConsumerMessageBatch.java:94
↓ 275 callers
Method
getValue
()
hermes-broker/src/main/java/com/ctrip/hermes/broker/status/BrokerStatusMonitor.java:38
↓ 228 callers
Method
format
(T obj)
hermes-env-provider/src/main/java/com/ctrip/hermes/env/provider/StringUtils.java:343
↓ 224 callers
Method
println
(Object o)
hermes-example/src/test/java/setup/SQLRunner.java:203
↓ 200 callers
Method
getKey
()
hermes-core/src/main/java/com/ctrip/hermes/core/message/ProducerMessage.java:70
↓ 191 callers
Method
get
(long pageNo)
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/storage/mysql/cache/PageCache.java:8
↓ 169 callers
Method
set
(String key, String value)
hermes-example/src/main/java/com/ctrip/hermes/example/common/Configuration.java:157
↓ 165 callers
Method
append
(boolean isPriority, MessageBatchWithRawData batch, long expireTime)
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/MessageQueueFlusher.java:18
↓ 165 callers
Method
getId
()
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/storage/mysql/dal/IdAware.java:8
↓ 164 callers
Method
writeInt
(int i)
hermes-core/src/main/java/com/ctrip/hermes/core/utils/HermesPrimitiveCodec.java:149
↓ 147 callers
Method
isEmpty
<p> Checks if a String is empty ("") or null. </p> <pre> StringUtils.isEmpty(null) = true StringUtils.isEmpty("") = true StringUtils.isEm
hermes-core/src/main/java/com/ctrip/hermes/core/utils/StringUtils.java:43
↓ 143 callers
Method
getLogger
()
hermes-broker/src/test/java/org/unidal/dal/jdbc/test/JdbcTestHelper.java:103
↓ 135 callers
Method
getName
()
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/event/EventHandler.java:13
↓ 131 callers
Method
readInt
()
hermes-core/src/main/java/com/ctrip/hermes/core/utils/HermesPrimitiveCodec.java:153
↓ 127 callers
Method
valueOf
(int type, int version)
hermes-core/src/main/java/com/ctrip/hermes/core/transport/command/CommandType.java:108
↓ 117 callers
Method
getProperty
(String name)
hermes-core/src/main/java/com/ctrip/hermes/core/message/ConsumerMessage.java:13
↓ 114 callers
Method
println
(Object o)
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/commons/CompositeException.java:194
↓ 113 callers
Method
getTopic
()
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/MessageQueue.java:23
↓ 100 callers
Method
sleep
(long timeMills)
hermes-consumer/src/main/java/com/ctrip/hermes/consumer/engine/notifier/StrictlyOrderedNotifyStrategy.java:58
↓ 93 callers
Method
getTopic
()
hermes-core/src/main/java/com/ctrip/hermes/core/message/ConsumerMessage.java:19
↓ 88 callers
Method
getHeader
()
hermes-core/src/main/java/com/ctrip/hermes/core/transport/command/Command.java:12
↓ 86 callers
Method
start
(ClusterStateHolder clusterStateHolder)
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/event/EventBus.java:17
↓ 85 callers
Method
create
(String namePrefix, boolean daemon)
hermes-core/src/main/java/com/ctrip/hermes/core/utils/HermesThreadFactory.java:32
↓ 84 callers
Method
contains
(long offset)
hermes-broker/src/main/java/com/ctrip/hermes/broker/ack/internal/DefaultAckHolder.java:158
↓ 78 callers
Method
getClass
(String name)
hermes-example/src/main/java/com/ctrip/hermes/example/common/Configuration.java:132
↓ 76 callers
Method
addData
(String key, Object value)
hermes-core/src/main/java/com/ctrip/hermes/core/log/BizEvent.java:24
↓ 75 callers
Method
getKey
()
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/DefaultMessageQueueManager.java:278
↓ 73 callers
Method
getPartition
()
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/MessageQueue.java:25
↓ 72 callers
Method
now
()
hermes-core/src/main/java/com/ctrip/hermes/core/service/SystemClockService.java:8
↓ 71 callers
Method
remove
(QueryLatestConsumerOffsetCommandV5 cmd)
hermes-consumer/src/main/java/com/ctrip/hermes/consumer/engine/monitor/QueryOffsetResultMonitor.java:15
↓ 68 callers
Method
lookup
(Class<T> clazz)
hermes-metaserver/src/test/java/com/ctrip/hermes/core/utils/PlexusComponentLocator.java:13
↓ 67 callers
Method
getBody
()
hermes-core/src/main/java/com/ctrip/hermes/core/message/ConsumerMessage.java:23
↓ 60 callers
Method
equals
(Object obj)
hermes-core/src/main/java/com/ctrip/hermes/core/bo/Tp.java:42
↓ 58 callers
Method
send
()
hermes-producer/src/main/java/com/ctrip/hermes/producer/api/Producer.java:21
↓ 56 callers
Method
getGroupId
(String exchangeName, String idAndQueueName)
hermes-core/src/main/java/com/ctrip/hermes/core/cmessaging/CMessagingConfigService.java:12
↓ 55 callers
Method
close
()
hermes-consumer/src/main/java/com/ctrip/hermes/consumer/pull/Committer.java:13
↓ 55 callers
Method
length
()
hermes-core/src/main/java/com/ctrip/hermes/core/transport/netty/Magic.java:35
↓ 55 callers
Method
writeString
(String str)
hermes-core/src/main/java/com/ctrip/hermes/core/utils/HermesPrimitiveCodec.java:84
↓ 54 callers
Method
readString
()
hermes-core/src/main/java/com/ctrip/hermes/core/utils/HermesPrimitiveCodec.java:94
↓ 53 callers
Method
message
(String topic, String partitionKey, Object body)
hermes-producer/src/main/java/com/ctrip/hermes/producer/api/Producer.java:12
↓ 52 callers
Method
getInstance
()
hermes-consumer/src/main/java/com/ctrip/hermes/consumer/api/Consumer.java:22
↓ 52 callers
Method
getType
()
hermes-core/src/main/java/com/ctrip/hermes/core/message/payload/PayloadCodec.java:6
↓ 52 callers
Method
writeLong
(long v)
hermes-core/src/main/java/com/ctrip/hermes/core/utils/HermesPrimitiveCodec.java:165
↓ 49 callers
Method
lookup
(Class<T> clazz)
hermes-core/src/main/java/com/ctrip/hermes/core/utils/PlexusComponentLocator.java:20
↓ 49 callers
Method
readLong
()
hermes-core/src/main/java/com/ctrip/hermes/core/utils/HermesPrimitiveCodec.java:169
↓ 48 callers
Method
addData
(List<Pair<Long, T>> idDataPairs)
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/storage/mysql/cache/Page.java:83
↓ 48 callers
Method
name
()
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/event/Task.java:10
↓ 44 callers
Method
getPartition
()
hermes-core/src/main/java/com/ctrip/hermes/core/message/ConsumerMessage.java:29
↓ 44 callers
Method
getSessionId
()
hermes-core/src/main/java/com/ctrip/hermes/core/lease/SessionIdAware.java:8
↓ 42 callers
Method
fail
(boolean shouldSleep)
hermes-core/src/main/java/com/ctrip/hermes/core/schedule/SchedulePolicy.java:5
↓ 42 callers
Method
getInstance
()
hermes-producer/src/main/java/com/ctrip/hermes/producer/api/Producer.java:14
↓ 41 callers
Method
build
()
hermes-metaserver/src/test/java/com/ctrip/hermes/meta/avro/AvroVisitEvent.java:236
↓ 41 callers
Method
getCommand
()
hermes-core/src/main/java/com/ctrip/hermes/core/transport/command/processor/CommandProcessorContext.java:22
↓ 41 callers
Method
getTopic
()
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/storage/mysql/dal/TopicPartitionAware.java:5
↓ 41 callers
Method
register
(T key, ExpireTimeHolder expireTimeHolder, SelectorCallback callback, long lastTriggerTime, Slot... slots)
hermes-core/src/main/java/com/ctrip/hermes/core/selector/Selector.java:9
↓ 39 callers
Method
getGlobalConfig
()
hermes-env/src/main/java/com/ctrip/hermes/env/ClientEnvironment.java:12
↓ 38 callers
Method
close
()
hermes-consumer/src/main/java/com/ctrip/hermes/consumer/api/Consumer.java:27
↓ 38 callers
Method
findTopicByName
(String topic)
hermes-core/src/main/java/com/ctrip/hermes/core/meta/MetaService.java:36
↓ 38 callers
Method
getOffset
()
hermes-core/src/main/java/com/ctrip/hermes/core/message/ConsumerMessage.java:31
↓ 38 callers
Method
next
(Object payload)
hermes-core/src/main/java/com/ctrip/hermes/core/pipeline/PipelineContext.java:7
↓ 37 callers
Method
getChannel
()
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/AckMessagesTask.java:101
↓ 35 callers
Method
addAssignment
(Key key, Map<String, ClientContext> clients)
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/commons/Assignment.java:24
↓ 35 callers
Method
channel
@param channel Mock channel to write ack/nack when received messages @return
hermes-consumer/src/test/java/com/ctrip/hermes/consumer/integration/assist/PullMessageAnswer.java:80
↓ 35 callers
Method
isNumeric
<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-core/src/main/java/com/ctrip/hermes/core/utils/StringUtils.java:305
↓ 35 callers
Method
parse
(ByteBuf buf, Header header)
hermes-core/src/main/java/com/ctrip/hermes/core/transport/command/Command.java:14
↓ 34 callers
Method
toString
()
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/commons/Assignment.java:35
↓ 34 callers
Method
trim
<p> Removes control characters (char <= 32) from both ends of this String, handling <code>null</code> by returning <code>null</code>. </p> <p> The
hermes-core/src/main/java/com/ctrip/hermes/core/utils/StringUtils.java:159
↓ 33 callers
Method
getRemainingRetries
()
hermes-core/src/main/java/com/ctrip/hermes/core/message/ConsumerMessage.java:39
↓ 31 callers
Method
getCorrelationId
()
hermes-core/src/main/java/com/ctrip/hermes/core/transport/command/Header.java:46
↓ 31 callers
Method
getPartition
()
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/storage/mysql/dal/TopicPartitionAware.java:7
↓ 31 callers
Method
lookup
(Class<T> clazz)
hermes-consumer/src/test/java/com/ctrip/hermes/core/utils/PlexusComponentLocator.java:13
↓ 30 callers
Method
getMessages
()
hermes-consumer/src/main/java/com/ctrip/hermes/consumer/api/PulledBatch.java:9
↓ 29 callers
Method
getExpireTime
()
hermes-core/src/main/java/com/ctrip/hermes/core/lease/Lease.java:37
↓ 29 callers
Method
nack
(long id, NackCallback<T> callback)
hermes-consumer/src/main/java/com/ctrip/hermes/consumer/engine/ack/AckHolder.java:13
↓ 29 callers
Method
printStackTrace
All of the following {@code printStackTrace} functionality is derived from JDK {@link Throwable} {@code printStackTrace}. In particular, the {@code Pr
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/commons/CompositeException.java:121
↓ 28 callers
Method
equals
(Object obj)
hermes-core/src/main/java/com/ctrip/hermes/core/meta/manual/ManualConfig.java:116
↓ 28 callers
Method
isPriority
()
hermes-core/src/main/java/com/ctrip/hermes/core/message/ConsumerMessage.java:33
↓ 28 callers
Method
isResend
()
hermes-core/src/main/java/com/ctrip/hermes/core/message/ConsumerMessage.java:37
↓ 27 callers
Method
ack
(long id, AckCallback<T> callback)
hermes-consumer/src/main/java/com/ctrip/hermes/consumer/engine/ack/AckHolder.java:11
↓ 27 callers
Method
fail
(boolean shouldSleep)
hermes-core/src/main/java/com/ctrip/hermes/core/schedule/ExponentialSchedulePolicy.java:16
↓ 27 callers
Method
getGroupId
()
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/storage/mysql/dal/TopicPartitionPriorityGroupAware.java:5
↓ 27 callers
Method
getMetricRegistryByTP
@param topic @param partition @return
hermes-metrics/src/main/java/com/ctrip/hermes/metrics/HermesMetricsRegistry.java:136
↓ 27 callers
Method
toString
()
hermes-core/src/main/java/com/ctrip/hermes/core/bo/Tp.java:61
↓ 27 callers
Method
unlock
()
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/commons/LeaseHolder.java:56
↓ 27 callers
Method
update
(T key, boolean refreshUpdateTimeWhenNoOb, Slot... slots)
hermes-core/src/main/java/com/ctrip/hermes/core/selector/Selector.java:11
↓ 26 callers
Method
getAssignments
()
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/commons/Assignment.java:31
↓ 26 callers
Method
lock
()
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/commons/LeaseHolder.java:52
↓ 26 callers
Method
poll
Attempt to fetch messages, return as soon as some messages are got. @param maxMessageCount max number of messages to return @param timeout
hermes-consumer/src/main/java/com/ctrip/hermes/consumer/api/PullConsumerHolder.java:15
↓ 26 callers
Method
readBoolean
()
hermes-core/src/main/java/com/ctrip/hermes/core/utils/HermesPrimitiveCodec.java:34
↓ 26 callers
Method
writeBoolean
(boolean b)
hermes-core/src/main/java/com/ctrip/hermes/core/utils/HermesPrimitiveCodec.java:30
↓ 25 callers
Method
getMeta
()
hermes-core/src/main/java/com/ctrip/hermes/core/meta/manual/ManualConfigService.java:16
↓ 25 callers
Method
getMsgSeq
()
hermes-consumer/src/main/java/com/ctrip/hermes/consumer/message/BrokerConsumerMessage.java:81
↓ 25 callers
Method
getVersion
()
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/event/Event.java:24
↓ 25 callers
Method
release
()
hermes-core/src/main/java/com/ctrip/hermes/core/transport/command/Command.java:18
↓ 25 callers
Method
writeAndFlush
(Channel channel, Object msg)
hermes-core/src/main/java/com/ctrip/hermes/core/transport/ChannelUtils.java:17
↓ 24 callers
Method
deepCopy
(T obj, Class<T> clazz)
hermes-core/src/main/java/com/ctrip/hermes/core/utils/ObjectUtils.java:6
↓ 24 callers
Method
getCorrelationId
()
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/AckMessagesTask.java:69
↓ 24 callers
Method
status
()
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/rest/resource/ManagementResource.java:50
next →
1–100 of 4,501, ranked by callers