MCPcopy Create free account

hub / github.com/ctripcorp/hermes / functions

Functions4,501 in github.com/ctripcorp/hermes

⨍ Functions 4,501◇ Types & classes 841
↓ 12 callersMethodreadOffset
()
hermes-core/src/main/java/com/ctrip/hermes/core/utils/HermesPrimitiveCodec.java:173
↓ 12 callersMethodrefreshEndpoint
(String topic, int partition)
hermes-core/src/main/java/com/ctrip/hermes/core/transport/endpoint/EndpointManager.java:15
↓ 12 callersMethodsendAsync
(String topic, String partitionKey, Object body, String refKey, List<Pair<String, String>> appPropertie
hermes-producer/src/test/java/com/ctrip/hermes/producer/integration/BaseProducerIntegrationTest.java:139
↓ 12 callersMethodsendSync
()
hermes-producer/src/main/java/com/ctrip/hermes/producer/api/Producer.java:23
↓ 12 callersMethodsubmit
(final ProducerMessage<?> msg)
hermes-producer/src/main/java/com/ctrip/hermes/producer/sender/BrokerMessageSender.java:406
↓ 12 callersMethodwriteBytes
(byte[] bytes)
hermes-core/src/main/java/com/ctrip/hermes/core/utils/HermesPrimitiveCodec.java:38
↓ 12 callersMethodwriteOffset
(Offset offset)
hermes-core/src/main/java/com/ctrip/hermes/core/utils/HermesPrimitiveCodec.java:207
↓ 11 callersMethodassertAcquireBrokerLeaseOnAll
(boolean expected, int brokerPort, String topic, int partition, String sessionId)
hermes-metaserver/src/test/java/com/ctrip/hermes/metaserver/fulltest/MetaServerBaseTest.java:371
↓ 11 callersMethodassertMsg
(ProducerMessage<?> msg, String topic, String partitionKey, Object body, String refKey, List<Pair<Strin
hermes-producer/src/test/java/com/ctrip/hermes/producer/integration/BaseProducerIntegrationTest.java:179
↓ 11 callersMethodconfigure
(ManualConfig config)
hermes-core/src/main/java/com/ctrip/hermes/core/meta/manual/ManualConfigService.java:12
↓ 11 callersMethodcreateTopic
(String topic, int partition, int replication)
hermes-kafka/src/test/java/com/ctrip/hermes/kafka/server/MockKafka.java:56
↓ 11 callersMethodfindPartitionByTopicAndPartition
(String topic, int partition)
hermes-core/src/main/java/com/ctrip/hermes/core/meta/MetaService.java:30
↓ 11 callersMethodget
()
hermes-kafka/src/main/java/com/ctrip/hermes/kafka/producer/KafkaFuture.java:25
↓ 11 callersMethodgetBytes
(ByteArrayInputStream bais)
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/storage/mysql/MySQLMessageQueueStorage.java:396
↓ 11 callersMethodgetHost
()
hermes-core/src/main/java/com/ctrip/hermes/core/bo/HostPort.java:19
↓ 11 callersMethodgetIdc
()
hermes-env/src/main/java/com/ctrip/hermes/env/ClientEnvironment.java:16
↓ 11 callersMethodgetLease
()
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/commons/ClientLeaseInfo.java:24
↓ 11 callersMethodgetLease
()
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/MessageQueueCursor.java:23
↓ 11 callersMethodgetMsgs
()
hermes-core/src/main/java/com/ctrip/hermes/core/transport/command/v6/SendMessageCommandV6.java:85
↓ 11 callersMethodgetName
()
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/commons/ClientContext.java:40
↓ 11 callersMethodgetRetryTimes
()
hermes-core/src/main/java/com/ctrip/hermes/core/message/retry/RetryPolicy.java:9
↓ 11 callersMethodinit
()
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/MessageQueueCursor.java:21
↓ 11 callersMethodisClosed
()
hermes-consumer/src/main/java/com/ctrip/hermes/consumer/engine/bootstrap/strategy/BaseConsumerTask.java:146
↓ 11 callersMethodisMatch
(String tag, String filter, Map<String, String> source)
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/storage/filter/Filter.java:6
↓ 11 callersMethodmockBrokerRegisterToZK
(int brokerCount)
hermes-metaserver/src/test/java/com/ctrip/hermes/metaserver/fulltest/MetaServerBaseTest.java:446
↓ 11 callersMethodnewBuilder
()
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/storage/mysql/cache/PageCacheBuilder.java:62
↓ 11 callersMethodoffer
(final CommandProcessorContext ctx)
hermes-core/src/main/java/com/ctrip/hermes/core/transport/command/processor/CommandProcessorManager.java:43
↓ 11 callersMethodsetPartition
(int partition)
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/AckMessagesTask.java:89
↓ 11 callersMethodsetTopic
(String topic)
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/AckMessagesTask.java:81
↓ 11 callersMethodstopMultipleMetaServersRandomly
(int number)
hermes-metaserver/src/test/java/com/ctrip/hermes/metaserver/fulltest/MetaServerBaseTest.java:188
↓ 11 callersMethodtoString
()
hermes-broker/src/test/java/com/ctrip/hermes/broker/queue/storage/mysql/cache/DefaultMessageCacheTest.java:239
↓ 10 callersMethodbrokerActions4PollMessageCmd
(Answer<?> answer)
hermes-consumer/src/test/java/com/ctrip/hermes/consumer/integration/BaseConsumerIntegrationTest.java:126
↓ 10 callersMethodcountDownAll
()
hermes-consumer/src/test/java/com/ctrip/hermes/consumer/integration/assist/TestMessageListener.java:58
↓ 10 callersMethodcreateProducerMessage
(String topic, String body, String key, int partition, String partitionKey, long bornTime, boolean isPr
hermes-core/src/test/java/com/ctrip/hermes/core/transport/command/SendMessageCommandTest.java:232
↓ 10 callersMethodfindEndpointByTopicAndPartition
(String topic, int partition)
hermes-core/src/main/java/com/ctrip/hermes/core/meta/MetaService.java:28
↓ 10 callersMethodgetBatch
()
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/DefaultMessageQueueFlusher.java:361
↓ 10 callersMethodgetDefaultLeaseAcquireOrRenewRetryDelayMillis
()
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/config/MetaServerConfig.java:22
↓ 10 callersMethodgetInt
(String name, int defaultValue)
hermes-example/src/main/java/com/ctrip/hermes/example/common/Configuration.java:94
↓ 10 callersMethodgetLease
()
hermes-core/src/main/java/com/ctrip/hermes/core/lease/LeaseAcquireResponse.java:31
↓ 10 callersMethodgetMessageCount
()
hermes-core/src/main/java/com/ctrip/hermes/core/transport/command/SendMessageCommand.java:102
↓ 10 callersMethodgetMessageMetas
()
hermes-core/src/main/java/com/ctrip/hermes/core/message/TppConsumerMessageBatch.java:74
↓ 10 callersMethodgetProperties
()
hermes-core/src/main/java/com/ctrip/hermes/core/transport/command/Header.java:54
↓ 10 callersMethodgetSlotMatchResults
()
hermes-core/src/main/java/com/ctrip/hermes/core/selector/CallbackContext.java:21
↓ 10 callersMethodisPriority
()
hermes-core/src/main/java/com/ctrip/hermes/core/bo/Tpp.java:42
↓ 10 callersMethodpubEvent
(Event event)
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/event/EventBus.java:13
↓ 10 callersMethodreceiveCount
(int count)
hermes-consumer/src/test/java/com/ctrip/hermes/consumer/integration/assist/TestMessageListener.java:22
↓ 10 callersMethodscan
()
hermes-broker/src/main/java/com/ctrip/hermes/broker/ack/internal/AckHolder.java:16
↓ 10 callersMethodsetCallback
(CompletionCallback<SendResult> callback)
hermes-producer/src/main/java/com/ctrip/hermes/producer/api/Producer.java:29
↓ 10 callersMethodsetPriority
(boolean priority)
hermes-core/src/main/java/com/ctrip/hermes/core/bo/Tpp.java:30
↓ 10 callersMethodshutdown
()
hermes-kafka/src/main/java/com/ctrip/hermes/kafka/engine/KafkaConsumerBootstrap.java:212
↓ 10 callersMethodsubmit
(PartitionOperation<T> operation)
hermes-consumer/src/main/java/com/ctrip/hermes/consumer/pull/DefaultCommitter.java:105
↓ 10 callersMethodwaitUntilReceivedAllMessage
(long timeoutInMillisecond)
hermes-consumer/src/test/java/com/ctrip/hermes/consumer/integration/assist/TestMessageListener.java:33
↓ 9 callersMethodaddPartition
(Partition partition)
hermes-core/src/main/java/com/ctrip/hermes/core/bo/ClientMeta.java:308
↓ 9 callersMethodassertAllStopped
()
hermes-metaserver/src/test/java/com/ctrip/hermes/metaserver/fulltest/MetaServerBaseTest.java:495
↓ 9 callersMethodassign
(List<Partition> partitions, Map<String, ClientContext> currentConsumers, Map<Integer, Map<String, Clie
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/consumer/LeastAdjustmentConsumerPartitionAssigningStrategy.java:32
↓ 9 callersMethodcommitSync
Commit these messages synchronously
hermes-consumer/src/main/java/com/ctrip/hermes/consumer/api/PulledBatch.java:21
↓ 9 callersMethodconcurrencyLevel
(int concurrencyLevel)
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/storage/mysql/cache/MessageCacheBuilder.java:90
↓ 9 callersMethodconnect
(final Endpoint endpoint, final EndpointChannel endpointChannel)
hermes-core/src/main/java/com/ctrip/hermes/core/transport/endpoint/AbstractEndpointClient.java:137
↓ 9 callersMethodcreator
@param creator Generate mock messages to simulate PullMessageResultCommand @return
hermes-consumer/src/test/java/com/ctrip/hermes/consumer/integration/assist/PullMessageAnswer.java:90
↓ 9 callersMethoddecode
(String topic, ByteBuf buf, Class<?> bodyClazz)
hermes-core/src/main/java/com/ctrip/hermes/core/message/codec/MessageCodec.java:15
↓ 9 callersMethoddeserialize
(byte[] bytes, Class<T> clazz)
hermes-metaservice/src/main/java/com/ctrip/hermes/metaservice/zk/ZKSerializeUtils.java:16
↓ 9 callersMethodexecute
(LeasesContext leasesContext)
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/commons/LeaseHolder.java:63
↓ 9 callersMethodfindStorageByTopic
(String topic)
hermes-core/src/main/java/com/ctrip/hermes/core/meta/MetaService.java:34
↓ 9 callersMethodgetAcked
()
hermes-consumer/src/main/java/com/ctrip/hermes/consumer/engine/ack/AckHolderScanningResult.java:23
↓ 9 callersMethodgetActiveConsumers
()
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/consumer/ActiveConsumerList.java:51
↓ 9 callersMethodgetBaseConsumerMessage
()
hermes-core/src/main/java/com/ctrip/hermes/core/message/BaseConsumerMessageAware.java:8
↓ 9 callersMethodgetBaseMetaVersionZkPath
()
hermes-metaservice/src/main/java/com/ctrip/hermes/metaservice/zk/ZKPathUtils.java:31
↓ 9 callersMethodgetIp
()
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/commons/ClientContext.java:48
↓ 9 callersMethodgetMetaInfoZkPath
()
hermes-metaservice/src/main/java/com/ctrip/hermes/metaservice/zk/ZKPathUtils.java:35
↓ 9 callersMethodgetMsgSeqNo
()
hermes-core/src/main/java/com/ctrip/hermes/core/message/ProducerMessage.java:50
↓ 9 callersMethodgetNacked
()
hermes-consumer/src/main/java/com/ctrip/hermes/consumer/engine/ack/AckHolderScanningResult.java:27
↓ 9 callersMethodgetOrInitializeMessageQueue
(final String topic, final int partition)
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/DefaultMessageQueueManager.java:107
↓ 9 callersMethodgetPartition
()
hermes-core/src/main/java/com/ctrip/hermes/core/bo/Tpp.java:38
↓ 9 callersMethodgetState
()
hermes-core/src/main/java/com/ctrip/hermes/core/selector/TriggerResult.java:32
↓ 9 callersMethodgetTopic
()
hermes-core/src/main/java/com/ctrip/hermes/core/bo/Tpp.java:34
↓ 9 callersMethodinitLeaseToBroker
(int brokerPort, String topic, int partition, String sessionId)
hermes-metaserver/src/test/java/com/ctrip/hermes/metaserver/fulltest/MetaServerBaseTest.java:356
↓ 9 callersMethodlistPartitionsByTopic
(String topic)
hermes-core/src/main/java/com/ctrip/hermes/core/meta/MetaService.java:42
↓ 9 callersMethodreadAndCheckMagic
(ByteBuffer buf)
hermes-core/src/main/java/com/ctrip/hermes/core/transport/netty/Magic.java:11
↓ 9 callersMethodreassign
(Map<String, ClientContext> runningBrokers, Map<String, Idc> idcs)
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/broker/BrokerAssignmentHolder.java:149
↓ 9 callersMethodrun
()
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/event/Task.java:8
↓ 9 callersMethodsetCorrelationId
(long correlationId)
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/AckMessagesTask.java:73
↓ 9 callersMethodsetKey
(String key)
hermes-core/src/main/java/com/ctrip/hermes/core/message/ProducerMessage.java:83
↓ 9 callersMethodsetOffset
(Object offset)
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/storage/FetchResult.java:22
↓ 9 callersMethodwriteCommand
(Endpoint endpoint, Command cmd)
hermes-core/src/main/java/com/ctrip/hermes/core/transport/endpoint/EndpointClient.java:11
↓ 8 callersMethodaddMessageMeta
(MessageMeta msgMeta)
hermes-core/src/main/java/com/ctrip/hermes/core/message/TppConsumerMessageBatch.java:78
↓ 8 callersMethodaddProperty
(String key, String value)
hermes-producer/src/main/java/com/ctrip/hermes/producer/api/Producer.java:27
↓ 8 callersMethodassertAssignment
(Pair<String, String> tg, List<Pair<Integer, List<ClientContext>>> expectedPartition2ConsumersList)
hermes-metaserver/src/test/java/com/ctrip/hermes/metaserver/consumer/ConsumerAssignmentHolderTest.java:194
↓ 8 callersMethodclose
()
hermes-kafka/src/main/java/com/ctrip/hermes/kafka/producer/KafkaMessageSender.java:164
↓ 8 callersMethodcommitAsync
Commit these messages asynchronously
hermes-consumer/src/main/java/com/ctrip/hermes/consumer/api/PulledBatch.java:14
↓ 8 callersMethodcreate
(String policyValue)
hermes-core/src/main/java/com/ctrip/hermes/core/message/retry/RetryPolicyFactory.java:24
↓ 8 callersMethodcreatePrimitiveSchema
(Schema.Parser parser, String type)
hermes-core/src/main/java/com/ctrip/hermes/core/message/payload/assist/kafka/avro/AbstractKafkaAvroSerDe.java:52
↓ 8 callersMethodflush
(int maxMsgCount)
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/MessageQueue.java:46
↓ 8 callersMethodget
(String name)
hermes-example/src/main/java/com/ctrip/hermes/example/common/Configuration.java:74
↓ 8 callersMethodgetAndResetChanged
()
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/consumer/ActiveConsumerList.java:45
↓ 8 callersMethodgetBornTime
()
hermes-core/src/main/java/com/ctrip/hermes/core/message/ConsumerMessage.java:17
↓ 8 callersMethodgetConnection
()
hermes-kafka/src/test/java/com/ctrip/hermes/kafka/server/MockZookeeper.java:42
↓ 8 callersMethodgetIdcs
()
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/meta/MetaHolder.java:197
↓ 8 callersMethodgetManualCommitInterval
()
hermes-consumer/src/main/java/com/ctrip/hermes/consumer/api/PullConsumerConfig.java:27
↓ 8 callersMethodgetNextTryTime
()
hermes-core/src/main/java/com/ctrip/hermes/core/lease/LeaseAcquireResponse.java:39
↓ 8 callersMethodgetOffsets
()
hermes-broker/src/main/java/com/ctrip/hermes/broker/ack/internal/EnumRange.java:28
← previousnext →201–300 of 4,501, ranked by callers