MCPcopy Create free account

hub / github.com/ctripcorp/hermes / functions

Functions4,501 in github.com/ctripcorp/hermes

⨍ Functions 4,501◇ Types & classes 841
↓ 1 callersMethodaddMessageMetas
(List<MessageMeta> msgMetas)
hermes-core/src/main/java/com/ctrip/hermes/core/message/TppConsumerMessageBatch.java:82
↓ 1 callersMethodaddMetaServer
(String server, String host, int port)
hermes-metaserver/src/test/java/com/ctrip/hermes/metaserver/event/LeaderEventEngineTest.java:120
↓ 1 callersMethodaddMetaServerListListener
(long version)
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/event/impl/LeaderInitEventHandler.java:214
↓ 1 callersMethodaddNackMessage
(ConsumerMessage<T> msg)
hermes-consumer/src/main/java/com/ctrip/hermes/consumer/pull/RetriveSnapshot.java:61
↓ 1 callersMethodaddNackRecord
(int partition, int priorityOrResend, int remainingRetries, long offset)
hermes-consumer/src/main/java/com/ctrip/hermes/consumer/pull/RetriveSnapshot.java:131
↓ 1 callersMethodaddObserver
(ExpireTimeHolder expireTimeHolder, SelectorCallback callback, long lastTriggerTime, Slot[] slots)
hermes-core/src/main/java/com/ctrip/hermes/core/selector/DefaultSelector.java:134
↓ 1 callersMethodaddOffsetMessage
(OffsetMessage offsetMessage)
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/storage/mysql/ack/DefaultMySQLMessageAckFlusher.java:97
↓ 1 callersMethodaddOffsetResend
(OffsetResend offsetResend)
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/storage/mysql/ack/DefaultMySQLMessageAckFlusher.java:107
↓ 1 callersMethodaddOffsetResend
(OffsetResend offsetResend)
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/storage/mysql/ack/DefaultMySQLMessageAckFlusher.java:367
↓ 1 callersMethodaddResource
(String name)
hermes-example/src/main/java/com/ctrip/hermes/example/common/Configuration.java:32
↓ 1 callersMethodafter
()
hermes-broker/src/test/java/com/ctrip/hermes/broker/StartBroker.java:38
↓ 1 callersMethodallAcked
()
hermes-broker/src/main/java/com/ctrip/hermes/broker/ack/internal/DefaultAckHolder.java:150
↓ 1 callersMethodappendMessageSync
(List<PendingMessageWrapper> todos)
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/DefaultMessageQueueFlusher.java:158
↓ 1 callersMethodappendStackTrace
(StringBuilder bldr, Throwable ex, String prefix)
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/commons/CompositeException.java:160
↓ 1 callersMethodappendToMsgQueue
(PullMessageResultCommandV5 ack)
hermes-consumer/src/main/java/com/ctrip/hermes/consumer/engine/bootstrap/strategy/BaseConsumerTask.java:702
↓ 1 callersMethodassertAllMetaServerHaveNotTopic
(Topic topic)
hermes-metaserver/src/test/java/com/ctrip/hermes/metaserver/fulltest/MetaServerBaseTest.java:267
↓ 1 callersMethodassertBrokerContains
(List<ClientContext> brokers, ClientContext broker)
hermes-metaserver/src/test/java/com/ctrip/hermes/metaserver/broker/DefaultBrokerPartitionAssigningStrategyTest.java:222
↓ 1 callersMethodassertListEqual
(List list1, List list2)
hermes-metaserver/src/test/java/com/ctrip/hermes/metaserver/fulltest/MetaServerBaseTest.java:347
↓ 1 callersMethodassign
(Map<K, List<V>> originAssigns, List<V> freeAssigns)
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/assign/LeastAdjustmentAssianBalancer.java:14
↓ 1 callersMethodassign
()
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/broker/BrokerAssignmentHolder.java:181
↓ 1 callersMethodbaseMetaUpdateTopic
(Topic topic)
hermes-metaserver/src/test/java/com/ctrip/hermes/metaserver/fulltest/MetaServerBaseTest.java:529
↓ 1 callersMethodbatchInsert
(Topic topic, int partition, boolean priority, List<MessagePriority> msgs)
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/storage/mysql/MySQLMessageQueueStorage.java:196
↓ 1 callersMethodbecomeLeader
()
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/cluster/ClusterStateHolder.java:96
↓ 1 callersMethodbizLog
(CommandProcessorContext ctx, Map<Integer, MessageBatchWithRawData> rawBatches, int partition)
hermes-broker/src/main/java/com/ctrip/hermes/broker/transport/command/processor/SendMessageCommandProcessorV5.java:176
↓ 1 callersMethodbizLog
(CommandProcessorContext ctx, Map<Integer, MessageBatchWithRawData> rawBatches, int partition)
hermes-broker/src/main/java/com/ctrip/hermes/broker/transport/command/processor/SendMessageCommandProcessorV6.java:172
↓ 1 callersMethodbizLog
(CommandProcessorContext ctx, Map<Integer, MessageBatchWithRawData> rawBatches, int partition)
hermes-broker/src/main/java/com/ctrip/hermes/broker/transport/command/processor/SendMessageCommandProcessorV3.java:179
↓ 1 callersMethodbizLog
(CommandProcessorContext ctx, Map<Integer, MessageBatchWithRawData> rawBatches, int partition)
hermes-broker/src/main/java/com/ctrip/hermes/broker/transport/command/processor/SendMessageCommandProcessor.java:180
↓ 1 callersMethodbizLog
(boolean isPriority, MessageBatchWithRawData batch, boolean success)
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/DefaultMessageQueueFlusher.java:297
↓ 1 callersMethodbizLog
(String topic, int partition, boolean priority, List<MessagePriority> msgs, long startTime, long endTim
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/storage/mysql/MySQLMessageQueueStorage.java:232
↓ 1 callersMethodbizLogDelivered
(String ip, List<MessageMeta> metas, Tpg tpg, Date pullCmdReceiveTime, Date pullTime, boolean networkWr
hermes-broker/src/main/java/com/ctrip/hermes/broker/longpolling/DefaultLongPollingService.java:244
↓ 1 callersMethodbrokerAcceptTimeout
(String topic, int partition, int messageCount)
hermes-producer/src/main/java/com/ctrip/hermes/producer/status/ProducerStatusMonitor.java:40
↓ 1 callersMethodbrokerRegisterToZK
()
hermes-metaserver/src/test/java/com/ctrip/hermes/metaserver/fulltest/MetaServerBaseTest.java:463
↓ 1 callersMethodbrokerRejected
(String topic, int partition, int messageCount)
hermes-producer/src/main/java/com/ctrip/hermes/producer/status/ProducerStatusMonitor.java:36
↓ 1 callersMethodbuildCache
()
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/storage/mysql/cache/MessageCacheBuilder.java:194
↓ 1 callersMethodbuildExpectedServers
(Map<Integer, HermesClassLoaderMetaServer> metaServers)
hermes-metaserver/src/test/java/com/ctrip/hermes/metaserver/fulltest/MetaServerBaseTest.java:487
↓ 1 callersMethodbuildMatchPattern
(String topicPattern)
hermes-core/src/main/java/com/ctrip/hermes/core/meta/internal/DefaultMetaService.java:144
↓ 1 callersMethodbuildMatchPattern
(String topicPattern)
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/storage/filter/DefaultFilter.java:88
↓ 1 callersMethodbuildPageCache
(final Pair<String, Integer> tp)
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/storage/mysql/cache/MessageCacheBuilder.java:240
↓ 1 callersMethodbuildUpdatedTopic
(Topic topic)
hermes-metaserver/src/test/java/com/ctrip/hermes/metaserver/fulltest/MetaServerBaseTest.java:585
↓ 1 callersMethodcacheCall
(String topic, int partition, boolean hasData)
hermes-broker/src/main/java/com/ctrip/hermes/broker/status/BrokerStatusMonitor.java:110
↓ 1 callersMethodcalMaxAckOffset
(List<AckContext> ackedContexts, List<AckContext> nackedContexts)
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/AbstractMessageQueue.java:386
↓ 1 callersMethodcalSize
(Map<Integer, MessageBatchWithRawData> messageRawDataBatches)
hermes-broker/src/main/java/com/ctrip/hermes/broker/transport/command/processor/SendMessageCommandProcessorV5.java:159
↓ 1 callersMethodcalSize
(Map<Integer, MessageBatchWithRawData> messageRawDataBatches)
hermes-broker/src/main/java/com/ctrip/hermes/broker/transport/command/processor/SendMessageCommandProcessorV6.java:155
↓ 1 callersMethodcalSize
(Map<Integer, MessageBatchWithRawData> messageRawDataBatches)
hermes-broker/src/main/java/com/ctrip/hermes/broker/transport/command/processor/SendMessageCommandProcessorV3.java:162
↓ 1 callersMethodcalSize
(Map<Integer, MessageBatchWithRawData> messageRawDataBatches)
hermes-broker/src/main/java/com/ctrip/hermes/broker/transport/command/processor/SendMessageCommandProcessor.java:163
↓ 1 callersMethodcalculateRebalanceTaskDelay
(Lease lease)
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/commons/EndpointMaker.java:168
↓ 1 callersMethodcall
()
hermes-example/src/test/java/com/ctrip/hermes/example/ConsumerVerifier.java:144
↓ 1 callersMethodcancel
(long correlationId)
hermes-consumer/src/main/java/com/ctrip/hermes/consumer/engine/monitor/PullMessageAcceptanceMonitor.java:18
↓ 1 callersMethodcancel
(long correlationId)
hermes-consumer/src/main/java/com/ctrip/hermes/consumer/engine/monitor/QueryOffsetAcceptanceMonitor.java:17
↓ 1 callersMethodchangeLeaseTo
(int fromBrokerPort, int toBrokerPort, String topic, int partition, long timeoutInMs)
hermes-metaserver/src/test/java/com/ctrip/hermes/metaserver/fulltest/MetaServerBaseTest.java:362
↓ 1 callersMethodcheck
(final TpgAckHolder holder)
hermes-consumer/src/main/java/com/ctrip/hermes/consumer/engine/ack/DefaultAckManager.java:275
↓ 1 callersMethodcheckHolders
()
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/MessageQueue.java:40
↓ 1 callersMethodchildChanged
()
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/commons/BasePathChildrenCacheListener.java:71
↓ 1 callersMethodclassify
(Set<T> src, Set<T> des, ClassifyStandard<T> standard)
hermes-core/src/main/java/com/ctrip/hermes/core/utils/HermesThreadFactory.java:71
↓ 1 callersMethodcleanEnv
()
hermes-metaserver/src/test/java/com/ctrip/hermes/metaserver/fulltest/MetaServerBaseTest.java:115
↓ 1 callersMethodclearDeliveredMessageMetasBefore
(long offset)
hermes-broker/src/main/java/com/ctrip/hermes/broker/ack/internal/ForwardOnlyAckHolder.java:44
↓ 1 callersMethodclearHolders
(String groupId)
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/AbstractMessageQueue.java:230
↓ 1 callersMethodclearMockitoComponent
()
hermes-broker/src/test/java/com/ctrip/hermes/broker/integration/MockitoComponentTestCase.java:63
↓ 1 callersMethodclearZk
()
hermes-metaserver/src/test/java/com/ctrip/hermes/metaserver/ZKSuppportTestCase.java:63
↓ 1 callersMethodcloneOffsetMessage
(OffsetMessage offsetMessage)
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/storage/mysql/ack/DefaultMySQLMessageAckFlusher.java:386
↓ 1 callersMethodcloneOffsetResend
(OffsetResend offsetResend)
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/storage/mysql/ack/DefaultMySQLMessageAckFlusher.java:402
↓ 1 callersMethodclose
()
hermes-metaserver/src/main/java/com/ctrip/hermes/metaserver/cluster/ClusterStateHolder.java:208
↓ 1 callersMethodclose
()
hermes-core/src/main/java/com/ctrip/hermes/core/transport/endpoint/AbstractEndpointClient.java:242
↓ 1 callersMethodclose
()
hermes-consumer/src/main/java/com/ctrip/hermes/consumer/engine/SubscribeHandle.java:5
↓ 1 callersMethodclose
()
hermes-consumer/src/main/java/com/ctrip/hermes/consumer/engine/bootstrap/strategy/ConsumerTask.java:11
↓ 1 callersMethodclose
()
hermes-metrics/src/main/java/com/ctrip/hermes/metrics/HermesMetricsRegistry.java:26
↓ 1 callersMethodcollectCachedMessages
(LinkedList<ConsumerMessage<T>> result, int targetSize)
hermes-consumer/src/main/java/com/ctrip/hermes/consumer/pull/DefaultPullConsumerHolder.java:195
↓ 1 callersMethodcommandProcessed
(CommandType type, long duration)
hermes-core/src/main/java/com/ctrip/hermes/core/status/StatusMonitor.java:59
↓ 1 callersMethodcommandProcessorException
(CommandType type, CommandProcessor processor)
hermes-core/src/main/java/com/ctrip/hermes/core/status/StatusMonitor.java:55
↓ 1 callersMethodcommandReceived
(CommandType type, String clientIp)
hermes-core/src/main/java/com/ctrip/hermes/core/status/StatusMonitor.java:37
↓ 1 callersMethodcommandTypes
()
hermes-core/src/main/java/com/ctrip/hermes/core/transport/command/processor/CommandProcessor.java:9
↓ 1 callersMethodcommitSnapshotAsync
(RetriveSnapshot<T> snapshot)
hermes-consumer/src/main/java/com/ctrip/hermes/consumer/pull/DefaultCommitter.java:193
↓ 1 callersMethodcompare
(OffsetMessage o1, OffsetMessage o2)
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/storage/mysql/ack/DefaultMySQLMessageAckFlusher.java:54
↓ 1 callersMethodcompress
()
hermes-core/src/main/java/com/ctrip/hermes/core/bo/ClientMeta.java:119
↓ 1 callersMethodcompress
(byte[] bytes)
hermes-core/src/main/java/com/ctrip/hermes/core/meta/manual/ManualConfig.java:91
↓ 1 callersMethodcomputeTaskQueueKey
(ProducerMessage<?> msg)
hermes-producer/src/main/java/com/ctrip/hermes/producer/sender/BrokerMessageSender.java:124
↓ 1 callersMethodconfigure
(WebAppContext context)
hermes-metaserver/src/test/java/com/ctrip/hermes/metaserver/fulltest/HermesClassLoaderMetaServer.java:69
↓ 1 callersMethodconfigure
(ManualConfig newConfig)
hermes-core/src/main/java/com/ctrip/hermes/core/meta/manual/DefaultManualConfigService.java:39
↓ 1 callersMethodconfigureCurator
()
hermes-metaserver/src/test/java/com/ctrip/hermes/metaserver/ZKSuppportTestCase.java:67
↓ 1 callersMethodconfigureStubComponents
()
hermes-consumer/src/test/java/com/ctrip/hermes/consumer/integration/BaseConsumerIntegrationTest.java:77
↓ 1 callersMethodconfigureStubComponents
()
hermes-producer/src/test/java/com/ctrip/hermes/producer/integration/BaseProducerIntegrationTest.java:95
↓ 1 callersMethodconsumeMessages
(long token)
hermes-consumer/src/main/java/com/ctrip/hermes/consumer/engine/bootstrap/strategy/BaseConsumerTask.java:490
↓ 1 callersMethodcontainsEndpoint
(Endpoint endpoint)
hermes-core/src/main/java/com/ctrip/hermes/core/transport/endpoint/EndpointManager.java:17
↓ 1 callersMethodconvertResults
(Map<Integer, SendMessageResult> results)
hermes-broker/src/main/java/com/ctrip/hermes/broker/transport/command/processor/SendMessageCommandProcessorV5.java:249
↓ 1 callersMethodconvertResults
(Map<Integer, SendMessageResult> results)
hermes-broker/src/main/java/com/ctrip/hermes/broker/transport/command/processor/SendMessageCommandProcessorV3.java:252
↓ 1 callersMethodconvertResults
(Map<Integer, SendMessageResult> results)
hermes-broker/src/main/java/com/ctrip/hermes/broker/transport/command/processor/SendMessageCommandProcessor.java:253
↓ 1 callersMethodconvertToClientMeta
(Meta meta)
hermes-core/src/main/java/com/ctrip/hermes/core/bo/ClientMeta.java:39
↓ 1 callersMethodconvertToEndpoints
(String brokers)
hermes-core/src/main/java/com/ctrip/hermes/core/meta/manual/DefaultManualConfigFetcher.java:91
↓ 1 callersMethodconvertToMeta
()
hermes-core/src/main/java/com/ctrip/hermes/core/bo/ClientMeta.java:132
↓ 1 callersMethodconvertToSingleSendMessageResult
(SendMessageResultCommandV6 cmd)
hermes-producer/src/main/java/com/ctrip/hermes/producer/monitor/DefaultSendMessageResultMonitor.java:98
↓ 1 callersMethodcopyCacheDatas
(Cache<Long, Page<T>> from, Cache<Long, Page<T>> to)
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/storage/mysql/cache/PageCacheBuilder.java:181
↓ 1 callersMethodcopyDatasourcesXml
()
hermes-example/src/test/java/setup/Setup.java:60
↓ 1 callersMethodcopyToDeadLetter
(Tpp tpp, String groupId, List<Pair<Long, MessageMeta>> msgId2Metas, boolean resend)
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/storage/mysql/MySQLMessageQueueStorage.java:578
↓ 1 callersMethodcopyToResend
(Tpp tpp, String groupId, List<Pair<Long, MessageMeta>> msgId2Metas, boolean resend, RetryPolicy retryP
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/storage/mysql/MySQLMessageQueueStorage.java:534
↓ 1 callersMethodcreatChannel
(Endpoint endpoint)
hermes-core/src/main/java/com/ctrip/hermes/core/transport/endpoint/AbstractEndpointClient.java:129
↓ 1 callersMethodcreateAckFlushTasks
(Topic topic)
hermes-broker/src/main/java/com/ctrip/hermes/broker/queue/storage/mysql/ack/DefaultMySQLMessageAckFlusher.java:223
↓ 1 callersMethodcreateBootstrap
(final Endpoint endpoint, final EndpointChannel endpointChannel)
hermes-core/src/main/java/com/ctrip/hermes/core/transport/endpoint/AbstractEndpointClient.java:196
↓ 1 callersMethodcreateBrokerAssignments
()
hermes-core/src/test/java/com/ctrip/hermes/core/meta/manual/ManualConfigGenerator.java:31
↓ 1 callersMethodcreateConsumer
(Map<Pair<String, String>, List<Pair<String, ConsumerHolder>>> topicGroup2Consumers, String line)
hermes-consumer/src/test/java/com/ctrip/hermes/consumer/StartConsumer.java:113
↓ 1 callersMethodcreateConsumerAssignments
()
hermes-core/src/test/java/com/ctrip/hermes/core/meta/manual/ManualConfigGenerator.java:43
← previousnext →1,201–1,300 of 4,501, ranked by callers