MCPcopy Create free account

hub / github.com/ctripcorp/hermes / functions

Functions4,501 in github.com/ctripcorp/hermes

⨍ Functions 4,501◇ Types & classes 841
↓ 4 callersMethodsetPort
(int port)
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/commons/ClientContext.java:60
↓ 4 callersMethodsetRemainingRetries
(int remainingRetries)
hermes-core/src/main/java/com/ctrip/hermes/core/message/BaseConsumerMessage.java:51
↓ 4 callersMethodsetRemainingRetries
(int remainingRetries)
hermes-core/src/main/java/com/ctrip/hermes/core/message/PartialDecodedMessage.java:35
↓ 4 callersMethodsetStartOffset
(Offset startOffset)
hermes-broker/src/main/java/com/ctrip/hermes/broker/longpolling/PullMessageTask.java:71
↓ 4 callersMethodsetStorageType
(String storageType)
hermes-core/src/main/java/com/ctrip/hermes/core/bo/ClientMeta.java:393
↓ 4 callersMethodsetWithOffset
(boolean withOffset)
hermes-broker/src/main/java/com/ctrip/hermes/broker/longpolling/PullMessageTask.java:131
↓ 4 callersMethodstart
()
hermes-broker/src/main/java/com/ctrip/hermes/broker/bootstrap/BrokerBootstrap.java:8
↓ 4 callersMethodstartServer
()
hermes-metaserver/src/test/java/com/ctrip/hermes/metaserver/StartMetaServer.java:33
↓ 4 callersMethodsucceess
()
hermes-core/src/main/java/com/ctrip/hermes/core/schedule/ExponentialSchedulePolicy.java:38
↓ 4 callersMethodtoClientLeaseResponse
(long timeDiff)
hermes-core/src/main/java/com/ctrip/hermes/core/lease/LeaseAcquireResponse.java:47
↓ 4 callersMethodtransform
(Object input)
hermes-core/src/main/java/com/ctrip/hermes/core/utils/CollectionUtil.java:69
↓ 4 callersMethodupdateAll
(boolean refreshUpdateTimeWhenNoOb, Slot... slots)
hermes-core/src/main/java/com/ctrip/hermes/core/selector/Selector.java:13
↓ 4 callersMethodupdateEndpoint
(String topic, int partition, Endpoint newEndpoint)
hermes-core/src/main/java/com/ctrip/hermes/core/transport/endpoint/EndpointManager.java:13
↓ 4 callersMethodupdateZkBaseMetaVersion
(long version)
hermes-metaservice/src/main/java/com/ctrip/hermes/metaservice/service/ZookeeperService.java:19
↓ 4 callersMethodwaitUntilConsumerStarted
(ConsumerHolder holder)
hermes-consumer/src/test/java/com/ctrip/hermes/consumer/integration/ConsumerIntegrationTest.java:45
↓ 4 callersMethodwriteMsgs
(HermesPrimitiveCodec codec, Map<Integer, List<AckContext>> msgs)
hermes-core/src/main/java/com/ctrip/hermes/core/transport/command/v5/AckMessageCommandV5.java:97
↓ 4 callersMethodwriteMsgs
(HermesPrimitiveCodec codec, Map<Integer, List<AckContext>> msgs)
hermes-core/src/main/java/com/ctrip/hermes/core/transport/command/v3/AckMessageCommandV3.java:88
↓ 4 callersMethodwriteMsgs
(HermesPrimitiveCodec codec, Map<Integer, List<AckContext>> msgs)
hermes-core/src/main/java/com/ctrip/hermes/core/transport/command/v4/AckMessageCommandV4.java:97
↓ 4 callersMethodwriteProperties
(ByteBuf propertiesBuf, ByteBuf out, HermesPrimitiveCodec codec)
hermes-core/src/main/java/com/ctrip/hermes/core/message/codec/internal/MessageCodecBinaryV1Handler.java:204
↓ 3 callersMethodack
(Tpp tpp, String groupId, boolean resend, long msgSeq)
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/storage/MessageQueueStorage.java:36
↓ 3 callersMethodacked
(long offset, boolean success)
hermes-broker/src/main/java/com/ctrip/hermes/broker/ack/internal/AckHolder.java:14
↓ 3 callersMethodaddNackMsg
(Tpp tpp, String groupId, boolean resend, long msgSeq, int remainingRetries, long onMessageStartTimeMil
hermes-core/src/main/java/com/ctrip/hermes/core/transport/command/AckMessageCommand.java:123
↓ 3 callersMethodaddOneTopicToMeta
(String name)
hermes-metaserver/src/test/java/com/ctrip/hermes/metaserver/fulltest/MetaServerBaseTest.java:499
↓ 3 callersMethodassertOK
(String stringFormat, int retryTimes, int interval)
hermes-core/src/test/java/com/ctrip/hermes/core/message/retry/FixedIntervalRetryPolicyTest.java:27
↓ 3 callersMethodassign
(List<Server> metaServers, List<Topic> topics, Assignment<String> originAssignments)
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/meta/LeastAdjustmentMetaServerAssigningStrategy.java:34
↓ 3 callersMethodbaseMetaCreateTopic
(Topic topic)
hermes-metaserver/src/test/java/com/ctrip/hermes/metaserver/fulltest/MetaServerBaseTest.java:522
↓ 3 callersMethodcancel
(SendMessageCommandV6 cmd)
hermes-producer/src/main/java/com/ctrip/hermes/producer/monitor/SendMessageResultMonitor.java:17
↓ 3 callersMethodcloseLeaderLatch
()
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/cluster/ClusterStateHolder.java:182
↓ 3 callersMethodcollect
(Collection inputCollection, Transformer transformer)
hermes-core/src/main/java/com/ctrip/hermes/core/utils/CollectionUtil.java:31
↓ 3 callersMethodcomputePartitionNo
(String key, int partitionCount)
hermes-core/src/main/java/com/ctrip/hermes/core/message/partition/PartitioningStrategy.java:8
↓ 3 callersMethodcontainsConsumerGroup
(String topicName, String groupId)
hermes-core/src/main/java/com/ctrip/hermes/core/meta/internal/DefaultMetaService.java:349
↓ 3 callersMethodcreateBrokerLease
(String brokerName, String ip, int port, long leaseId, long leasExpireTime)
hermes-metaserver/src/test/java/com/ctrip/hermes/metaserver/commons/EndpointMakerTest.java:112
↓ 3 callersMethodcreateCache
(int coreSize, int maxSize, int pageSize, int pageLoadIntervalMillis, ResizeListener<Long> resizeListen
hermes-broker/src/test/java/com/ctrip/hermes/broker/queue/storage/mysql/cache/DefaultPageCacheTest.java:180
↓ 3 callersMethodcreateTagsMap
(CommandType type)
hermes-core/src/main/java/com/ctrip/hermes/core/status/StatusMonitor.java:48
↓ 3 callersMethoddecodePartial
(ByteBuf buf)
hermes-core/src/main/java/com/ctrip/hermes/core/message/codec/DefaultMessageCodec.java:33
↓ 3 callersMethoddelayRetry
(ScheduledExecutorService executor, final Task task)
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/event/impl/BaseEventHandler.java:98
↓ 3 callersMethoddoCheckHolders
(Pair<Boolean, String> pg, BatchResult<MessageMeta> result, boolean isResend)
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/AbstractMessageQueue.java:276
↓ 3 callersMethoddoNackAndAck
(String groupId, boolean isPriority, boolean isResend, List<AckContext> ackedContexts, List<AckContext
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/AbstractMessageQueue.java:368
↓ 3 callersMethoddoTestConsumeFailed
()
hermes-consumer/src/test/java/com/ctrip/hermes/consumer/integration/ConsumerIntegrationTest.java:192
↓ 3 callersMethodequals
(Object obj)
hermes-consumer/src/main/java/com/ctrip/hermes/consumer/engine/lease/ConsumerLeaseKey.java:34
↓ 3 callersMethodexecuteUpdate
(String dataSource, String sql)
hermes-broker/src/test/java/org/unidal/dal/jdbc/test/JdbcTestHelper.java:97
↓ 3 callersMethodfetchMetaInfo
(MetaInfo metaInfo)
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/event/impl/LeaderMetaFetcher.java:11
↓ 3 callersMethodfindLastResendOffset
(Tpg tpg)
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/storage/MessageQueueStorage.java:24
↓ 3 callersMethodfindMessagesByOffsets
(boolean isPriority, List<Long> offsets)
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/MessageQueue.java:36
↓ 3 callersMethodfindTpgAckHolder
(String topic, int partition, long token)
hermes-consumer/src/main/java/com/ctrip/hermes/consumer/engine/ack/DefaultAckManager.java:123
↓ 3 callersMethodgenerateCorrelationId
()
hermes-core/src/main/java/com/ctrip/hermes/core/transport/command/CorrelationIdGenerator.java:10
↓ 3 callersMethodgenerateEvent
()
hermes-kafka/src/test/java/com/ctrip/hermes/kafka/avro/KafkaAvroTest.java:124
↓ 3 callersMethodgetAckCommandMaxSize
()
hermes-consumer/src/main/java/com/ctrip/hermes/consumer/engine/config/ConsumerConfig.java:238
↓ 3 callersMethodgetAckMsgs
()
hermes-core/src/main/java/com/ctrip/hermes/core/transport/command/AckMessageCommand.java:133
↓ 3 callersMethodgetActiveConsumerList
(Pair<String, String> topicGroup)
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/consumer/ActiveConsumerListHolder.java:82
↓ 3 callersMethodgetAssignment
(String topic)
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/broker/BrokerAssignmentHolder.java:129
↓ 3 callersMethodgetAwaitingOffset
()
hermes-core/src/main/java/com/ctrip/hermes/core/selector/SlotMatchResult.java:33
↓ 3 callersMethodgetBrokerLease
()
hermes-broker/src/main/java/com/ctrip/hermes/broker/longpolling/PullMessageTask.java:119
↓ 3 callersMethodgetBrokerLeaseClientSideAdjustmentTimeMills
()
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/config/MetaServerConfig.java:54
↓ 3 callersMethodgetBrokerLeaseTimeMillis
()
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/config/MetaServerConfig.java:50
↓ 3 callersMethodgetConfigedMetaServers
()
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/meta/MetaHolder.java:281
↓ 3 callersMethodgetConsumerGroups
()
hermes-core/src/main/java/com/ctrip/hermes/core/bo/ClientMeta.java:317
↓ 3 callersMethodgetConsumerLeaseClientSideAdjustmentTimeMills
()
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/config/MetaServerConfig.java:34
↓ 3 callersMethodgetConsumerLeaseTimeMillis
()
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/config/MetaServerConfig.java:30
↓ 3 callersMethodgetConsumerRetryPolicy
()
hermes-core/src/main/java/com/ctrip/hermes/core/bo/ClientMeta.java:321
↓ 3 callersMethodgetData
()
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/DefaultMessageQueueManager.java:282
↓ 3 callersMethodgetDelimiter
()
hermes-example/src/test/java/setup/SQLRunner.java:193
↓ 3 callersMethodgetDoneRange
()
hermes-broker/src/main/java/com/ctrip/hermes/broker/ack/internal/BatchResult.java:20
↓ 3 callersMethodgetExpireTime
()
hermes-broker/src/main/java/com/ctrip/hermes/broker/longpolling/PullMessageTask.java:91
↓ 3 callersMethodgetFailRange
()
hermes-broker/src/main/java/com/ctrip/hermes/broker/ack/internal/BatchResult.java:16
↓ 3 callersMethodgetFilter
()
hermes-broker/src/main/java/com/ctrip/hermes/broker/longpolling/PullMessageTask.java:99
↓ 3 callersMethodgetGroup
()
hermes-consumer/src/main/java/com/ctrip/hermes/consumer/engine/ConsumerContext.java:62
↓ 3 callersMethodgetIndex
()
hermes-core/src/main/java/com/ctrip/hermes/core/selector/Slot.java:28
↓ 3 callersMethodgetLatch
()
hermes-consumer/src/test/java/com/ctrip/hermes/consumer/integration/assist/TestMessageListener.java:18
↓ 3 callersMethodgetMessageCount
()
hermes-core/src/main/java/com/ctrip/hermes/core/transport/command/v3/SendMessageCommandV3.java:113
↓ 3 callersMethodgetMessageRawDataBatches
()
hermes-core/src/main/java/com/ctrip/hermes/core/transport/command/SendMessageCommand.java:98
↓ 3 callersMethodgetMeta
()
hermes-core/src/main/java/com/ctrip/hermes/core/meta/manual/DefaultManualConfigService.java:52
↓ 3 callersMethodgetMetaServerName
()
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/config/MetaServerConfig.java:58
↓ 3 callersMethodgetMetricRegistryByTPG
@param topic @param partition @param group @return
hermes-metrics/src/main/java/com/ctrip/hermes/metrics/HermesMetricsRegistry.java:159
↓ 3 callersMethodgetNackMessages
()
hermes-consumer/src/main/java/com/ctrip/hermes/consumer/pull/OffsetHistory.java:65
↓ 3 callersMethodgetNackMsgs
()
hermes-core/src/main/java/com/ctrip/hermes/core/transport/command/AckMessageCommand.java:137
↓ 3 callersMethodgetNonPriorityOffset
()
hermes-consumer/src/main/java/com/ctrip/hermes/consumer/api/OffsetAndMetadata.java:28
↓ 3 callersMethodgetOffset
()
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/storage/FetchResult.java:18
↓ 3 callersMethodgetOffsetRecords
()
hermes-consumer/src/main/java/com/ctrip/hermes/consumer/pull/RetriveSnapshot.java:155
↓ 3 callersMethodgetOffsetStorage
()
hermes-consumer/src/main/java/com/ctrip/hermes/consumer/engine/Subscriber.java:85
↓ 3 callersMethodgetPartition
()
hermes-core/src/main/java/com/ctrip/hermes/core/transport/command/v6/SendMessageCommandV6.java:93
↓ 3 callersMethodgetPartition
()
hermes-core/src/main/java/com/ctrip/hermes/core/transport/command/v5/QueryLatestConsumerOffsetCommandV5.java:37
↓ 3 callersMethodgetPrimaryIdc
()
hermes-core/src/main/java/com/ctrip/hermes/core/meta/MetaService.java:66
↓ 3 callersMethodgetPriorityOffset
()
hermes-consumer/src/main/java/com/ctrip/hermes/consumer/api/OffsetAndMetadata.java:24
↓ 3 callersMethodgetProducerMessages
()
hermes-core/src/main/java/com/ctrip/hermes/core/transport/command/SendMessageCommand.java:210
↓ 3 callersMethodgetProducerMessages
()
hermes-core/src/main/java/com/ctrip/hermes/core/transport/command/v6/SendMessageCommandV6.java:247
↓ 3 callersMethodgetProperties
(String topic, String consumerGroup)
hermes-kafka/src/main/java/com/ctrip/hermes/kafka/service/KafkaService.java:71
↓ 3 callersMethodgetPropertyNames
()
hermes-core/src/main/java/com/ctrip/hermes/core/message/ConsumerMessage.java:15
↓ 3 callersMethodgetPullMessageCommandVersion
()
hermes-broker/src/main/java/com/ctrip/hermes/broker/longpolling/PullMessageTask.java:123
↓ 3 callersMethodgetQueryOffsetTimeoutMillis
()
hermes-consumer/src/main/java/com/ctrip/hermes/consumer/engine/config/ConsumerConfig.java:134
↓ 3 callersMethodgetRetryPolicy
()
hermes-core/src/main/java/com/ctrip/hermes/core/bo/ClientMeta.java:431
↓ 3 callersMethodgetRole
()
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/cluster/ClusterStateHolder.java:195
↓ 3 callersMethodgetSchema
(Object object)
hermes-core/src/main/java/com/ctrip/hermes/core/message/payload/assist/kafka/avro/AbstractKafkaAvroSerDe.java:57
↓ 3 callersMethodgetServletFromUri
(String fullUri, String topic, String partition, String group)
hermes-metrics/src/main/java/com/ctrip/hermes/metrics/HermesServlet.java:199
↓ 3 callersMethodgetShutdownRequestPort
()
hermes-env/src/main/java/com/ctrip/hermes/env/config/broker/BrokerConfigProvider.java:41
↓ 3 callersMethodgetStartOffset
()
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/storage/mysql/cache/Page.java:121
↓ 3 callersMethodgetStorages
()
hermes-core/src/main/java/com/ctrip/hermes/core/bo/ClientMeta.java:256
↓ 3 callersMethodgetThreadGroup
()
hermes-core/src/main/java/com/ctrip/hermes/core/utils/HermesThreadFactory.java:28
↓ 3 callersMethodgetTimeout
()
hermes-core/src/main/java/com/ctrip/hermes/core/transport/command/v5/AckMessageCommandV5.java:51
↓ 3 callersMethodgetTimestamp
()
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/meta/MetaInfo.java:36
← previousnext →601–700 of 4,501, ranked by callers