MCPcopy Create free account

hub / github.com/ctripcorp/hermes / functions

Functions4,501 in github.com/ctripcorp/hermes

↓ 755 callersMethodget
(String name)
hermes-core/src/main/java/com/ctrip/hermes/core/pipeline/PipelineContext.java:11
↓ 529 callersMethodput
(Object msg)
hermes-core/src/main/java/com/ctrip/hermes/core/pipeline/Pipeline.java:5
↓ 415 callersMethodsize
()
hermes-core/src/main/java/com/ctrip/hermes/core/message/TppConsumerMessageBatch.java:94
↓ 275 callersMethodgetValue
()
hermes-broker/src/main/java/com/ctrip/hermes/broker/status/BrokerStatusMonitor.java:38
↓ 228 callersMethodformat
(T obj)
hermes-env-provider/src/main/java/com/ctrip/hermes/env/provider/StringUtils.java:343
↓ 224 callersMethodprintln
(Object o)
hermes-example/src/test/java/setup/SQLRunner.java:203
↓ 200 callersMethodgetKey
()
hermes-core/src/main/java/com/ctrip/hermes/core/message/ProducerMessage.java:70
↓ 191 callersMethodget
(long pageNo)
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/storage/mysql/cache/PageCache.java:8
↓ 169 callersMethodset
(String key, String value)
hermes-example/src/main/java/com/ctrip/hermes/example/common/Configuration.java:157
↓ 165 callersMethodappend
(boolean isPriority, MessageBatchWithRawData batch, long expireTime)
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/MessageQueueFlusher.java:18
↓ 165 callersMethodgetId
()
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/storage/mysql/dal/IdAware.java:8
↓ 164 callersMethodwriteInt
(int i)
hermes-core/src/main/java/com/ctrip/hermes/core/utils/HermesPrimitiveCodec.java:149
↓ 147 callersMethodisEmpty
<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 callersMethodgetLogger
()
hermes-broker/src/test/java/org/unidal/dal/jdbc/test/JdbcTestHelper.java:103
↓ 135 callersMethodgetName
()
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/event/EventHandler.java:13
↓ 131 callersMethodreadInt
()
hermes-core/src/main/java/com/ctrip/hermes/core/utils/HermesPrimitiveCodec.java:153
↓ 127 callersMethodvalueOf
(int type, int version)
hermes-core/src/main/java/com/ctrip/hermes/core/transport/command/CommandType.java:108
↓ 117 callersMethodgetProperty
(String name)
hermes-core/src/main/java/com/ctrip/hermes/core/message/ConsumerMessage.java:13
↓ 114 callersMethodprintln
(Object o)
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/commons/CompositeException.java:194
↓ 113 callersMethodgetTopic
()
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/MessageQueue.java:23
↓ 100 callersMethodsleep
(long timeMills)
hermes-consumer/src/main/java/com/ctrip/hermes/consumer/engine/notifier/StrictlyOrderedNotifyStrategy.java:58
↓ 93 callersMethodgetTopic
()
hermes-core/src/main/java/com/ctrip/hermes/core/message/ConsumerMessage.java:19
↓ 88 callersMethodgetHeader
()
hermes-core/src/main/java/com/ctrip/hermes/core/transport/command/Command.java:12
↓ 86 callersMethodstart
(ClusterStateHolder clusterStateHolder)
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/event/EventBus.java:17
↓ 85 callersMethodcreate
(String namePrefix, boolean daemon)
hermes-core/src/main/java/com/ctrip/hermes/core/utils/HermesThreadFactory.java:32
↓ 84 callersMethodcontains
(long offset)
hermes-broker/src/main/java/com/ctrip/hermes/broker/ack/internal/DefaultAckHolder.java:158
↓ 78 callersMethodgetClass
(String name)
hermes-example/src/main/java/com/ctrip/hermes/example/common/Configuration.java:132
↓ 76 callersMethodaddData
(String key, Object value)
hermes-core/src/main/java/com/ctrip/hermes/core/log/BizEvent.java:24
↓ 75 callersMethodgetKey
()
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/DefaultMessageQueueManager.java:278
↓ 73 callersMethodgetPartition
()
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/MessageQueue.java:25
↓ 72 callersMethodnow
()
hermes-core/src/main/java/com/ctrip/hermes/core/service/SystemClockService.java:8
↓ 71 callersMethodremove
(QueryLatestConsumerOffsetCommandV5 cmd)
hermes-consumer/src/main/java/com/ctrip/hermes/consumer/engine/monitor/QueryOffsetResultMonitor.java:15
↓ 68 callersMethodlookup
(Class<T> clazz)
hermes-metaserver/src/test/java/com/ctrip/hermes/core/utils/PlexusComponentLocator.java:13
↓ 67 callersMethodgetBody
()
hermes-core/src/main/java/com/ctrip/hermes/core/message/ConsumerMessage.java:23
↓ 60 callersMethodequals
(Object obj)
hermes-core/src/main/java/com/ctrip/hermes/core/bo/Tp.java:42
↓ 58 callersMethodsend
()
hermes-producer/src/main/java/com/ctrip/hermes/producer/api/Producer.java:21
↓ 56 callersMethodgetGroupId
(String exchangeName, String idAndQueueName)
hermes-core/src/main/java/com/ctrip/hermes/core/cmessaging/CMessagingConfigService.java:12
↓ 55 callersMethodclose
()
hermes-consumer/src/main/java/com/ctrip/hermes/consumer/pull/Committer.java:13
↓ 55 callersMethodlength
()
hermes-core/src/main/java/com/ctrip/hermes/core/transport/netty/Magic.java:35
↓ 55 callersMethodwriteString
(String str)
hermes-core/src/main/java/com/ctrip/hermes/core/utils/HermesPrimitiveCodec.java:84
↓ 54 callersMethodreadString
()
hermes-core/src/main/java/com/ctrip/hermes/core/utils/HermesPrimitiveCodec.java:94
↓ 53 callersMethodmessage
(String topic, String partitionKey, Object body)
hermes-producer/src/main/java/com/ctrip/hermes/producer/api/Producer.java:12
↓ 52 callersMethodgetInstance
()
hermes-consumer/src/main/java/com/ctrip/hermes/consumer/api/Consumer.java:22
↓ 52 callersMethodgetType
()
hermes-core/src/main/java/com/ctrip/hermes/core/message/payload/PayloadCodec.java:6
↓ 52 callersMethodwriteLong
(long v)
hermes-core/src/main/java/com/ctrip/hermes/core/utils/HermesPrimitiveCodec.java:165
↓ 49 callersMethodlookup
(Class<T> clazz)
hermes-core/src/main/java/com/ctrip/hermes/core/utils/PlexusComponentLocator.java:20
↓ 49 callersMethodreadLong
()
hermes-core/src/main/java/com/ctrip/hermes/core/utils/HermesPrimitiveCodec.java:169
↓ 48 callersMethodaddData
(List<Pair<Long, T>> idDataPairs)
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/storage/mysql/cache/Page.java:83
↓ 48 callersMethodname
()
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/event/Task.java:10
↓ 44 callersMethodgetPartition
()
hermes-core/src/main/java/com/ctrip/hermes/core/message/ConsumerMessage.java:29
↓ 44 callersMethodgetSessionId
()
hermes-core/src/main/java/com/ctrip/hermes/core/lease/SessionIdAware.java:8
↓ 42 callersMethodfail
(boolean shouldSleep)
hermes-core/src/main/java/com/ctrip/hermes/core/schedule/SchedulePolicy.java:5
↓ 42 callersMethodgetInstance
()
hermes-producer/src/main/java/com/ctrip/hermes/producer/api/Producer.java:14
↓ 41 callersMethodbuild
()
hermes-metaserver/src/test/java/com/ctrip/hermes/meta/avro/AvroVisitEvent.java:236
↓ 41 callersMethodgetCommand
()
hermes-core/src/main/java/com/ctrip/hermes/core/transport/command/processor/CommandProcessorContext.java:22
↓ 41 callersMethodgetTopic
()
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/storage/mysql/dal/TopicPartitionAware.java:5
↓ 41 callersMethodregister
(T key, ExpireTimeHolder expireTimeHolder, SelectorCallback callback, long lastTriggerTime, Slot... slots)
hermes-core/src/main/java/com/ctrip/hermes/core/selector/Selector.java:9
↓ 39 callersMethodgetGlobalConfig
()
hermes-env/src/main/java/com/ctrip/hermes/env/ClientEnvironment.java:12
↓ 38 callersMethodclose
()
hermes-consumer/src/main/java/com/ctrip/hermes/consumer/api/Consumer.java:27
↓ 38 callersMethodfindTopicByName
(String topic)
hermes-core/src/main/java/com/ctrip/hermes/core/meta/MetaService.java:36
↓ 38 callersMethodgetOffset
()
hermes-core/src/main/java/com/ctrip/hermes/core/message/ConsumerMessage.java:31
↓ 38 callersMethodnext
(Object payload)
hermes-core/src/main/java/com/ctrip/hermes/core/pipeline/PipelineContext.java:7
↓ 37 callersMethodgetChannel
()
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/AckMessagesTask.java:101
↓ 35 callersMethodaddAssignment
(Key key, Map<String, ClientContext> clients)
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/commons/Assignment.java:24
↓ 35 callersMethodchannel
@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 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-core/src/main/java/com/ctrip/hermes/core/utils/StringUtils.java:305
↓ 35 callersMethodparse
(ByteBuf buf, Header header)
hermes-core/src/main/java/com/ctrip/hermes/core/transport/command/Command.java:14
↓ 34 callersMethodtoString
()
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/commons/Assignment.java:35
↓ 34 callersMethodtrim
<p> Removes control characters (char &lt;= 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 callersMethodgetRemainingRetries
()
hermes-core/src/main/java/com/ctrip/hermes/core/message/ConsumerMessage.java:39
↓ 31 callersMethodgetCorrelationId
()
hermes-core/src/main/java/com/ctrip/hermes/core/transport/command/Header.java:46
↓ 31 callersMethodgetPartition
()
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/storage/mysql/dal/TopicPartitionAware.java:7
↓ 31 callersMethodlookup
(Class<T> clazz)
hermes-consumer/src/test/java/com/ctrip/hermes/core/utils/PlexusComponentLocator.java:13
↓ 30 callersMethodgetMessages
()
hermes-consumer/src/main/java/com/ctrip/hermes/consumer/api/PulledBatch.java:9
↓ 29 callersMethodgetExpireTime
()
hermes-core/src/main/java/com/ctrip/hermes/core/lease/Lease.java:37
↓ 29 callersMethodnack
(long id, NackCallback<T> callback)
hermes-consumer/src/main/java/com/ctrip/hermes/consumer/engine/ack/AckHolder.java:13
↓ 29 callersMethodprintStackTrace
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 callersMethodequals
(Object obj)
hermes-core/src/main/java/com/ctrip/hermes/core/meta/manual/ManualConfig.java:116
↓ 28 callersMethodisPriority
()
hermes-core/src/main/java/com/ctrip/hermes/core/message/ConsumerMessage.java:33
↓ 28 callersMethodisResend
()
hermes-core/src/main/java/com/ctrip/hermes/core/message/ConsumerMessage.java:37
↓ 27 callersMethodack
(long id, AckCallback<T> callback)
hermes-consumer/src/main/java/com/ctrip/hermes/consumer/engine/ack/AckHolder.java:11
↓ 27 callersMethodfail
(boolean shouldSleep)
hermes-core/src/main/java/com/ctrip/hermes/core/schedule/ExponentialSchedulePolicy.java:16
↓ 27 callersMethodgetGroupId
()
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/storage/mysql/dal/TopicPartitionPriorityGroupAware.java:5
↓ 27 callersMethodgetMetricRegistryByTP
@param topic @param partition @return
hermes-metrics/src/main/java/com/ctrip/hermes/metrics/HermesMetricsRegistry.java:136
↓ 27 callersMethodtoString
()
hermes-core/src/main/java/com/ctrip/hermes/core/bo/Tp.java:61
↓ 27 callersMethodunlock
()
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/commons/LeaseHolder.java:56
↓ 27 callersMethodupdate
(T key, boolean refreshUpdateTimeWhenNoOb, Slot... slots)
hermes-core/src/main/java/com/ctrip/hermes/core/selector/Selector.java:11
↓ 26 callersMethodgetAssignments
()
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/commons/Assignment.java:31
↓ 26 callersMethodlock
()
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/commons/LeaseHolder.java:52
↓ 26 callersMethodpoll
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 callersMethodreadBoolean
()
hermes-core/src/main/java/com/ctrip/hermes/core/utils/HermesPrimitiveCodec.java:34
↓ 26 callersMethodwriteBoolean
(boolean b)
hermes-core/src/main/java/com/ctrip/hermes/core/utils/HermesPrimitiveCodec.java:30
↓ 25 callersMethodgetMeta
()
hermes-core/src/main/java/com/ctrip/hermes/core/meta/manual/ManualConfigService.java:16
↓ 25 callersMethodgetMsgSeq
()
hermes-consumer/src/main/java/com/ctrip/hermes/consumer/message/BrokerConsumerMessage.java:81
↓ 25 callersMethodgetVersion
()
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/event/Event.java:24
↓ 25 callersMethodrelease
()
hermes-core/src/main/java/com/ctrip/hermes/core/transport/command/Command.java:18
↓ 25 callersMethodwriteAndFlush
(Channel channel, Object msg)
hermes-core/src/main/java/com/ctrip/hermes/core/transport/ChannelUtils.java:17
↓ 24 callersMethoddeepCopy
(T obj, Class<T> clazz)
hermes-core/src/main/java/com/ctrip/hermes/core/utils/ObjectUtils.java:6
↓ 24 callersMethodgetCorrelationId
()
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/AckMessagesTask.java:69
↓ 24 callersMethodstatus
()
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/rest/resource/ManagementResource.java:50
next →1–100 of 4,501, ranked by callers