MCPcopy Create free account

hub / github.com/ctripcorp/hermes / functions

Functions4,501 in github.com/ctripcorp/hermes

⨍ Functions 4,501◇ Types & classes 841
↓ 8 callersMethodgetPayload
@param consumerMsg @return
hermes-core/src/main/java/com/ctrip/hermes/core/message/codec/MessageCodecUtils.java:28
↓ 8 callersMethodgetReceiveTime
()
hermes-core/src/main/java/com/ctrip/hermes/core/transport/command/Command.java:20
↓ 8 callersMethodgetRemainingTime
()
hermes-core/src/main/java/com/ctrip/hermes/core/lease/Lease.java:47
↓ 8 callersMethodgetRemoteAddr
(String host, HttpServletRequest req)
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/rest/resource/LeaseResource.java:628
↓ 8 callersMethodgetSelector
()
hermes-core/src/main/java/com/ctrip/hermes/core/selector/SelectorManager.java:13
↓ 8 callersMethodgetTopic
()
hermes-core/src/main/java/com/ctrip/hermes/core/bo/Tpg.java:25
↓ 8 callersMethodisBlank
<p> Checks if a String is whitespace, empty ("") or null. </p> <pre> StringUtils.isBlank(null) = true StringUtils.isBlank("") = true Stri
hermes-env-provider/src/main/java/com/ctrip/hermes/env/provider/StringUtils.java:64
↓ 8 callersMethodisEmpty
<p> Checks if a String is empty ("") or null. </p> <pre> StringUtils.isEmpty(null) = true StringUtils.isEmpty("") = true StringUtils.isEm
hermes-env-provider/src/main/java/com/ctrip/hermes/env/provider/StringUtils.java:43
↓ 8 callersMethodisShouldSkip
()
hermes-core/src/main/java/com/ctrip/hermes/core/bo/SendMessageResult.java:32
↓ 8 callersMethodnewBuilder
()
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/storage/mysql/cache/MessageCacheBuilder.java:80
↓ 8 callersMethodprintMeter
(String name, Meter meter)
hermes-metrics/src/main/java/com/ctrip/hermes/metrics/MetricsUtils.java:9
↓ 8 callersMethodreadProperties
(ByteBuf buf)
hermes-core/src/test/java/com/ctrip/hermes/core/HermesCoreBaseTest.java:31
↓ 8 callersMethodrole
()
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/event/impl/FollowerInitEventHandler.java:192
↓ 8 callersMethodsetBody
(ByteBuf body)
hermes-core/src/main/java/com/ctrip/hermes/core/message/PartialDecodedMessage.java:39
↓ 8 callersMethodsetPartition
(int partition)
hermes-core/src/main/java/com/ctrip/hermes/core/message/TppConsumerMessageBatch.java:54
↓ 8 callersMethodsetResend
(boolean resend)
hermes-core/src/main/java/com/ctrip/hermes/core/message/TppConsumerMessageBatch.java:38
↓ 8 callersMethodsetTopic
(String topic)
hermes-core/src/main/java/com/ctrip/hermes/core/message/TppConsumerMessageBatch.java:70
↓ 8 callersMethodwriteMagic
(ByteBuf buf)
hermes-core/src/main/java/com/ctrip/hermes/core/transport/netty/Magic.java:31
↓ 7 callersMethodaddPayloadCodec
(PayloadCodec codec)
hermes-core/src/main/java/com/ctrip/hermes/core/message/payload/PayloadCodecCompositor.java:48
↓ 7 callersMethodaddResults
(Map<Integer, SendMessageResult> result, List<Integer> seqs, boolean success)
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/DefaultMessageQueueFlusher.java:191
↓ 7 callersMethodassertOnlyOneLeader
()
hermes-metaserver/src/test/java/com/ctrip/hermes/metaserver/fulltest/MetaServerBaseTest.java:224
↓ 7 callersMethodcompareWithPrecision
(long src, long dst, long precisionMillis)
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/storage/mysql/MySQLMessageQueueStorage.java:842
↓ 7 callersMethoddefaultPageCacheCoreSize
(int defaultPageCacheCoreSize)
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/storage/mysql/cache/MessageCacheBuilder.java:100
↓ 7 callersMethoddefaultPageCacheMaximumSize
(int defaultPageCacheMaximumSize)
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/storage/mysql/cache/MessageCacheBuilder.java:105
↓ 7 callersMethoddefaultPageSize
(int defaultPageSize)
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/storage/mysql/cache/MessageCacheBuilder.java:110
↓ 7 callersMethodfindRetryPolicyByTopicAndGroup
(String topic, String groupId)
hermes-core/src/main/java/com/ctrip/hermes/core/meta/MetaService.java:32
↓ 7 callersMethodgenerateEvent
()
hermes-kafka/src/test/java/com/ctrip/hermes/kafka/consumer/ProducerTest.java:43
↓ 7 callersMethodgetConsumerType
(String exchangeName, String identifier, String ip)
hermes-core/src/main/java/com/ctrip/hermes/core/cmessaging/CMessagingConfigService.java:16
↓ 7 callersMethodgetCorrelationId
()
hermes-broker/src/main/java/com/ctrip/hermes/broker/longpolling/PullMessageTask.java:103
↓ 7 callersMethodgetErrorMessage
()
hermes-core/src/main/java/com/ctrip/hermes/core/bo/SendMessageResult.java:40
↓ 7 callersMethodgetIdcPolicy
()
hermes-core/src/main/java/com/ctrip/hermes/core/bo/ClientMeta.java:333
↓ 7 callersMethodgetMessage
()
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/commons/CompositeException.java:63
↓ 7 callersMethodgetMessageCount
()
hermes-core/src/main/java/com/ctrip/hermes/core/transport/command/v6/SendMessageCommandV6.java:134
↓ 7 callersMethodgetMetaServerAssignmentRootZkPath
()
hermes-metaservice/src/main/java/com/ctrip/hermes/metaservice/zk/ZKPathUtils.java:53
↓ 7 callersMethodgetMetaServersZkPath
()
hermes-metaservice/src/main/java/com/ctrip/hermes/metaservice/zk/ZKPathUtils.java:39
↓ 7 callersMethodgetMsgSeqs
()
hermes-core/src/main/java/com/ctrip/hermes/core/transport/command/MessageBatchWithRawData.java:45
↓ 7 callersMethodgetNonPriorityOffset
()
hermes-core/src/main/java/com/ctrip/hermes/core/bo/Offset.java:32
↓ 7 callersMethodgetOriginId
()
hermes-core/src/main/java/com/ctrip/hermes/core/message/TppConsumerMessageBatch.java:135
↓ 7 callersMethodgetPartitionKey
()
hermes-core/src/main/java/com/ctrip/hermes/core/message/ProducerMessage.java:95
↓ 7 callersMethodgetPort
()
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/commons/ClientContext.java:56
↓ 7 callersMethodgetPriorityOffset
()
hermes-core/src/main/java/com/ctrip/hermes/core/bo/Offset.java:24
↓ 7 callersMethodgetScanIntervalMax
()
hermes-consumer/src/main/java/com/ctrip/hermes/consumer/api/PullConsumerConfig.java:23
↓ 7 callersMethodmaximumMessageCapacity
(int maximumMessageCapacity)
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/storage/mysql/cache/MessageCacheBuilder.java:115
↓ 7 callersMethodmessageLoader
(MessageLoader<?> messageLoader)
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/storage/mysql/cache/MessageCacheBuilder.java:120
↓ 7 callersMethodnewThread
(Runnable r)
hermes-core/src/main/java/com/ctrip/hermes/core/utils/HermesThreadFactory.java:87
↓ 7 callersMethodpageSize
()
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/storage/mysql/cache/PageCache.java:14
↓ 7 callersMethodprocess
(CommandProcessorContext ctx)
hermes-core/src/main/java/com/ctrip/hermes/core/transport/command/processor/CommandProcessor.java:11
↓ 7 callersMethodsetData
(byte[] data)
hermes-core/src/main/java/com/ctrip/hermes/core/transport/command/v6/FetchManualConfigResultCommandV6.java:27
↓ 7 callersMethodsetEndpoint
(Endpoint endpoint, long refreshTime)
hermes-core/src/main/java/com/ctrip/hermes/core/transport/endpoint/DefaultEndpointManager.java:225
↓ 7 callersMethodsetGroupId
(String groupId)
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/AckMessagesTask.java:97
↓ 7 callersMethodsetPort
(int port)
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/meta/MetaInfo.java:32
↓ 7 callersMethodsetPriority
(int priority)
hermes-core/src/main/java/com/ctrip/hermes/core/message/TppConsumerMessageBatch.java:46
↓ 7 callersMethodsetType
(CommandType type)
hermes-core/src/main/java/com/ctrip/hermes/core/transport/command/Header.java:42
↓ 7 callersMethodshrinkStrategy
(ShrinkStrategy<?> shrinkStrategy)
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/storage/mysql/cache/MessageCacheBuilder.java:125
↓ 7 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-env-provider/src/main/java/com/ctrip/hermes/env/provider/StringUtils.java:247
↓ 7 callersMethodtoString
()
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/storage/mysql/ack/DefaultMySQLMessageAckFlusher.java:375
↓ 7 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-env-provider/src/main/java/com/ctrip/hermes/env/provider/StringUtils.java:159
↓ 7 callersMethoduuid
()
hermes-broker/src/test/java/com/ctrip/hermes/broker/ack/internal/DefaultAckHolderTest.java:161
↓ 7 callersMethodwrite
(Command cmd)
hermes-core/src/main/java/com/ctrip/hermes/core/transport/endpoint/AbstractEndpointClient.java:251
↓ 6 callersMethodassertAcquireConsumerLeaseOnAll
(boolean expected, String topic, String group)
hermes-metaserver/src/test/java/com/ctrip/hermes/metaserver/fulltest/MetaServerBaseTest.java:404
↓ 6 callersMethodassertEndpoint
(String id, String host, int port, Endpoint actual)
hermes-metaserver/src/test/java/com/ctrip/hermes/metaserver/commons/EndpointMakerTest.java:99
↓ 6 callersMethodassertException
(String stringFormat)
hermes-core/src/test/java/com/ctrip/hermes/core/message/retry/FixedIntervalRetryPolicyTest.java:40
↓ 6 callersMethodassertRenewConsumerLeaseOnAll
(boolean expected, long leaseId, String topic, String group)
hermes-metaserver/src/test/java/com/ctrip/hermes/metaserver/fulltest/MetaServerBaseTest.java:430
↓ 6 callersMethodassign
(Map<K, List<V>> originAssigns, List<V> freeAssigns)
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/assign/AssignBalancer.java:7
↓ 6 callersMethodbizLog
(Tpp tpp, String consumerIp, String groupId, List<AckContext> ackContexts, boolean isResend, boolean ac
hermes-broker/src/main/java/com/ctrip/hermes/broker/transport/command/processor/AckMessageCommandProcessorV4.java:99
↓ 6 callersMethodbizLog
(Tpp tpp, String consumerIp, String groupId, List<AckContext> ackContexts, boolean isResend, boolean ac
hermes-broker/src/main/java/com/ctrip/hermes/broker/transport/command/processor/AckMessageCommandProcessorV3.java:99
↓ 6 callersMethodbizLog
(Tpp tpp, String consumerIp, String groupId, List<AckContext> ackContexts, boolean isResend, boolean ac
hermes-broker/src/main/java/com/ctrip/hermes/broker/transport/command/processor/AckMessageCommandProcessorV5.java:139
↓ 6 callersMethodcheck
(DefaultAckHolder<String> m, // final String expId, int totalOffsets, // List<Integer> success
hermes-broker/src/test/java/com/ctrip/hermes/broker/ack/internal/DefaultAckHolderTest.java:108
↓ 6 callersMethodcreateBroker
(String name, String ip, int port)
hermes-metaserver/src/test/java/com/ctrip/hermes/metaserver/commons/EndpointMakerTest.java:106
↓ 6 callersMethodcreateTagsMap
(String topic, int partition)
hermes-producer/src/main/java/com/ctrip/hermes/producer/status/ProducerStatusMonitor.java:62
↓ 6 callersMethoddecode
(String topic, ByteBuf buf, Class<?> bodyClazz)
hermes-core/src/main/java/com/ctrip/hermes/core/message/codec/DefaultMessageCodec.java:40
↓ 6 callersMethoddecode
(byte[] raw, Class<T> clazz)
hermes-core/src/main/java/com/ctrip/hermes/core/message/payload/PayloadCodec.java:10
↓ 6 callersMethodencode
(ProducerMessage<?> msg, ByteBuf buf)
hermes-core/src/main/java/com/ctrip/hermes/core/message/codec/DefaultMessageCodec.java:20
↓ 6 callersMethodencode
(String topic, Object obj)
hermes-core/src/main/java/com/ctrip/hermes/core/message/payload/PayloadCodec.java:8
↓ 6 callersMethodensurePath
(String path)
hermes-metaservice/src/main/java/com/ctrip/hermes/metaservice/service/DefaultZookeeperService.java:130
↓ 6 callersMethodexecuteLeaseOperation
(Key contextKey, LeaseOperationCallback callback)
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/commons/LeaseHolder.java:19
↓ 6 callersMethodfetchMessages
(Tpp tpp, Object startOffset, int batchSize, String filter)
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/storage/MessageQueueStorage.java:28
↓ 6 callersMethodgetAckTimeoutSecondsByTopicAndConsumerGroup
(String topic, String groupId)
hermes-core/src/main/java/com/ctrip/hermes/core/meta/MetaService.java:38
↓ 6 callersMethodgetAckedResendMsgs
()
hermes-core/src/main/java/com/ctrip/hermes/core/transport/command/v5/AckMessageCommandV5.java:200
↓ 6 callersMethodgetArg
()
hermes-core/src/main/java/com/ctrip/hermes/core/selector/TriggerResult.java:40
↓ 6 callersMethodgetBatch
()
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/storage/FetchResult.java:10
↓ 6 callersMethodgetBodyCodecType
()
hermes-core/src/main/java/com/ctrip/hermes/core/message/PartialDecodedMessage.java:23
↓ 6 callersMethodgetEndpointType
()
hermes-core/src/main/java/com/ctrip/hermes/core/bo/ClientMeta.java:325
↓ 6 callersMethodgetExecutor
()
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/event/EventBus.java:15
↓ 6 callersMethodgetExpireTime
()
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/AckMessagesTask.java:61
↓ 6 callersMethodgetGroup
()
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/commons/ClientContext.java:64
↓ 6 callersMethodgetGroupId
()
hermes-core/src/main/java/com/ctrip/hermes/core/bo/Tpg.java:33
↓ 6 callersMethodgetLastHeartbeatTime
()
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/commons/ClientContext.java:72
↓ 6 callersMethodgetMetaProxy
()
hermes-core/src/main/java/com/ctrip/hermes/core/meta/internal/MetaManager.java:9
↓ 6 callersMethodgetMetaProxy
()
hermes-core/src/main/java/com/ctrip/hermes/core/meta/internal/DefaultMetaService.java:74
↓ 6 callersMethodgetMetaServerPort
()
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/config/MetaServerConfig.java:66
↓ 6 callersMethodgetMetricRegistryByT
@param topic @return
hermes-metrics/src/main/java/com/ctrip/hermes/metrics/HermesMetricsRegistry.java:115
↓ 6 callersMethodgetNackedResendMsgs
()
hermes-core/src/main/java/com/ctrip/hermes/core/transport/command/v5/AckMessageCommandV5.java:208
↓ 6 callersMethodgetPartition
()
hermes-core/src/main/java/com/ctrip/hermes/core/bo/Tpg.java:29
↓ 6 callersMethodgetStatus
()
hermes-core/src/main/java/com/ctrip/hermes/core/message/ConsumerMessage.java:25
↓ 6 callersMethodgetStatusCode
()
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/rest/resource/LeaseResource.java:606
↓ 6 callersMethodgetSuccesses
()
hermes-core/src/main/java/com/ctrip/hermes/core/transport/command/SendMessageResultCommand.java:60
↓ 6 callersMethodgetTpg
()
hermes-broker/src/main/java/com/ctrip/hermes/broker/longpolling/PullMessageTask.java:95
↓ 6 callersMethodgetTransferCallback
()
hermes-core/src/main/java/com/ctrip/hermes/core/message/TppConsumerMessageBatch.java:86
↓ 6 callersMethodgetVolatileProperties
()
hermes-core/src/main/java/com/ctrip/hermes/core/message/PropertiesHolder.java:69
← previousnext →301–400 of 4,501, ranked by callers