MCPcopy Create free account

hub / github.com/ctripcorp/hermes / functions

Functions4,501 in github.com/ctripcorp/hermes

⨍ Functions 4,501◇ Types & classes 841
↓ 3 callersMethodgetTopic
()
hermes-core/src/main/java/com/ctrip/hermes/core/transport/command/v5/QueryLatestConsumerOffsetCommandV5.java:33
↓ 3 callersMethodgetTopicPattern
()
hermes-consumer/src/main/java/com/ctrip/hermes/consumer/engine/Subscriber.java:73
↓ 3 callersMethodgetTppg
(Map map)
hermes-broker/src/test/java/com/ctrip/hermes/broker/selector/BizLogAnalyzer.java:108
↓ 3 callersMethodgetWriter
(HttpServletRequest request)
hermes-metrics/src/main/java/com/ctrip/hermes/metrics/JVMMetricsServlet.java:91
↓ 3 callersMethodisManualConfigureModeOn
()
hermes-env/src/main/java/com/ctrip/hermes/env/ManualConfigProvider.java:8
↓ 3 callersMethodisMetaModified
(long version, long hashCode, Meta meta)
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/rest/resource/MetaResource.java:118
↓ 3 callersMethodisNullOrEmpty
(Collection<?> collection)
hermes-core/src/main/java/com/ctrip/hermes/core/utils/CollectionUtil.java:19
↓ 3 callersMethodisSuccess
()
hermes-core/src/main/java/com/ctrip/hermes/core/transport/command/SendMessageAckCommand.java:25
↓ 3 callersMethodloadLeaderMeta
(final long version)
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/event/impl/FollowerInitEventHandler.java:140
↓ 3 callersMethodlogDebug
(String debugInfo, long correlationId, Tpg tpg, Exception e)
hermes-broker/src/main/java/com/ctrip/hermes/broker/transport/command/processor/PullMessageCommandProcessor.java:87
↓ 3 callersMethodmakeSelector
(int slotCount, InitialLastUpdateTime initialLastUpdateTime)
hermes-core/src/test/java/com/ctrip/hermes/core/selector/SelectorTest.java:31
↓ 3 callersMethodmonitor
(SendMessageCommandV6 cmd)
hermes-producer/src/main/java/com/ctrip/hermes/producer/monitor/SendMessageResultMonitor.java:15
↓ 3 callersMethodnewInstance
(ComponentDescriptor desc, ClassRealm classRealm, PlexusContainer container)
hermes-broker/src/test/java/com/ctrip/hermes/broker/integration/MockitoComponentTestCase.java:72
↓ 3 callersMethodnewLastUpdateTime
()
hermes-core/src/main/java/com/ctrip/hermes/core/selector/DefaultSelector.java:116
↓ 3 callersMethodnextScheduleTimeMillis
(int retryTimes, long currentTimeMillis)
hermes-core/src/main/java/com/ctrip/hermes/core/message/retry/FrequencySpecifiedRetryPolicy.java:47
↓ 3 callersMethodnextScheduleTimeMillis
(int retryTimes, long currentTimeMillis)
hermes-core/src/main/java/com/ctrip/hermes/core/message/retry/RetryPolicy.java:11
↓ 3 callersMethodnormalAssert
(List<Partition> partitions, Map<String, ClientContext> consumers, Map<Integer, Map<String, ClientConte
hermes-metaserver/src/test/java/com/ctrip/hermes/metaserver/consumer/LeastAdjustmentConsumerPartitionAssigningStrategyTest.java:24
↓ 3 callersMethodnormalAssert
(List<Server> metaServers, List<Topic> topics, Assignment<String> newAssigns)
hermes-metaserver/src/test/java/com/ctrip/hermes/metaserver/meta/LeastAdjustmentMetaServerAssigningStrategyTest.java:26
↓ 3 callersMethodnotifySendFail
(SettableFuture<SendResult> future, MessageSendException exception)
hermes-producer/src/main/java/com/ctrip/hermes/producer/sender/BrokerMessageSender.java:326
↓ 3 callersMethodofferAckHolderOp
(Operation operation)
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/MessageQueue.java:42
↓ 3 callersMethodofferOperation
(Operation op)
hermes-consumer/src/main/java/com/ctrip/hermes/consumer/engine/ack/DefaultAckManager.java:487
↓ 3 callersMethodonComplete
(Map<TopicPartition, OffsetAndMetadata> offsets, Exception exception)
hermes-consumer/src/main/java/com/ctrip/hermes/consumer/api/OffsetCommitCallback.java:7
↓ 3 callersMethodpageLoadIntervalMillis
(int pageLoadIntervalMillis)
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/storage/mysql/cache/PageCacheBuilder.java:92
↓ 3 callersMethodpageLoader
(PageLoader<?> pageLoader)
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/storage/mysql/cache/PageCacheBuilder.java:82
↓ 3 callersMethodpurgeExpired
(long timeoutMillis, long now)
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/consumer/ActiveConsumerList.java:34
↓ 3 callersMethodpush
(SendMessageCommandV6 cmd)
hermes-producer/src/main/java/com/ctrip/hermes/producer/sender/BrokerMessageSender.java:352
↓ 3 callersMethodputToPathDataPair
(Map<String, byte[]> zkPathAndDatas, String topic, Map<String, ClientContext> metaServers)
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/meta/MetaServerAssignmentHolder.java:262
↓ 3 callersMethodrandomString
(int maxLen)
hermes-broker/src/test/java/com/ctrip/hermes/broker/queue/storage/filter/DefaultFilterTest.java:18
↓ 3 callersMethodreadByteBuf
(ByteBuf buf)
hermes-core/src/main/java/com/ctrip/hermes/core/message/PartialDecodedMessage.java:99
↓ 3 callersMethodreadIntBooleanMap
()
hermes-core/src/main/java/com/ctrip/hermes/core/utils/HermesPrimitiveCodec.java:375
↓ 3 callersMethodreadPageDataToResult
(Page<T> page, long startOffsetInclusive, int batchSize, LinkedList<T> datas)
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/storage/mysql/cache/MessageCacheBuilder.java:365
↓ 3 callersMethodregister
(T key, ExpireTimeHolder expireTimeHolder, SelectorCallback callback, long lastTriggerTime, Slot... slots)
hermes-core/src/main/java/com/ctrip/hermes/core/selector/DefaultSelector.java:51
↓ 3 callersMethodremoveChannel
(Endpoint endpoint, EndpointChannel endpointChannel, boolean sinceIdle)
hermes-core/src/main/java/com/ctrip/hermes/core/transport/endpoint/AbstractEndpointClient.java:103
↓ 3 callersMethodremoveListener
()
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/commons/BaseNodeCacheListener.java:58
↓ 3 callersMethodremoveOneTopicFromMeta
()
hermes-metaserver/src/test/java/com/ctrip/hermes/metaserver/fulltest/MetaServerBaseTest.java:513
↓ 3 callersMethodresetPriorityIfResend
(Tpp tpp, boolean resend)
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/DefaultMessageQueueManager.java:240
↓ 3 callersMethodresponse
(Channel channel, long correlationId, Offset offset)
hermes-broker/src/main/java/com/ctrip/hermes/broker/transport/command/processor/QueryLatestConsumerOffsetCommandProcessorV3.java:81
↓ 3 callersMethodresponse
(PullMessageTask pullTask, List<TppConsumerMessageBatch> batches, Offset offset, boolean success)
hermes-broker/src/main/java/com/ctrip/hermes/broker/longpolling/AbstractLongPollingService.java:41
↓ 3 callersMethodsetAckedContexts
(List<AckContext> ackedContexts)
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/AckMessagesTask.java:113
↓ 3 callersMethodsetAckedPriorityContexts
(List<AckContext> ackedPriorityContexts)
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/AckMessagesTask.java:121
↓ 3 callersMethodsetAckedResendContexts
(List<AckContext> ackedResendContexts)
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/AckMessagesTask.java:129
↓ 3 callersMethodsetBrokerAccepted
(boolean accepted)
hermes-core/src/main/java/com/ctrip/hermes/core/transport/command/v3/PullMessageResultCommandV3.java:39
↓ 3 callersMethodsetChannelFuture
(ChannelFuture channelFuture)
hermes-core/src/main/java/com/ctrip/hermes/core/transport/endpoint/AbstractEndpointClient.java:232
↓ 3 callersMethodsetConfigedMetaServers
(List<Server> configedMetaServers)
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/meta/MetaHolder.java:285
↓ 3 callersMethodsetHeader
(Header header)
hermes-core/src/main/java/com/ctrip/hermes/core/transport/command/AbstractCommand.java:29
↓ 3 callersMethodsetId
(Long id)
hermes-core/src/main/java/com/ctrip/hermes/core/bo/ClientMeta.java:373
↓ 3 callersMethodsetIdcs
(Map<String, Idc> idcs)
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/meta/MetaHolder.java:193
↓ 3 callersMethodsetIp
Sets the value of the 'ip' field. @param value the value to set.
hermes-kafka/src/test/java/com/ctrip/hermes/kafka/avro/AvroVisitEvent.java:64
↓ 3 callersMethodsetLeaseAssigning
(boolean m_leaseAssigning)
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/rest/resource/ManagementResource.java:145
↓ 3 callersMethodsetMeta
(Meta meta)
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/meta/MetaHolder.java:173
↓ 3 callersMethodsetNackedContexts
(List<AckContext> nackedContexts)
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/AckMessagesTask.java:137
↓ 3 callersMethodsetNackedPriorityContexts
(List<AckContext> nackedPriorityContexts)
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/AckMessagesTask.java:145
↓ 3 callersMethodsetNackedResendContexts
(List<AckContext> nackedResendContexts)
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/AckMessagesTask.java:153
↓ 3 callersMethodsetPartition
(int partition)
hermes-core/src/main/java/com/ctrip/hermes/core/bo/Tpp.java:26
↓ 3 callersMethodsetRole
(Role role)
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/commons/MetaServerStatusResponse.java:55
↓ 3 callersMethodsetSchemaRestService
(SchemaRegisterRestClient restService)
hermes-core/src/main/java/com/ctrip/hermes/core/message/payload/assist/HermesKafkaAvroSerializer.java:20
↓ 3 callersMethodsetSuccess
(boolean success)
hermes-core/src/main/java/com/ctrip/hermes/core/transport/command/v6/SendMessageAckCommandV6.java:26
↓ 3 callersMethodsetTransferCallback
(TransferCallback transferCallback)
hermes-core/src/main/java/com/ctrip/hermes/core/message/TppConsumerMessageBatch.java:90
↓ 3 callersMethodsetTz
Sets the value of the 'tz' field. @param value the value to set.
hermes-kafka/src/test/java/com/ctrip/hermes/kafka/avro/AvroVisitEvent.java:94
↓ 3 callersMethodsetUrl
Sets the value of the 'url' field. @param value the value to set.
hermes-kafka/src/test/java/com/ctrip/hermes/kafka/avro/AvroVisitEvent.java:79
↓ 3 callersMethodsetVolatileProperties
(ByteBuf volatileProperties)
hermes-core/src/main/java/com/ctrip/hermes/core/message/PartialDecodedMessage.java:55
↓ 3 callersMethodsetWithCatTrace
(boolean withHeader)
hermes-core/src/main/java/com/ctrip/hermes/core/message/ProducerMessage.java:159
↓ 3 callersMethodshutdown
()
hermes-kafka/src/test/java/com/ctrip/hermes/kafka/NativeKafkaWithAvroDecoderTest.java:97
↓ 3 callersMethodstartBroker
()
hermes-example/src/test/java/com/ctrip/hermes/example/performance/ProduceAndConsume.java:87
↓ 3 callersMethodstartEngine
()
hermes-metaserver/src/test/java/com/ctrip/hermes/metaserver/event/LeaderEventEngineTest.java:184
↓ 3 callersMethodstartEngine
()
hermes-metaserver/src/test/java/com/ctrip/hermes/metaserver/event/FollowerEventEngineTest.java:128
↓ 3 callersMethodstartMetaServer
(int port)
hermes-metaserver/src/test/java/com/ctrip/hermes/metaserver/fulltest/MetaServerBaseTest.java:151
↓ 3 callersMethodstopMetaServer
(int port)
hermes-metaserver/src/test/java/com/ctrip/hermes/metaserver/fulltest/MetaServerBaseTest.java:158
↓ 3 callersMethodstopServer
()
hermes-metaserver/src/test/java/com/ctrip/hermes/metaserver/StartMetaServer.java:60
↓ 3 callersMethodsubmitAckMessagesTask
(AckMessagesTask task)
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/MessageQueueManager.java:40
↓ 3 callersMethodtestAckNack
(boolean priority, boolean resend, int remainingRetries)
hermes-consumer/src/test/java/com/ctrip/hermes/consumer/pull/DefaultPullConsumerHolderTest.java:521
↓ 3 callersMethodtoCamal
(List<String> parts)
hermes-broker/src/test/java/com/ctrip/hermes/broker/config/ConfigGenerator.java:77
↓ 3 callersMethodtoString
()
hermes-core/src/main/java/com/ctrip/hermes/core/transport/command/v2/PullMessageCommandV2.java:83
↓ 3 callersMethodtoString
()
hermes-core/src/main/java/com/ctrip/hermes/core/selector/Slot.java:40
↓ 3 callersMethodtoString
()
hermes-core/src/main/java/com/ctrip/hermes/core/message/payload/PayloadCodecFactory.java:119
↓ 3 callersMethodtoString
()
hermes-consumer/src/test/java/com/ctrip/hermes/consumer/integration/assist/TestObjectMessage.java:45
↓ 3 callersMethodtoString
()
hermes-consumer/src/main/java/com/ctrip/hermes/consumer/engine/ConsumerContext.java:82
↓ 3 callersMethodtopicPageCacheSize
(String topic, int coreSize, int maximumSize)
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/storage/mysql/cache/MessageCacheBuilder.java:135
↓ 3 callersMethodtopicPageSize
(String topic, int pageSize)
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/storage/mysql/cache/MessageCacheBuilder.java:140
↓ 3 callersMethodupdateVersionAndOutputAndUpdateZKVersion
(Meta meta)
hermes-metaserver/src/test/java/com/ctrip/hermes/metaserver/fulltest/MetaServerBaseTest.java:538
↓ 3 callersMethodwaitOneLeaseTime
()
hermes-metaserver/src/test/java/com/ctrip/hermes/metaserver/fulltest/MetaServerBaseTest.java:552
↓ 3 callersMethodwriteAck
(CommandProcessorContext ctx, String topic, int partition, boolean success)
hermes-broker/src/main/java/com/ctrip/hermes/broker/transport/command/processor/SendMessageCommandProcessorV5.java:295
↓ 3 callersMethodwriteAck
(CommandProcessorContext ctx, String topic, int partition, boolean success)
hermes-broker/src/main/java/com/ctrip/hermes/broker/transport/command/processor/SendMessageCommandProcessorV6.java:274
↓ 3 callersMethodwriteAck
(CommandProcessorContext ctx, boolean success)
hermes-broker/src/main/java/com/ctrip/hermes/broker/transport/command/processor/SendMessageCommandProcessorV3.java:298
↓ 3 callersMethodwriteAck
(CommandProcessorContext ctx, boolean success)
hermes-broker/src/main/java/com/ctrip/hermes/broker/transport/command/processor/SendMessageCommandProcessor.java:299
↓ 3 callersMethodwriteIntBooleanMap
(Map<Integer, Boolean> map)
hermes-core/src/main/java/com/ctrip/hermes/core/utils/HermesPrimitiveCodec.java:311
↓ 2 callersMethodacked
(Tpp tpp, String groupId, boolean resend, List<AckContext> ackContexts, int ackType)
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/MessageQueueManager.java:35
↓ 2 callersMethodacquireConsumerLease
(Integer metaServerPort, String topic, String group)
hermes-metaserver/src/test/java/com/ctrip/hermes/metaserver/fulltest/MetaServerBaseTest.java:421
↓ 2 callersMethodaddAckOffset
(T ackOffset)
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/storage/mysql/ack/DefaultMySQLMessageAckFlusher.java:154
↓ 2 callersMethodaddConsumerGroup
(ConsumerGroup consumerGroup)
hermes-core/src/main/java/com/ctrip/hermes/core/bo/ClientMeta.java:303
↓ 2 callersMethodaddDurableAppProperty
(String name, String value)
hermes-core/src/main/java/com/ctrip/hermes/core/message/PropertiesHolder.java:28
↓ 2 callersMethodaddDurableSysProperty
(String name, String value)
hermes-core/src/main/java/com/ctrip/hermes/core/message/PropertiesHolder.java:33
↓ 2 callersMethodaddMetric
(KafkaMetric metric)
hermes-kafka/src/main/java/com/ctrip/hermes/kafka/util/LoggerMetricsReporter.java:46
↓ 2 callersMethodaddNacked
(T item)
hermes-consumer/src/main/java/com/ctrip/hermes/consumer/engine/ack/AckHolderScanningResult.java:19
↓ 2 callersMethodaddOffsetMessage
(OffsetMessage offsetMessage)
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/storage/mysql/ack/DefaultMySQLMessageAckFlusher.java:363
↓ 2 callersMethodaddResults
(Map<Integer, Boolean> results)
hermes-core/src/main/java/com/ctrip/hermes/core/transport/command/SendMessageResultCommand.java:35
↓ 2 callersMethodaddResults
(Map<Integer, SendMessageResult> results)
hermes-core/src/main/java/com/ctrip/hermes/core/transport/command/v6/SendMessageResultCommandV6.java:38
↓ 2 callersMethodaddSubscribeHandle
(SubscribeHandle handle)
hermes-consumer/src/main/java/com/ctrip/hermes/consumer/engine/CompositeSubscribeHandle.java:10
↓ 2 callersMethodaddVolatileProperty
(String name, String value)
hermes-core/src/main/java/com/ctrip/hermes/core/message/PropertiesHolder.java:45
↓ 2 callersMethodappendMessages
(String topic, int partition, boolean priority, Collection<MessageBatchWithRawData> batches)
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/storage/MessageQueueStorage.java:19
← previousnext →701–800 of 4,501, ranked by callers