MCPcopy Create free account

hub / github.com/ctripcorp/hermes / functions

Functions4,501 in github.com/ctripcorp/hermes

⨍ Functions 4,501◇ Types & classes 841
↓ 2 callersMethodgetValveList
()
hermes-core/src/main/java/com/ctrip/hermes/core/pipeline/ValveRegistry.java:10
↓ 2 callersMethodgetZkConnectionString
()
hermes-metaserver/src/test/java/com/ctrip/hermes/metaserver/ZKSuppportTestCase.java:119
↓ 2 callersMethodgetZkConnectionTimeoutMillis
()
hermes-metaservice/src/main/java/com/ctrip/hermes/metaservice/zk/ZKConfig.java:22
↓ 2 callersMethodgetZkConnectionTimeoutMillis
()
hermes-broker/src/main/java/com/ctrip/hermes/broker/zk/ZKConfig.java:18
↓ 2 callersMethodgetZkSessionTimeoutMillis
()
hermes-metaservice/src/main/java/com/ctrip/hermes/metaservice/zk/ZKConfig.java:42
↓ 2 callersMethodgetZkSessionTimeoutMillis
()
hermes-broker/src/main/java/com/ctrip/hermes/broker/zk/ZKConfig.java:38
↓ 2 callersMethodhandle
(PipelineContext<?> ctx, Object payload)
hermes-core/src/main/java/com/ctrip/hermes/core/pipeline/spi/Valve.java:7
↓ 2 callersMethodhashCode
()
hermes-core/src/main/java/com/ctrip/hermes/core/bo/Tp.java:33
↓ 2 callersMethodheartbeat
(Tpg tpg, String consumerName, String ip)
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/consumer/AbstractConsumerLeaseAllocator.java:64
↓ 2 callersMethodisConsumerEnabled
(String topicName, String consumerName)
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/consumer/AbstractConsumerLeaseAllocator.java:112
↓ 2 callersMethodisDone
()
hermes-example/src/test/java/com/ctrip/hermes/example/ConsumerVerifier.java:239
↓ 2 callersMethodisEnabled
()
hermes-env-provider/src/main/java/com/ctrip/hermes/env/provider/DefaultMySQLCacheConfigProvider.java:362
↓ 2 callersMethodisForwordOnly
(Operation op)
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/AbstractMessageQueue.java:481
↓ 2 callersMethodisFromAnotherMetaServer
(HttpServletRequest req)
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/rest/resource/LeaseResource.java:478
↓ 2 callersMethodisInited
()
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/MessageQueueCursor.java:27
↓ 2 callersMethodisNack
()
hermes-consumer/src/main/java/com/ctrip/hermes/consumer/pull/OffsetRecord.java:54
↓ 2 callersMethodisSlotIndexValid
(Slot slot)
hermes-core/src/main/java/com/ctrip/hermes/core/selector/DefaultSelector.java:95
↓ 2 callersMethodisStrictlyOrdering
()
hermes-consumer/src/main/java/com/ctrip/hermes/consumer/api/MessageListenerConfig.java:16
↓ 2 callersMethodisWithOffset
()
hermes-broker/src/main/java/com/ctrip/hermes/broker/longpolling/PullMessageTask.java:127
↓ 2 callersMethodlistAllMysqlDataSources
()
hermes-core/src/main/java/com/ctrip/hermes/core/meta/MetaService.java:40
↓ 2 callersMethodloadAndAddBrokerListListener
(ServiceCacheListener listener)
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/event/impl/LeaderInitEventHandler.java:199
↓ 2 callersMethodloadConfig
(String confFile)
hermes-example/src/main/java/com/ctrip/hermes/example/common/Configuration.java:46
↓ 2 callersMethodloadExistingLeases
(List<BrokerLease> existingLeases)
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/broker/BrokerLeaseHolder.java:205
↓ 2 callersMethodloadExistingLeases
(List<ConsumerLease> existingLeases)
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/consumer/ConsumerLeaseHolder.java:205
↓ 2 callersMethodloadLocalMeta
()
hermes-consumer/src/test/java/com/ctrip/hermes/consumer/integration/BaseConsumerIntegrationTest.java:111
↓ 2 callersMethodloadMessages
(String topic, int partition, int priorityInt, long startOffsetExclusive, int batchSize)
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/storage/mysql/dal/CachedMessagePriorityDaoInterceptor.java:132
↓ 2 callersMethodloadMeta
()
hermes-core/src/main/java/com/ctrip/hermes/core/meta/internal/MetaManager.java:7
↓ 2 callersMethodloadMetaServerList
()
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/event/impl/LeaderInitEventHandler.java:219
↓ 2 callersMethodlogDebug
(QueryLatestConsumerOffsetCommand cmd, String debugInfo)
hermes-broker/src/main/java/com/ctrip/hermes/broker/transport/command/processor/QueryLatestConsumerOffsetCommandProcessor.java:79
↓ 2 callersMethodlogProcessTime
()
hermes-consumer/src/main/java/com/ctrip/hermes/consumer/pull/DefaultPulledBatch.java:56
↓ 2 callersMethodlogSelecotrMetric
(Tpg tpg, CallbackContext callbackCtx, int count)
hermes-broker/src/main/java/com/ctrip/hermes/broker/longpolling/DefaultLongPollingService.java:228
↓ 2 callersMethodmatches
(String topic, String source, String pattern)
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/storage/filter/DefaultFilter.java:139
↓ 2 callersMethodmaxSize
(int maxSize)
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/storage/mysql/cache/PageCacheBuilder.java:77
↓ 2 callersMethodmessageReceived
(long token, List<ConsumerMessage<?>> msgs)
hermes-consumer/src/main/java/com/ctrip/hermes/consumer/engine/notifier/ConsumerNotifier.java:18
↓ 2 callersMethodmockBrokerAllUnRegisterToZK
()
hermes-metaserver/src/test/java/com/ctrip/hermes/metaserver/fulltest/MetaServerBaseTest.java:454
↓ 2 callersMethodmonitor
(long correlationId)
hermes-consumer/src/main/java/com/ctrip/hermes/consumer/engine/monitor/AckMessageResultMonitor.java:13
↓ 2 callersMethodmsgAcked
(Tpg tpg, long onMessageStart, long onMessageEnd, boolean ack)
hermes-consumer/src/main/java/com/ctrip/hermes/consumer/engine/status/ConsumerStatusMonitor.java:39
↓ 2 callersMethodnacked
(Tpp tpp, String groupId, boolean resend, List<AckContext> nackContexts, int ackType)
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/MessageQueueManager.java:38
↓ 2 callersMethodnewBuilder
Creates a new AvroVisitEvent RecordBuilder
hermes-kafka/src/test/java/com/ctrip/hermes/kafka/avro/AvroVisitEvent.java:99
↓ 2 callersMethodnewLease
(Key contextKey, String clientKey, LeasesContext leasesContext, long leaseTimeMillis, String ip, int po
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/commons/LeaseHolder.java:21
↓ 2 callersMethodnext
(Object payload)
hermes-core/src/main/java/com/ctrip/hermes/core/pipeline/DefaultPipelineContext.java:28
↓ 2 callersMethodnextAwaitingSlots
()
hermes-core/src/main/java/com/ctrip/hermes/core/selector/CallbackContext.java:29
↓ 2 callersMethodnextOffset
()
hermes-producer/src/main/java/com/ctrip/hermes/producer/sender/BrokerMessageSender.java:348
↓ 2 callersMethodnonGrayConsumeStateToInt
(String state)
hermes-core/src/main/java/com/ctrip/hermes/core/cmessaging/DefaultCMessagingConfigService.java:137
↓ 2 callersMethodnonGrayProduceStateToBoolean
(String state)
hermes-core/src/main/java/com/ctrip/hermes/core/cmessaging/DefaultCMessagingConfigService.java:97
↓ 2 callersMethodonFailure
(Throwable t)
hermes-core/src/main/java/com/ctrip/hermes/core/result/CompletionCallback.java:10
↓ 2 callersMethodonResultReceived
(SendMessageResultCommand result)
hermes-core/src/main/java/com/ctrip/hermes/core/transport/command/SendMessageCommand.java:106
↓ 2 callersMethodonResultReceived
(SendMessageResultCommandV6 result)
hermes-core/src/main/java/com/ctrip/hermes/core/transport/command/v6/SendMessageCommandV6.java:138
↓ 2 callersMethodonSuccess
(T result)
hermes-core/src/main/java/com/ctrip/hermes/core/result/CompletionCallback.java:8
↓ 2 callersMethodoutputToTestXml
(Meta meta)
hermes-metaserver/src/test/java/com/ctrip/hermes/metaserver/fulltest/MetaServerBaseTest.java:628
↓ 2 callersMethodoverrideByCtripDefaultConsumerSetting
@param consumerProp @return
hermes-kafka/src/main/java/com/ctrip/hermes/kafka/util/KafkaProperties.java:82
↓ 2 callersMethodpageLoaderThreadPool
(ExecutorService pageLoaderThreadPool)
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/storage/mysql/cache/PageCacheBuilder.java:87
↓ 2 callersMethodparseTimeUnit
(String value, TimeUnit defaultValue)
hermes-metrics/src/main/java/com/ctrip/hermes/metrics/JVMMetricsServlet.java:99
↓ 2 callersMethodpersistDirtyLeases
(int batchSize)
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/broker/BrokerLeaseHolder.java:122
↓ 2 callersMethodpersistDirtyLeases
(int batchSize)
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/consumer/ConsumerLeaseHolder.java:143
↓ 2 callersMethodpollMetaServer
(Function<String, Pair<Integer, String>> fun)
hermes-core/src/main/java/com/ctrip/hermes/core/meta/remote/RemoteMetaProxy.java:143
↓ 2 callersMethodpop
(int size)
hermes-producer/src/main/java/com/ctrip/hermes/producer/sender/BrokerMessageSender.java:356
↓ 2 callersMethodpost
(URL url, Object payload)
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/rest/resource/LeaseResource.java:537
↓ 2 callersMethodproxyBrokerLeaseRequestIfNecessary
(HttpServletRequest req, String uri, Map<String, String> params, Object payload, Transaction tx)
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/rest/resource/LeaseResource.java:432
↓ 2 callersMethodproxyConsumerLeaseRequestIfNecessary
(HttpServletRequest req, String topic, String uri, Map<String, String> params, Object payload, Transact
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/rest/resource/LeaseResource.java:452
↓ 2 callersMethodproxyPass
(String host, int port, String uri, Map<String, String> params, Object payload)
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/rest/resource/LeaseResource.java:490
↓ 2 callersMethodqueryLatestOffset
(String topic, int partition)
hermes-consumer/src/main/java/com/ctrip/hermes/consumer/api/OffsetStorage.java:6
↓ 2 callersMethodreadLongIntMap
()
hermes-core/src/main/java/com/ctrip/hermes/core/utils/HermesPrimitiveCodec.java:358
↓ 2 callersMethodreadMsgSeqMap
(HermesPrimitiveCodec codec)
hermes-core/src/main/java/com/ctrip/hermes/core/transport/command/AckMessageCommand.java:81
↓ 2 callersMethodreadMsgSeqMap
(HermesPrimitiveCodec codec)
hermes-core/src/main/java/com/ctrip/hermes/core/transport/command/v2/AckMessageCommandV2.java:96
↓ 2 callersMethodreadProperties
(ByteBuf buf)
hermes-core/src/main/java/com/ctrip/hermes/core/message/codec/internal/MessageCodecBinaryV1Handler.java:232
↓ 2 callersMethodrefreshMeta
()
hermes-core/src/main/java/com/ctrip/hermes/core/meta/internal/DefaultMetaService.java:214
↓ 2 callersMethodregisterSchema
(String schema, String subject)
hermes-core/src/main/java/com/ctrip/hermes/core/meta/internal/MetaProxy.java:24
↓ 2 callersMethodregisterSchema
(Map<String, String> requestProperties, RegisterSchemaRequest registerSchemaRequest, String subject)
hermes-core/src/main/java/com/ctrip/hermes/core/message/payload/assist/SchemaRegisterRestClient.java:26
↓ 2 callersMethodremoveExpiredLeases
(LeasesContext leasesContext)
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/commons/BaseLeaseHolder.java:119
↓ 2 callersMethodrenewLease
(Key contextKey, String clientKey, LeasesContext leasesContext, ClientLeaseInfo existingLeaseInfo, long
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/commons/LeaseHolder.java:24
↓ 2 callersMethodresetConsumerOffset
(String topic, String consumerGroup, RESET_POSITION position)
hermes-kafka/src/main/java/com/ctrip/hermes/kafka/service/KafkaService.java:36
↓ 2 callersMethodresize
(int newSize)
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/storage/mysql/cache/PageCacheBuilder.java:267
↓ 2 callersMethodresizeListener
(ResizeListener<?> resizeListener)
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/storage/mysql/cache/PageCacheBuilder.java:102
↓ 2 callersMethodresponse
(Channel channel, long correlationId, Offset offset)
hermes-broker/src/main/java/com/ctrip/hermes/broker/transport/command/processor/QueryMessageOffsetByTimeCommandProcessor.java:68
↓ 2 callersMethodresponse
(Channel channel, long correlationId, Offset offset)
hermes-broker/src/main/java/com/ctrip/hermes/broker/transport/command/processor/QueryLatestConsumerOffsetCommandProcessor.java:73
↓ 2 callersMethodresponseAck
(Channel channel, QueryLatestConsumerOffsetCommandV5 reqCmd, boolean success)
hermes-broker/src/main/java/com/ctrip/hermes/broker/transport/command/processor/QueryLatestConsumerOffsetCommandProcessorV5.java:84
↓ 2 callersMethodresponseAck
(Channel channel, PullMessageCommandV5 reqCmd, boolean success)
hermes-broker/src/main/java/com/ctrip/hermes/broker/transport/command/processor/PullMessageCommandProcessorV5.java:91
↓ 2 callersMethodresponseAck
(Channel channel, AckMessageCommandV5 reqCmd, boolean success)
hermes-broker/src/main/java/com/ctrip/hermes/broker/transport/command/processor/AckMessageCommandProcessorV5.java:104
↓ 2 callersMethodrestart
(ConsumerContext consumerContext)
hermes-kafka/src/main/java/com/ctrip/hermes/kafka/engine/KafkaConsumerBootstrap.java:127
↓ 2 callersMethodresultReceived
(QueryOffsetResultCommandV5 ack)
hermes-consumer/src/main/java/com/ctrip/hermes/consumer/engine/monitor/QueryOffsetResultMonitor.java:13
↓ 2 callersMethodresultReceived
(SendMessageResultCommandV6 result)
hermes-producer/src/main/java/com/ctrip/hermes/producer/monitor/SendMessageResultMonitor.java:19
↓ 2 callersMethodretrive
(int maxMessageCount, int timeout, RetrivePolicy retrivePolicy)
hermes-consumer/src/main/java/com/ctrip/hermes/consumer/pull/DefaultPullConsumerHolder.java:145
↓ 2 callersMethodretrived
(List<ConsumerMessage<String>> msgs)
hermes-example/src/test/java/com/ctrip/hermes/example/ConsumerVerifier.java:231
↓ 2 callersMethodrole
()
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/event/impl/ObserverInitEventHandler.java:50
↓ 2 callersMethodscheduleRenewLeaseTask
(final BrokerLeaseKey key, long delay)
hermes-broker/src/main/java/com/ctrip/hermes/broker/lease/BrokerLeaseContainer.java:128
↓ 2 callersMethodsend
(String topic, String prefix)
hermes-example/src/test/java/com/ctrip/hermes/example/OneBoxTest.java:218
↓ 2 callersMethodsend
(ProducerMessage<?> msg)
hermes-producer/src/main/java/com/ctrip/hermes/producer/sender/MessageSender.java:14
↓ 2 callersMethodserialize
(Object data)
hermes-kafka/src/main/java/com/ctrip/hermes/kafka/admin/ZKStringSerializer.java:10
↓ 2 callersMethodsetAssignments
(Map<String, Assignment<Integer>> newAssignments)
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/broker/BrokerAssignmentHolder.java:218
↓ 2 callersMethodsetBaseMeta
(Meta baseMeta)
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/meta/MetaHolder.java:201
↓ 2 callersMethodsetBatch
(TppConsumerMessageBatch batch)
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/storage/FetchResult.java:14
↓ 2 callersMethodsetBody
(T body)
hermes-core/src/main/java/com/ctrip/hermes/core/message/BaseConsumerMessage.java:83
↓ 2 callersMethodsetBody
(Object object)
hermes-core/src/main/java/com/ctrip/hermes/core/message/ProducerMessage.java:78
↓ 2 callersMethodsetBrokerAssignments
(Map<String, Assignment<Integer>> brokerAssignments)
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/commons/MetaServerStatusResponse.java:63
↓ 2 callersMethodsetConfig
(MetaServerConfig config)
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/commons/EndpointMaker.java:49
↓ 2 callersMethodsetFilter
(String filter)
hermes-broker/src/main/java/com/ctrip/hermes/broker/longpolling/PullMessageTask.java:59
↓ 2 callersMethodsetGroupId
(String groupId)
hermes-core/src/main/java/com/ctrip/hermes/core/bo/Tpg.java:45
↓ 2 callersMethodsetGroupId
(String groupId)
hermes-consumer/src/main/java/com/ctrip/hermes/consumer/message/BrokerConsumerMessage.java:48
↓ 2 callersMethodsetHost
(String host)
hermes-core/src/main/java/com/ctrip/hermes/core/bo/HostPort.java:23
← previousnext →1,001–1,100 of 4,501, ranked by callers