MCPcopy Create free account

hub / github.com/ctripcorp/hermes / functions

Functions4,501 in github.com/ctripcorp/hermes

⨍ Functions 4,501◇ Types & classes 841
↓ 2 callersMethodsetId
(Long id)
hermes-core/src/main/java/com/ctrip/hermes/core/bo/ClientMeta.java:220
↓ 2 callersMethodsetId
(Integer id)
hermes-core/src/main/java/com/ctrip/hermes/core/bo/ClientMeta.java:435
↓ 2 callersMethodsetIdcPolicy
(String idcPolicy)
hermes-core/src/main/java/com/ctrip/hermes/core/bo/ClientMeta.java:377
↓ 2 callersMethodsetIdcPolicy
(String idcPolicy)
hermes-core/src/main/java/com/ctrip/hermes/core/bo/ClientMeta.java:439
↓ 2 callersMethodsetIp
(String ip)
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/commons/ClientContext.java:52
↓ 2 callersMethodsetLeaderInfo
(HostPort leaderInfo)
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/commons/MetaServerStatusResponse.java:87
↓ 2 callersMethodsetLeasesMapping
(Map<String, ClientLeaseInfo> leasesMapping)
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/commons/LeaseHolder.java:40
↓ 2 callersMethodsetMetaCache
(Meta newMeta)
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/meta/MetaHolder.java:213
↓ 2 callersMethodsetMetaHolder
(MetaHolder metaHolder)
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/event/impl/LeaderInitEventHandler.java:95
↓ 2 callersMethodsetMetaServerAssignments
(Assignment<String> metaServerAssignments)
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/commons/MetaServerStatusResponse.java:95
↓ 2 callersMethodsetMetaServers
(List<Server> metaServers)
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/meta/MetaHolder.java:177
↓ 2 callersMethodsetMsgSeq
(long msgSeq)
hermes-consumer/src/main/java/com/ctrip/hermes/consumer/message/BrokerConsumerMessage.java:85
↓ 2 callersMethodsetName
(String name)
hermes-core/src/main/java/com/ctrip/hermes/core/bo/ClientMeta.java:443
↓ 2 callersMethodsetOnMessageEndTimeMillis
(long onMessageEndTimeMillis)
hermes-core/src/main/java/com/ctrip/hermes/core/bo/AckContext.java:31
↓ 2 callersMethodsetOnMessageStartTimeMillis
(long onMessageStartTimeMillis)
hermes-core/src/main/java/com/ctrip/hermes/core/bo/AckContext.java:27
↓ 2 callersMethodsetOnMessageStartTimeMills
(long onMessageStartTimeMills)
hermes-core/src/main/java/com/ctrip/hermes/core/message/BaseConsumerMessage.java:35
↓ 2 callersMethodsetPartition
(int partition)
hermes-consumer/src/main/java/com/ctrip/hermes/consumer/message/BrokerConsumerMessage.java:77
↓ 2 callersMethodsetPriority
(boolean priority)
hermes-core/src/main/java/com/ctrip/hermes/core/message/ProducerMessage.java:91
↓ 2 callersMethodsetPriority
(boolean priority)
hermes-consumer/src/main/java/com/ctrip/hermes/consumer/message/BrokerConsumerMessage.java:69
↓ 2 callersMethodsetPriorityMessageEnabled
(Boolean priorityMessageEnabled)
hermes-core/src/main/java/com/ctrip/hermes/core/bo/ClientMeta.java:389
↓ 2 callersMethodsetPropertiesHolder
(PropertiesHolder propertiesHolder)
hermes-core/src/main/java/com/ctrip/hermes/core/message/ProducerMessage.java:119
↓ 2 callersMethodsetRefKey
(String key)
hermes-core/src/main/java/com/ctrip/hermes/core/message/BaseConsumerMessage.java:67
↓ 2 callersMethodsetRemainingRetries
(int remainingRetries)
hermes-core/src/main/java/com/ctrip/hermes/core/message/TppConsumerMessageBatch.java:143
↓ 2 callersMethodsetResend
(boolean resend)
hermes-consumer/src/main/java/com/ctrip/hermes/consumer/message/BrokerConsumerMessage.java:138
↓ 2 callersMethodsetRetryPolicy
(String retryPolicy)
hermes-core/src/main/java/com/ctrip/hermes/core/bo/ClientMeta.java:447
↓ 2 callersMethodsetRole
(Role role)
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/cluster/ClusterStateHolder.java:316
↓ 2 callersMethodsetSelectorOffset
(long selectorOffset)
hermes-core/src/main/java/com/ctrip/hermes/core/message/ProducerMessage.java:46
↓ 2 callersMethodsetStrictlyOrderingRetryPolicy
(StrictlyOrderingRetryPolicy policy)
hermes-consumer/src/main/java/com/ctrip/hermes/consumer/api/MessageListenerConfig.java:11
↓ 2 callersMethodsetSuccess
(boolean success)
hermes-core/src/main/java/com/ctrip/hermes/core/transport/command/SendMessageAckCommand.java:21
↓ 2 callersMethodsetSuccess
(boolean success)
hermes-core/src/main/java/com/ctrip/hermes/core/bo/SendMessageResult.java:44
↓ 2 callersMethodsetTopic
(String topic)
hermes-core/src/main/java/com/ctrip/hermes/core/bo/Tpp.java:22
↓ 2 callersMethodsetTopic
(String topic)
hermes-core/src/main/java/com/ctrip/hermes/core/bo/Tpg.java:37
↓ 2 callersMethodsetTopic
(String topic)
hermes-core/src/main/java/com/ctrip/hermes/core/message/BaseConsumerMessage.java:75
↓ 2 callersMethodsetTopic
(String topic)
hermes-core/src/main/java/com/ctrip/hermes/core/message/ProducerMessage.java:103
↓ 2 callersMethodshrink
()
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/storage/mysql/cache/PageCache.java:10
↓ 2 callersMethodshrinkAfterLastResizeTimeMillis
()
hermes-env/src/main/java/com/ctrip/hermes/env/config/broker/MySQLCacheConfigProvider.java:15
↓ 2 callersMethodstart
()
hermes-kafka/src/test/java/com/ctrip/hermes/kafka/server/MockKafka.java:94
↓ 2 callersMethodstart
()
hermes-metrics/src/main/java/com/ctrip/hermes/metrics/HttpMetricsServer.java:58
↓ 2 callersMethodstartBroker
()
hermes-example/src/test/java/com/ctrip/hermes/example/feature/producer/OneProducer.java:25
↓ 2 callersMethodstartConsumeThread
()
hermes-example/src/test/java/com/ctrip/hermes/example/performance/ProduceAndConsume.java:150
↓ 2 callersMethodstartLeaderLatch
()
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/cluster/ClusterStateHolder.java:139
↓ 2 callersMethodstop
()
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/MessageQueueCursor.java:29
↓ 2 callersMethodstop
()
hermes-broker/src/main/java/com/ctrip/hermes/broker/bootstrap/BrokerBootstrap.java:10
↓ 2 callersMethodstopBroker
()
hermes-broker/src/main/java/com/ctrip/hermes/broker/bootstrap/BrokerBootstrapListener.java:34
↓ 2 callersMethodtest
(boolean priority, boolean resend, int remainingRetries, boolean nack)
hermes-consumer/src/test/java/com/ctrip/hermes/consumer/pull/DefaultPullConsumerHolderTest.java:530
↓ 2 callersMethodtoString
()
hermes-core/src/main/java/com/ctrip/hermes/core/transport/command/v3/PullMessageCommandV3.java:71
↓ 2 callersMethodtoString
()
hermes-core/src/main/java/com/ctrip/hermes/core/transport/command/v4/PullMessageCommandV4.java:81
↓ 2 callersMethodtopicConsumerGroupNoAssignment
()
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/consumer/AbstractConsumerLeaseAllocator.java:123
↓ 2 callersMethodtopicNoAssignment
()
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/broker/DefaultBrokerLeaseAllocator.java:90
↓ 2 callersMethodtopicNonpriorityPageCacheSizes
()
hermes-env/src/main/java/com/ctrip/hermes/env/config/broker/MySQLCacheConfigProvider.java:47
↓ 2 callersMethodtopicNonpriorityPageSizes
()
hermes-env/src/main/java/com/ctrip/hermes/env/config/broker/MySQLCacheConfigProvider.java:49
↓ 2 callersMethodtopicPartitionNotAssignToBroker
(String topic, int partition)
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/broker/DefaultBrokerLeaseAllocator.java:95
↓ 2 callersMethodtopicPartitionNotAssignToConsumer
(Tpg tpg)
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/consumer/AbstractConsumerLeaseAllocator.java:128
↓ 2 callersMethodtopicPriorityPageCacheSizes
()
hermes-env/src/main/java/com/ctrip/hermes/env/config/broker/MySQLCacheConfigProvider.java:31
↓ 2 callersMethodtopicPriorityPageSizes
()
hermes-env/src/main/java/com/ctrip/hermes/env/config/broker/MySQLCacheConfigProvider.java:33
↓ 2 callersMethodtouch
()
hermes-core/src/main/java/com/ctrip/hermes/core/transport/endpoint/DefaultEndpointManager.java:231
↓ 2 callersMethodtryAcquireConsumerLease
(Tpg tpg, String sessionId)
hermes-core/src/main/java/com/ctrip/hermes/core/meta/MetaService.java:52
↓ 2 callersMethodtryAcquireLease
(T key)
hermes-core/src/main/java/com/ctrip/hermes/core/lease/LeaseManager.java:8
↓ 2 callersMethodtryRenewConsumerLease
(Tpg tpg, Lease lease, String sessionId)
hermes-core/src/main/java/com/ctrip/hermes/core/meta/MetaService.java:54
↓ 2 callersMethodtryRenewLease
(T key, Lease lease)
hermes-core/src/main/java/com/ctrip/hermes/core/lease/LeaseManager.java:10
↓ 2 callersMethodunifyPriorityAndResend
(ConsumerMessage<T> msg)
hermes-consumer/src/main/java/com/ctrip/hermes/consumer/pull/RetriveSnapshot.java:136
↓ 2 callersMethodupdate
(T key, boolean refreshUpdateTimeWhenNoOb, Slot... slots)
hermes-core/src/main/java/com/ctrip/hermes/core/selector/DefaultSelector.java:64
↓ 2 callersMethodupdateCmsgConfig
()
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/rest/resource/CmessageResource.java:84
↓ 2 callersMethodupdateConfig
()
hermes-core/src/main/java/com/ctrip/hermes/core/cmessaging/DefaultCMessagingConfigService.java:167
↓ 2 callersMethodupdateEndpoint
(String topic, int partition, Endpoint newEndpoint, long refreshTime)
hermes-core/src/main/java/com/ctrip/hermes/core/transport/endpoint/DefaultEndpointManager.java:105
↓ 2 callersMethodupdateExchangeInfo
()
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/rest/resource/CmessageResource.java:77
↓ 2 callersMethodupdateLeaderInfo
()
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/cluster/ClusterStateHolder.java:218
↓ 2 callersMethodupdateMetaServerList
()
hermes-core/src/main/java/com/ctrip/hermes/core/meta/remote/DefaultMetaServerLocator.java:59
↓ 2 callersMethodupdateZookeeperEnsemble
(com.ctrip.hermes.metaservice.model.ZookeeperEnsemble zookeeperEnsemble)
hermes-metaservice/src/main/java/com/ctrip/hermes/metaservice/service/DefaultZookeeperEnsembleService.java:73
↓ 2 callersMethodvalueOf
(String codecString)
hermes-core/src/main/java/com/ctrip/hermes/core/message/payload/PayloadCodecFactory.java:93
↓ 2 callersMethodwaitUntilTrigger
()
hermes-consumer/src/test/java/com/ctrip/hermes/consumer/integration/assist/LeaseAnswer.java:53
↓ 2 callersMethodwithDelay
(int delay)
hermes-consumer/src/test/java/com/ctrip/hermes/consumer/integration/assist/LeaseAnswer.java:48
↓ 2 callersMethodwriteLongIntMap
(Map<Long, Integer> map)
hermes-core/src/main/java/com/ctrip/hermes/core/utils/HermesPrimitiveCodec.java:296
↓ 2 callersMethodwriteMsgSeqMap
(HermesPrimitiveCodec codec, ConcurrentMap<Triple<Tpp, String, Boolean>, List<AckContext>> msgSeqMap)
hermes-core/src/main/java/com/ctrip/hermes/core/transport/command/AckMessageCommand.java:48
↓ 2 callersMethodwriteMsgSeqMap
(HermesPrimitiveCodec codec, ConcurrentMap<Triple<Tpp, String, Boolean>, List<AckContext>> msgSeqMap)
hermes-core/src/main/java/com/ctrip/hermes/core/transport/command/v2/AckMessageCommandV2.java:63
↓ 2 callersMethodwriteProperties
(List<Pair<String, String>> properties, ByteBuf buf)
hermes-core/src/test/java/com/ctrip/hermes/core/HermesCoreBaseTest.java:36
↓ 1 callersMethodackOffsetMessage
(OffsetMessage offsetMessage)
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/storage/mysql/ack/MySQLMessageAckFlusher.java:7
↓ 1 callersMethodackOffsetResend
(OffsetResend offsetResend)
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/storage/mysql/ack/MySQLMessageAckFlusher.java:9
↓ 1 callersMethodacquireBrokerLease
(int brokerPort, String topic, int partition, String sessionId, Integer metaServerPort)
hermes-metaserver/src/test/java/com/ctrip/hermes/metaserver/fulltest/MetaServerBaseTest.java:379
↓ 1 callersMethodacquireLease
(final String topic, final int partition, final String brokerName, final String ip, final int port)
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/broker/DefaultBrokerLeaseAllocator.java:115
↓ 1 callersMethodacquireLease
(final Tpg tpg, final String consumerName, final String ip)
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/consumer/AbstractConsumerLeaseAllocator.java:147
↓ 1 callersMethodacquireLease
(ConsumerLeaseKey key)
hermes-consumer/src/main/java/com/ctrip/hermes/consumer/engine/bootstrap/strategy/BaseConsumerTask.java:431
↓ 1 callersMethodaddAckRecord
(int partition, int priorityOrResend, long offset)
hermes-consumer/src/main/java/com/ctrip/hermes/consumer/pull/RetriveSnapshot.java:126
↓ 1 callersMethodaddAcked
(T item)
hermes-consumer/src/main/java/com/ctrip/hermes/consumer/engine/ack/AckHolderScanningResult.java:15
↓ 1 callersMethodaddBaseMetaVersionListener
(long version)
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/event/impl/FollowerInitEventHandler.java:128
↓ 1 callersMethodaddBaseMetaVersionListener
(long version)
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/event/impl/LeaderInitEventHandler.java:194
↓ 1 callersMethodaddBatches
(List<TppConsumerMessageBatch> batches)
hermes-core/src/main/java/com/ctrip/hermes/core/transport/command/v5/PullMessageResultCommandV5.java:45
↓ 1 callersMethodaddBatches
(List<TppConsumerMessageBatch> batches)
hermes-core/src/main/java/com/ctrip/hermes/core/transport/command/v3/PullMessageResultCommandV3.java:56
↓ 1 callersMethodaddBizData
(BizEvent event, Tpp tpp, String consumerIp, String groupId, AckContext ctx, boolean isResend, boolean
hermes-broker/src/main/java/com/ctrip/hermes/broker/transport/command/processor/AckMessageCommandProcessorV4.java:117
↓ 1 callersMethodaddBizData
(BizEvent event, Tpp tpp, String consumerIp, String groupId, AckContext ctx, boolean isResend, boolean
hermes-broker/src/main/java/com/ctrip/hermes/broker/transport/command/processor/AckMessageCommandProcessorV3.java:117
↓ 1 callersMethodaddBizData
(BizEvent event, Tpp tpp, String consumerIp, String groupId, AckContext ctx, boolean isResend, boolean
hermes-broker/src/main/java/com/ctrip/hermes/broker/transport/command/processor/AckMessageCommandProcessorV5.java:157
↓ 1 callersMethodaddBizData
(BizEvent event, Tpp tpp, String consumerIp, String groupId, AckContext ctx, boolean isResend, boolean
hermes-broker/src/main/java/com/ctrip/hermes/broker/transport/command/processor/AckMessageCommandProcessor.java:120
↓ 1 callersMethodaddCacheSizeGauge
(final String topic, final int partition, String name, final PageCache<?> pageCache)
hermes-broker/src/main/java/com/ctrip/hermes/broker/status/BrokerStatusMonitor.java:33
↓ 1 callersMethodaddConnectionStateListener
()
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/cluster/ClusterStateHolder.java:259
↓ 1 callersMethodaddConsumerProcessTime
(BizEvent event, long processTime)
hermes-broker/src/main/java/com/ctrip/hermes/broker/transport/command/processor/AckMessageCommandProcessorV4.java:113
↓ 1 callersMethodaddConsumerProcessTime
(BizEvent event, long processTime)
hermes-broker/src/main/java/com/ctrip/hermes/broker/transport/command/processor/AckMessageCommandProcessorV3.java:113
↓ 1 callersMethodaddConsumerProcessTime
(BizEvent event, long processTime)
hermes-broker/src/main/java/com/ctrip/hermes/broker/transport/command/processor/AckMessageCommandProcessorV5.java:153
↓ 1 callersMethodaddConsumerProcessTime
(BizEvent event, long startTime, long endTime)
hermes-broker/src/main/java/com/ctrip/hermes/broker/transport/command/processor/AckMessageCommandProcessor.java:114
↓ 1 callersMethodaddDurableAppProperty
(String name, String value)
hermes-core/src/main/java/com/ctrip/hermes/core/message/ProducerMessage.java:123
↓ 1 callersMethodaddMessage
(ProducerMessage<?> msg, SettableFuture<SendResult> future)
hermes-core/src/main/java/com/ctrip/hermes/core/transport/command/v6/SendMessageCommandV6.java:101
← previousnext →1,101–1,200 of 4,501, ranked by callers