MCPcopy Create free account

hub / github.com/ctripcorp/hermes / functions

Functions4,501 in github.com/ctripcorp/hermes

⨍ Functions 4,501◇ Types & classes 841
↓ 2 callersMethodgetDurableAppProperty
(String name)
hermes-core/src/main/java/com/ctrip/hermes/core/message/ProducerMessage.java:131
↓ 2 callersMethodgetDurableSysProperty
(String name)
hermes-core/src/main/java/com/ctrip/hermes/core/message/PropertiesHolder.java:41
↓ 2 callersMethodgetEnabledConsumerCheckIntervalTimeMillis
()
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/config/MetaServerConfig.java:26
↓ 2 callersMethodgetEncodedMessage
()
hermes-core/src/main/java/com/ctrip/hermes/core/message/payload/RawMessage.java:11
↓ 2 callersMethodgetEndpoint
(boolean shouldTouch)
hermes-core/src/main/java/com/ctrip/hermes/core/transport/endpoint/DefaultEndpointManager.java:210
↓ 2 callersMethodgetEndpointChannelAutoReconnectDelay
()
hermes-core/src/main/java/com/ctrip/hermes/core/config/CoreConfig.java:140
↓ 2 callersMethodgetEventTime
()
hermes-core/src/main/java/com/ctrip/hermes/core/log/BizEvent.java:34
↓ 2 callersMethodgetEventType
()
hermes-core/src/main/java/com/ctrip/hermes/core/log/BizEvent.java:30
↓ 2 callersMethodgetExpectedAffectedOffsetCount
()
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/storage/mysql/ack/DefaultMySQLMessageAckFlusher.java:371
↓ 2 callersMethodgetFilterPerTopicCacheSize
()
hermes-env/src/main/java/com/ctrip/hermes/env/config/broker/BrokerConfigProvider.java:57
↓ 2 callersMethodgetFilterTopicCacheSize
()
hermes-env/src/main/java/com/ctrip/hermes/env/config/broker/BrokerConfigProvider.java:59
↓ 2 callersMethodgetGroup
()
hermes-core/src/main/java/com/ctrip/hermes/core/transport/command/v5/AckMessageCommandV5.java:63
↓ 2 callersMethodgetGroupId
()
hermes-consumer/src/main/java/com/ctrip/hermes/consumer/engine/ConsumerContext.java:66
↓ 2 callersMethodgetHeader
()
hermes-core/src/main/java/com/ctrip/hermes/core/transport/command/AbstractCommand.java:25
↓ 2 callersMethodgetHealthCheckRegistry
()
hermes-metrics/src/main/java/com/ctrip/hermes/metrics/HermesMetricsRegistry.java:74
↓ 2 callersMethodgetHolderType
(int ackType)
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/DefaultMessageQueueManager.java:230
↓ 2 callersMethodgetId
()
hermes-core/src/main/java/com/ctrip/hermes/core/bo/ClientMeta.java:329
↓ 2 callersMethodgetId
(Map<String, String> requestProperties, int id)
hermes-core/src/main/java/com/ctrip/hermes/core/message/payload/assist/SchemaRegisterRestClient.java:32
↓ 2 callersMethodgetId
()
hermes-broker/src/test/java/com/ctrip/hermes/broker/queue/storage/mysql/cache/DefaultMessageCacheTest.java:227
↓ 2 callersMethodgetIdcs
()
hermes-core/src/main/java/com/ctrip/hermes/core/bo/ClientMeta.java:224
↓ 2 callersMethodgetIntervalMillis
()
hermes-core/src/main/java/com/ctrip/hermes/core/message/retry/FixedIntervalRetryPolicy.java:33
↓ 2 callersMethodgetJsonStringComplete
()
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/meta/MetaHolder.java:104
↓ 2 callersMethodgetLastOffset
(SimpleConsumer consumer, String topic, int partition, long whichTime, String clientName)
hermes-kafka/src/test/java/com/ctrip/hermes/kafka/SimpleConsumerExample.java:128
↓ 2 callersMethodgetLatestLoadedOffset
()
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/storage/mysql/cache/Page.java:117
↓ 2 callersMethodgetLeaseAcquireResponse
(URIBuilder uriBuilder, Object payload)
hermes-metaserver/src/test/java/com/ctrip/hermes/metaserver/fulltest/MetaServerBaseTest.java:771
↓ 2 callersMethodgetLeaseExpireRebalanceTriggerDelayMillis
()
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/config/MetaServerConfig.java:96
↓ 2 callersMethodgetLimit
(Map<String, Double> limits, String topic)
hermes-env-provider/src/main/java/com/ctrip/hermes/env/provider/DefaultBrokerConfigProvider.java:311
↓ 2 callersMethodgetMaxAndResetOffsetMessageHolder
(Triple<Integer, Boolean, Integer> key)
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/storage/mysql/ack/DefaultMySQLMessageAckFlusher.java:103
↓ 2 callersMethodgetMaxOffsetAndResetOffsetHolder
(T key, Map<T, AckOffsetHolder<K>> offsetHolders)
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/storage/mysql/ack/DefaultMySQLMessageAckFlusher.java:121
↓ 2 callersMethodgetMessageClazz
()
hermes-consumer/src/main/java/com/ctrip/hermes/consumer/engine/ConsumerContext.java:54
↓ 2 callersMethodgetMessageCount
()
hermes-core/src/main/java/com/ctrip/hermes/core/transport/command/v5/SendMessageCommandV5.java:124
↓ 2 callersMethodgetMessageQueueFetchNonPriorityMessageBySafeTriggerMinInterval
()
hermes-env/src/main/java/com/ctrip/hermes/env/config/broker/BrokerConfigProvider.java:87
↓ 2 callersMethodgetMessageQueueFetchPriorityMessageBySafeTriggerMinInterval
()
hermes-env/src/main/java/com/ctrip/hermes/env/config/broker/BrokerConfigProvider.java:85
↓ 2 callersMethodgetMessageQueueFetchResendMessageBySafeTriggerMinInterval
()
hermes-env/src/main/java/com/ctrip/hermes/env/config/broker/BrokerConfigProvider.java:89
↓ 2 callersMethodgetMessageQueueFlushCountLimit
(String topic)
hermes-env/src/main/java/com/ctrip/hermes/env/config/broker/BrokerConfigProvider.java:95
↓ 2 callersMethodgetMessageQueueFlushThreadCount
()
hermes-env/src/main/java/com/ctrip/hermes/env/config/broker/BrokerConfigProvider.java:83
↓ 2 callersMethodgetMessageRawDataBatches
()
hermes-core/src/main/java/com/ctrip/hermes/core/transport/command/v6/SendMessageCommandV6.java:130
↓ 2 callersMethodgetMessageRawDataBatches
()
hermes-core/src/main/java/com/ctrip/hermes/core/transport/command/v5/SendMessageCommandV5.java:120
↓ 2 callersMethodgetMessageRawDataBatches
()
hermes-core/src/main/java/com/ctrip/hermes/core/transport/command/v3/SendMessageCommandV3.java:109
↓ 2 callersMethodgetMeta
(int port)
hermes-metaserver/src/test/java/com/ctrip/hermes/metaserver/fulltest/MetaServerBaseTest.java:647
↓ 2 callersMethodgetMetaCacheRefreshIntervalSecond
()
hermes-core/src/main/java/com/ctrip/hermes/core/config/CoreConfig.java:128
↓ 2 callersMethodgetMetaEntity
()
hermes-metaservice/src/main/java/com/ctrip/hermes/metaservice/service/MetaService.java:13
↓ 2 callersMethodgetMetaJson
(boolean needComplete)
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/meta/MetaHolder.java:119
↓ 2 callersMethodgetMetaServerHost
()
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/config/MetaServerConfig.java:62
↓ 2 callersMethodgetMetaServerIpFetchInterval
()
hermes-core/src/main/java/com/ctrip/hermes/core/config/CoreConfig.java:112
↓ 2 callersMethodgetMetaServerList
()
hermes-core/src/main/java/com/ctrip/hermes/core/meta/remote/MetaServerLocator.java:7
↓ 2 callersMethodgetMetricRegistry
()
hermes-metrics/src/main/java/com/ctrip/hermes/metrics/JVMMetricsServletContextListener.java:28
↓ 2 callersMethodgetMinFireInterval
()
hermes-core/src/main/java/com/ctrip/hermes/core/selector/Slot.java:36
↓ 2 callersMethodgetMySQLCacheConfig
()
hermes-env/src/main/java/com/ctrip/hermes/env/config/broker/BrokerConfigProvider.java:53
↓ 2 callersMethodgetNackedMsgs
()
hermes-core/src/main/java/com/ctrip/hermes/core/transport/command/v3/AckMessageCommandV3.java:195
↓ 2 callersMethodgetNackedMsgs
()
hermes-core/src/main/java/com/ctrip/hermes/core/transport/command/v4/AckMessageCommandV4.java:204
↓ 2 callersMethodgetName
()
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/commons/BaseNodeCacheListener.java:65
↓ 2 callersMethodgetName
()
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/commons/BaseLeaseHolder.java:183
↓ 2 callersMethodgetName
()
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/commons/BasePathChildrenCacheListener.java:73
↓ 2 callersMethodgetNoEndpointWaitBaseMillis
()
hermes-consumer/src/main/java/com/ctrip/hermes/consumer/engine/config/ConsumerConfig.java:117
↓ 2 callersMethodgetNoEndpointWaitMaxMillis
()
hermes-consumer/src/main/java/com/ctrip/hermes/consumer/engine/config/ConsumerConfig.java:121
↓ 2 callersMethodgetNotifierThreadCount
(String topic)
hermes-consumer/src/main/java/com/ctrip/hermes/consumer/engine/config/ConsumerConfig.java:125
↓ 2 callersMethodgetNotifierWorkQueueSize
(String topic)
hermes-consumer/src/main/java/com/ctrip/hermes/consumer/engine/config/ConsumerConfig.java:230
↓ 2 callersMethodgetOffset
()
hermes-core/src/main/java/com/ctrip/hermes/core/transport/command/QueryOffsetResultCommand.java:14
↓ 2 callersMethodgetOffset
()
hermes-core/src/main/java/com/ctrip/hermes/core/transport/command/v5/QueryOffsetResultCommandV5.java:16
↓ 2 callersMethodgetOnMessageEnd
()
hermes-consumer/src/main/java/com/ctrip/hermes/consumer/engine/ack/DefaultAckManager.java:556
↓ 2 callersMethodgetOnMessageEnd
()
hermes-consumer/src/main/java/com/ctrip/hermes/consumer/engine/ack/DefaultAckManager.java:578
↓ 2 callersMethodgetOnMessageEndTimeMills
()
hermes-core/src/main/java/com/ctrip/hermes/core/message/BaseConsumerMessage.java:39
↓ 2 callersMethodgetOnMessageStart
()
hermes-consumer/src/main/java/com/ctrip/hermes/consumer/engine/ack/DefaultAckManager.java:552
↓ 2 callersMethodgetOnMessageStart
()
hermes-consumer/src/main/java/com/ctrip/hermes/consumer/engine/ack/DefaultAckManager.java:574
↓ 2 callersMethodgetOnMessageStartTimeMills
()
hermes-core/src/main/java/com/ctrip/hermes/core/message/BaseConsumerMessage.java:31
↓ 2 callersMethodgetOrCreateAckFlushHolder
(String topic)
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/storage/mysql/ack/DefaultMySQLMessageAckFlusher.java:171
↓ 2 callersMethodgetOrCreateAckOffsetHolder
(Map<K, AckOffsetHolder<T>> offsetHolders, K key, Comparator<T> comparator)
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/storage/mysql/ack/DefaultMySQLMessageAckFlusher.java:133
↓ 2 callersMethodgetPartition
()
hermes-core/src/main/java/com/ctrip/hermes/core/transport/command/SendMessageCommand.java:65
↓ 2 callersMethodgetPartition
()
hermes-core/src/main/java/com/ctrip/hermes/core/transport/command/v5/AckMessageCommandV5.java:59
↓ 2 callersMethodgetPartition
()
hermes-broker/src/test/java/com/ctrip/hermes/broker/queue/storage/mysql/cache/DefaultMessageCacheTest.java:235
↓ 2 callersMethodgetPrimaryEnsemble
()
hermes-metaservice/src/main/java/com/ctrip/hermes/metaservice/zk/ZKClient.java:63
↓ 2 callersMethodgetPrimaryEnsemble
()
hermes-broker/src/main/java/com/ctrip/hermes/broker/zk/ZKClient.java:134
↓ 2 callersMethodgetProduceTimeoutSeconds
(String topic)
hermes-producer/src/main/java/com/ctrip/hermes/producer/config/ProducerConfig.java:144
↓ 2 callersMethodgetProducerProperties
(String topic)
hermes-kafka/src/main/java/com/ctrip/hermes/kafka/producer/KafkaMessageSender.java:60
↓ 2 callersMethodgetProxyPassConnectTimeout
()
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/config/MetaServerConfig.java:84
↓ 2 callersMethodgetProxyPassReadTimeout
()
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/config/MetaServerConfig.java:88
↓ 2 callersMethodgetPullMessageAcceptTimeoutMillis
()
hermes-consumer/src/main/java/com/ctrip/hermes/consumer/engine/config/ConsumerConfig.java:138
↓ 2 callersMethodgetPullMessageSelectorOffsetLoaderThreadPoolSize
()
hermes-env/src/main/java/com/ctrip/hermes/env/config/broker/BrokerConfigProvider.java:65
↓ 2 callersMethodgetQueryMessageOffsetTimeoutMillis
()
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/config/MetaServerConfig.java:108
↓ 2 callersMethodgetRawDurableAppPropertyNames
()
hermes-core/src/main/java/com/ctrip/hermes/core/message/PropertiesHolder.java:79
↓ 2 callersMethodgetRemainingRetries
()
hermes-core/src/main/java/com/ctrip/hermes/core/message/TppConsumerMessageBatch.java:127
↓ 2 callersMethodgetRenewLeaseTimeMillisBeforeExpired
()
hermes-consumer/src/main/java/com/ctrip/hermes/consumer/engine/config/ConsumerConfig.java:93
↓ 2 callersMethodgetRequestToMetaServer
(final String path, final Map<String, String> requestParams)
hermes-core/src/main/java/com/ctrip/hermes/core/meta/remote/RemoteMetaProxy.java:159
↓ 2 callersMethodgetResult
()
hermes-core/src/main/java/com/ctrip/hermes/core/pipeline/PipelineContext.java:13
↓ 2 callersMethodgetResult
()
hermes-broker/src/main/java/com/ctrip/hermes/broker/ack/internal/DefaultAckHolder.java:112
↓ 2 callersMethodgetRole
()
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/commons/MetaServerStatusResponse.java:51
↓ 2 callersMethodgetSchemaString
(int schemaId)
hermes-core/src/main/java/com/ctrip/hermes/core/meta/internal/MetaProxy.java:26
↓ 2 callersMethodgetServer
()
hermes-assembly/src/main/java/com/ctrip/hermes/tomcat/HermesTomcat.java:50
↓ 2 callersMethodgetSessionId
()
hermes-consumer/src/main/java/com/ctrip/hermes/consumer/engine/ConsumerContext.java:46
↓ 2 callersMethodgetStart
()
hermes-broker/src/main/java/com/ctrip/hermes/broker/ack/internal/ContinuousRange.java:14
↓ 2 callersMethodgetState
()
hermes-consumer/src/main/java/com/ctrip/hermes/consumer/engine/ack/DefaultAckHolder.java:141
↓ 2 callersMethodgetStatusCode
()
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/rest/resource/MessageAssistResource.java:321
↓ 2 callersMethodgetTestResourceFile
(String deltaXml)
hermes-broker/src/test/java/org/unidal/dal/jdbc/test/JdbcTestHelper.java:107
↓ 2 callersMethodgetTopic
()
hermes-kafka/src/main/java/com/ctrip/hermes/kafka/producer/KafkaSendResult.java:31
↓ 2 callersMethodgetTopic
()
hermes-core/src/main/java/com/ctrip/hermes/core/transport/command/SendMessageCommand.java:61
↓ 2 callersMethodgetTopic
()
hermes-broker/src/test/java/com/ctrip/hermes/broker/queue/storage/mysql/cache/DefaultMessageCacheTest.java:231
↓ 2 callersMethodgetTpg
()
hermes-consumer/src/main/java/com/ctrip/hermes/consumer/engine/lease/ConsumerLeaseKey.java:21
↓ 2 callersMethodgetTrimmed
(String name)
hermes-example/src/main/java/com/ctrip/hermes/example/common/Configuration.java:86
↓ 2 callersMethodgetType
()
hermes-core/src/main/java/com/ctrip/hermes/core/transport/command/Header.java:38
← previousnext →901–1,000 of 4,501, ranked by callers