hermes-consumers-0.16.0

Fast and reliable message broker built on top of Kafka.
点击查看hermes-consumers的另外79个版本信息


概述

项目名称 hermes-consumers
项目地址 https://github.com/allegro/hermes
开源时间 2015
开源协议 The Apache Software License, Version 2.0
发布时间 2019-04-15 16:59:22
Sha1对照码 f2622df65258a15c84c6383ecab536b9b4327731
开源类库 hermes-consumers
项目大小 393.3 KB
文件集 hermes-consumers-0.16.0 查看全部文件
中央仓库 hermes-consumers-0.16.0.jar 下载地址1 hermes-consumers-0.16.0-sources.jar 源码下载地址1
备用仓库1 hermes-consumers-0.16.0.jar 下载地址2 hermes-consumers-0.16.0-sources.jar 源码下载地址2
备用仓库2 hermes-consumers-0.16.0.jar 下载地址3 hermes-consumers-0.16.0-sources.jar 源码下载地址3
阿里云仓库 hermes-consumers-0.16.0.jar 下载地址4 hermes-consumers-0.16.0-sources.jar 源码下载地址4
Apache Maven Gradle/Grails Scala SBT Ivy Groovy Grape Leiningen Apache Buildr

研发人员

编号 名称 邮箱 网址
skylab Team Skylab

依赖项目

开发团队 项目名称 版本 作用域
org.slf4j slf4j-api 1.7.7 compile
pl.allegro.tech.hermes hermes-common 0.16.0 compile
pl.allegro.tech.hermes hermes-tracker 0.16.0 compile
pl.allegro.tech.hermes hermes-metrics 0.16.0 compile
pl.allegro.tech.hermes hermes-schema 0.16.0 compile
org.eclipse.jetty jetty-client 9.3.18.v20170406 compile
org.eclipse.jetty.http2 http2-http-client-transport 9.3.18.v20170406 compile
org.jctools jctools-core 1.2 compile
javax.jms javax.jms-api 2.0 compile
joda-time joda-time 2.5 compile
org.apache.httpcomponents httpclient 4.5.1 compile
com.github.rholder guava-retrying 2.0.0 compile
com.jayway.jsonpath json-path 2.2.0 compile
org.hornetq hornetq-jms-client 2.4.1.Final compile
junit junit 4.11 test
pl.pragmatists JUnitParams 1.0.2 test
org.mockito mockito-all 1.9.5 test
org.assertj assertj-core 3.1.0 test
com.jayway.awaitility awaitility 1.6.1 test
com.googlecode.catch-exception catch-exception 1.2.0 test
pl.allegro.tech.hermes hermes-test-helper 0.16.0 test
org.apache.curator curator-test 2.12.0 test
javax.servlet javax.servlet-api 3.1.0 test
tech.allegro.schema.json2avro converter 0.2.5 test
org.spockframework spock-core 1.2-groovy-2.4 test

包含类文件

文件名称
pl.allegro.tech.hermes.consumers.ConsumerEndpoint.class
pl.allegro.tech.hermes.consumers.HermesConsumers.class
pl.allegro.tech.hermes.consumers.HermesConsumersBuilder.class
pl.allegro.tech.hermes.consumers.consumer.ActiveConsumerCounter.class
pl.allegro.tech.hermes.consumers.consumer.BatchConsumer.class
pl.allegro.tech.hermes.consumers.consumer.Consumer.class
pl.allegro.tech.hermes.consumers.consumer.ConsumerAuthorizationHandler.class
pl.allegro.tech.hermes.consumers.consumer.ConsumerMessageSender.class
pl.allegro.tech.hermes.consumers.consumer.ConsumerMessageSenderFactory.class
pl.allegro.tech.hermes.consumers.consumer.Message.class
pl.allegro.tech.hermes.consumers.consumer.SerialConsumer.class
pl.allegro.tech.hermes.consumers.consumer.batch.BatchMonitoring.class
pl.allegro.tech.hermes.consumers.consumer.batch.ByteBufferMessageBatchFactory.class
pl.allegro.tech.hermes.consumers.consumer.batch.ByteBufferMessageBatchFactoryProvider.class
pl.allegro.tech.hermes.consumers.consumer.batch.DirectBufferPool.class
pl.allegro.tech.hermes.consumers.consumer.batch.JsonMessageBatch.class
pl.allegro.tech.hermes.consumers.consumer.batch.MessageBatch.class
pl.allegro.tech.hermes.consumers.consumer.batch.MessageBatchFactory.class
pl.allegro.tech.hermes.consumers.consumer.batch.MessageBatchReceiver.class
pl.allegro.tech.hermes.consumers.consumer.batch.MessageBatchingResult.class
pl.allegro.tech.hermes.consumers.consumer.converter.AvroToJsonMessageConverter.class
pl.allegro.tech.hermes.consumers.consumer.converter.MessageConverter.class
pl.allegro.tech.hermes.consumers.consumer.converter.MessageConverterResolver.class
pl.allegro.tech.hermes.consumers.consumer.converter.NoOperationMessageConverter.class
pl.allegro.tech.hermes.consumers.consumer.filtering.FilteredMessageHandler.class
pl.allegro.tech.hermes.consumers.consumer.filtering.FilteringException.class
pl.allegro.tech.hermes.consumers.consumer.filtering.MessageFilter.class
pl.allegro.tech.hermes.consumers.consumer.filtering.MessageFilterSource.class
pl.allegro.tech.hermes.consumers.consumer.filtering.MessageFilters.class
pl.allegro.tech.hermes.consumers.consumer.filtering.NoSuchFilterException.class
pl.allegro.tech.hermes.consumers.consumer.filtering.SubscriptionMessageFilterCompiler.class
pl.allegro.tech.hermes.consumers.consumer.filtering.avro.AvroPathPredicate.class
pl.allegro.tech.hermes.consumers.consumer.filtering.avro.AvroPathSubscriptionMessageFilterCompiler.class
pl.allegro.tech.hermes.consumers.consumer.filtering.chain.FilterChain.class
pl.allegro.tech.hermes.consumers.consumer.filtering.chain.FilterChainFactory.class
pl.allegro.tech.hermes.consumers.consumer.filtering.chain.FilterResult.class
pl.allegro.tech.hermes.consumers.consumer.filtering.header.HeaderPredicate.class
pl.allegro.tech.hermes.consumers.consumer.filtering.header.HeaderSubscriptionMessageFilterCompiler.class
pl.allegro.tech.hermes.consumers.consumer.filtering.json.JsonPathPredicate.class
pl.allegro.tech.hermes.consumers.consumer.filtering.json.JsonPathSubscriptionMessageFilterCompiler.class
pl.allegro.tech.hermes.consumers.consumer.idleTime.ExponentiallyGrowingIdleTimeCalculator.class
pl.allegro.tech.hermes.consumers.consumer.idleTime.IdleTimeCalculator.class
pl.allegro.tech.hermes.consumers.consumer.interpolation.InterpolationException.class
pl.allegro.tech.hermes.consumers.consumer.interpolation.MessageBodyInterpolator.class
pl.allegro.tech.hermes.consumers.consumer.interpolation.UriInterpolator.class
pl.allegro.tech.hermes.consumers.consumer.message.MessageConverter.class
pl.allegro.tech.hermes.consumers.consumer.oauth.OAuthAccessToken.class
pl.allegro.tech.hermes.consumers.consumer.oauth.OAuthAccessTokens.class
pl.allegro.tech.hermes.consumers.consumer.oauth.OAuthAccessTokensLoader.class
pl.allegro.tech.hermes.consumers.consumer.oauth.OAuthConsumerAuthorizationHandler.class
pl.allegro.tech.hermes.consumers.consumer.oauth.OAuthProviderCacheListener.class
pl.allegro.tech.hermes.consumers.consumer.oauth.OAuthProvidersNotifyingCache.class
pl.allegro.tech.hermes.consumers.consumer.oauth.OAuthProvidersNotifyingCacheFactory.class
pl.allegro.tech.hermes.consumers.consumer.oauth.OAuthSubscriptionAccessTokens.class
pl.allegro.tech.hermes.consumers.consumer.oauth.OAuthSubscriptionHandler.class
pl.allegro.tech.hermes.consumers.consumer.oauth.OAuthSubscriptionHandlerFactory.class
pl.allegro.tech.hermes.consumers.consumer.oauth.OAuthTokenRequestRateLimiter.class
pl.allegro.tech.hermes.consumers.consumer.oauth.OAuthTokenRequestRateLimiterFactory.class
pl.allegro.tech.hermes.consumers.consumer.oauth.client.OAuthClient.class
pl.allegro.tech.hermes.consumers.consumer.oauth.client.OAuthHttpClient.class
pl.allegro.tech.hermes.consumers.consumer.oauth.client.OAuthTokenRequest.class
pl.allegro.tech.hermes.consumers.consumer.oauth.client.OAuthTokenRequestException.class
pl.allegro.tech.hermes.consumers.consumer.oauth.client.OAuthTokenResponse.class
pl.allegro.tech.hermes.consumers.consumer.offset.FailedToCommitOffsets.class
pl.allegro.tech.hermes.consumers.consumer.offset.OffsetCommitter.class
pl.allegro.tech.hermes.consumers.consumer.offset.OffsetQueue.class
pl.allegro.tech.hermes.consumers.consumer.offset.OffsetsToCommit.class
pl.allegro.tech.hermes.consumers.consumer.offset.SubscriptionPartition.class
pl.allegro.tech.hermes.consumers.consumer.offset.SubscriptionPartitionOffset.class
pl.allegro.tech.hermes.consumers.consumer.offset.kafka.broker.BrokerOffsetCommitErrors.class
pl.allegro.tech.hermes.consumers.consumer.offset.kafka.broker.KafkaConsumerOffsetMover.class
pl.allegro.tech.hermes.consumers.consumer.offset.kafka.broker.PartitionNotAssignedException.class
pl.allegro.tech.hermes.consumers.consumer.offset.kafka.broker.ReadingConsumerMetadataException.class
pl.allegro.tech.hermes.consumers.consumer.rate.AdjustableSemaphore.class
pl.allegro.tech.hermes.consumers.consumer.rate.BatchConsumerRateLimiter.class
pl.allegro.tech.hermes.consumers.consumer.rate.ConsumerRateLimitSupervisor.class
pl.allegro.tech.hermes.consumers.consumer.rate.ConsumerRateLimiter.class
pl.allegro.tech.hermes.consumers.consumer.rate.InflightsPool.class
pl.allegro.tech.hermes.consumers.consumer.rate.SendCounters.class
pl.allegro.tech.hermes.consumers.consumer.rate.SerialConsumerRateLimiter.class
pl.allegro.tech.hermes.consumers.consumer.rate.calculator.HeartbeatModeOutputRateCalculator.class
pl.allegro.tech.hermes.consumers.consumer.rate.calculator.ModeOutputRateCalculator.class
pl.allegro.tech.hermes.consumers.consumer.rate.calculator.NormalModeOutputRateCalculator.class
pl.allegro.tech.hermes.consumers.consumer.rate.calculator.OutputRateCalculationResult.class
pl.allegro.tech.hermes.consumers.consumer.rate.calculator.OutputRateCalculator.class
pl.allegro.tech.hermes.consumers.consumer.rate.calculator.OutputRateCalculatorFactory.class
pl.allegro.tech.hermes.consumers.consumer.rate.calculator.SlowModeOutputRateCalculator.class
pl.allegro.tech.hermes.consumers.consumer.rate.maxrate.ConsumerInstance.class
pl.allegro.tech.hermes.consumers.consumer.rate.maxrate.ConsumerMaxRateStrategy.class
pl.allegro.tech.hermes.consumers.consumer.rate.maxrate.ConsumerRateInfo.class
pl.allegro.tech.hermes.consumers.consumer.rate.maxrate.MaxRate.class
pl.allegro.tech.hermes.consumers.consumer.rate.maxrate.MaxRateBalancer.class
pl.allegro.tech.hermes.consumers.consumer.rate.maxrate.MaxRateCalculator.class
pl.allegro.tech.hermes.consumers.consumer.rate.maxrate.MaxRateCalculatorJob.class
pl.allegro.tech.hermes.consumers.consumer.rate.maxrate.MaxRatePathSerializer.class
pl.allegro.tech.hermes.consumers.consumer.rate.maxrate.MaxRateProvider.class
pl.allegro.tech.hermes.consumers.consumer.rate.maxrate.MaxRateProviderFactory.class
pl.allegro.tech.hermes.consumers.consumer.rate.maxrate.MaxRateRegistry.class
pl.allegro.tech.hermes.consumers.consumer.rate.maxrate.MaxRateSupervisor.class
pl.allegro.tech.hermes.consumers.consumer.rate.maxrate.NegotiatedMaxRateProvider.class
pl.allegro.tech.hermes.consumers.consumer.rate.maxrate.RateHistory.class
pl.allegro.tech.hermes.consumers.consumer.rate.maxrate.RateInfo.class
pl.allegro.tech.hermes.consumers.consumer.rate.maxrate.StrictMaxRateProvider.class
pl.allegro.tech.hermes.consumers.consumer.receiver.ConsumerNotInitializedException.class
pl.allegro.tech.hermes.consumers.consumer.receiver.MessageCommitter.class
pl.allegro.tech.hermes.consumers.consumer.receiver.MessageReceiver.class
pl.allegro.tech.hermes.consumers.consumer.receiver.MessageReceivingTimeoutException.class
pl.allegro.tech.hermes.consumers.consumer.receiver.ReceiverFactory.class
pl.allegro.tech.hermes.consumers.consumer.receiver.ThrottlingMessageReceiver.class
pl.allegro.tech.hermes.consumers.consumer.receiver.UninitializedMessageReceiver.class
pl.allegro.tech.hermes.consumers.consumer.receiver.kafka.FilteringMessageReceiver.class
pl.allegro.tech.hermes.consumers.consumer.receiver.kafka.KafkaMessageReceiverFactory.class
pl.allegro.tech.hermes.consumers.consumer.receiver.kafka.KafkaSingleThreadedMessageReceiver.class
pl.allegro.tech.hermes.consumers.consumer.result.AbstractHandler.class
pl.allegro.tech.hermes.consumers.consumer.result.DefaultErrorHandler.class
pl.allegro.tech.hermes.consumers.consumer.result.DefaultSuccessHandler.class
pl.allegro.tech.hermes.consumers.consumer.result.ErrorHandler.class
pl.allegro.tech.hermes.consumers.consumer.result.SuccessHandler.class
pl.allegro.tech.hermes.consumers.consumer.sender.CompletableFutureAwareMessageSender.class
pl.allegro.tech.hermes.consumers.consumer.sender.HttpMessageBatchSenderFactory.class
pl.allegro.tech.hermes.consumers.consumer.sender.MessageBatchSender.class
pl.allegro.tech.hermes.consumers.consumer.sender.MessageBatchSenderFactory.class
pl.allegro.tech.hermes.consumers.consumer.sender.MessageSender.class
pl.allegro.tech.hermes.consumers.consumer.sender.MessageSenderFactory.class
pl.allegro.tech.hermes.consumers.consumer.sender.MessageSendingResult.class
pl.allegro.tech.hermes.consumers.consumer.sender.MessageSendingResultLogInfo.class
pl.allegro.tech.hermes.consumers.consumer.sender.MultiMessageSendingResult.class
pl.allegro.tech.hermes.consumers.consumer.sender.ProtocolMessageSenderProvider.class
pl.allegro.tech.hermes.consumers.consumer.sender.SingleMessageSendingResult.class
pl.allegro.tech.hermes.consumers.consumer.sender.http.ApacheHttpClientMessageBatchSender.class
pl.allegro.tech.hermes.consumers.consumer.sender.http.ByteBufferEntity.class
pl.allegro.tech.hermes.consumers.consumer.sender.http.DefaultHttpMetadataAppender.class
pl.allegro.tech.hermes.consumers.consumer.sender.http.HttpClientFactory.class
pl.allegro.tech.hermes.consumers.consumer.sender.http.HttpRequestFactory.class
pl.allegro.tech.hermes.consumers.consumer.sender.http.JettyBroadCastMessageSender.class
pl.allegro.tech.hermes.consumers.consumer.sender.http.JettyHttpMessageSenderProvider.class
pl.allegro.tech.hermes.consumers.consumer.sender.http.JettyMessageSender.class
pl.allegro.tech.hermes.consumers.consumer.sender.http.SslContextFactoryProvider.class
pl.allegro.tech.hermes.consumers.consumer.sender.http.auth.BasicAuthProvider.class
pl.allegro.tech.hermes.consumers.consumer.sender.http.auth.HttpAuthorizationProvider.class
pl.allegro.tech.hermes.consumers.consumer.sender.http.auth.HttpAuthorizationProviderFactory.class
pl.allegro.tech.hermes.consumers.consumer.sender.http.auth.OAuthHttpAuthorizationProvider.class
pl.allegro.tech.hermes.consumers.consumer.sender.jms.AbstractJmsMessageSenderProvider.class
pl.allegro.tech.hermes.consumers.consumer.sender.jms.JmsHornetQMessageSenderProvider.class
pl.allegro.tech.hermes.consumers.consumer.sender.jms.JmsMessageSender.class
pl.allegro.tech.hermes.consumers.consumer.sender.jms.JmsMessageSenderProvider.class
pl.allegro.tech.hermes.consumers.consumer.sender.jms.JmsMetadataAppender.class
pl.allegro.tech.hermes.consumers.consumer.sender.resolver.EndpointAddressResolutionException.class
pl.allegro.tech.hermes.consumers.consumer.sender.resolver.EndpointAddressResolver.class
pl.allegro.tech.hermes.consumers.consumer.sender.resolver.InterpolatingEndpointAddressResolver.class
pl.allegro.tech.hermes.consumers.consumer.sender.resolver.ResolvableEndpointAddress.class
pl.allegro.tech.hermes.consumers.consumer.sender.resolver.SimpleEndpointAddressResolver.class
pl.allegro.tech.hermes.consumers.consumer.sender.timeout.FutureAsyncTimeout.class
pl.allegro.tech.hermes.consumers.consumer.sender.timeout.FutureAsyncTimeoutFactory.class
pl.allegro.tech.hermes.consumers.consumer.trace.MetadataAppender.class
pl.allegro.tech.hermes.consumers.di.ConsumersBinder.class
pl.allegro.tech.hermes.consumers.di.TrackersBinder.class
pl.allegro.tech.hermes.consumers.health.Checks.class
pl.allegro.tech.hermes.consumers.health.ConsumerHttpServer.class
pl.allegro.tech.hermes.consumers.health.ConsumerMonitor.class
pl.allegro.tech.hermes.consumers.message.undelivered.UndeliveredMessageLogPersister.class
pl.allegro.tech.hermes.consumers.queue.MonitoredMpscQueue.class
pl.allegro.tech.hermes.consumers.subscription.cache.NotificationsBasedSubscriptionCache.class
pl.allegro.tech.hermes.consumers.subscription.cache.SubscriptionCacheFactory.class
pl.allegro.tech.hermes.consumers.subscription.cache.SubscriptionsCache.class
pl.allegro.tech.hermes.consumers.supervisor.ConsumerFactory.class
pl.allegro.tech.hermes.consumers.supervisor.ConsumerHolder.class
pl.allegro.tech.hermes.consumers.supervisor.ConsumersExecutorService.class
pl.allegro.tech.hermes.consumers.supervisor.ConsumersSupervisor.class
pl.allegro.tech.hermes.consumers.supervisor.NonblockingConsumersSupervisor.class
pl.allegro.tech.hermes.consumers.supervisor.monitor.ConsumersRuntimeMonitor.class
pl.allegro.tech.hermes.consumers.supervisor.monitor.ConsumersRuntimeMonitorFactory.class
pl.allegro.tech.hermes.consumers.supervisor.monitor.DifferenceCalculator.class
pl.allegro.tech.hermes.consumers.supervisor.monitor.SetDifference.class
pl.allegro.tech.hermes.consumers.supervisor.process.ConsumerProcess.class
pl.allegro.tech.hermes.consumers.supervisor.process.ConsumerProcessFactory.class
pl.allegro.tech.hermes.consumers.supervisor.process.ConsumerProcessKiller.class
pl.allegro.tech.hermes.consumers.supervisor.process.ConsumerProcessSupervisor.class
pl.allegro.tech.hermes.consumers.supervisor.process.ConsumerProcessSupplier.class
pl.allegro.tech.hermes.consumers.supervisor.process.Retransmitter.class
pl.allegro.tech.hermes.consumers.supervisor.process.RunningConsumerProcess.class
pl.allegro.tech.hermes.consumers.supervisor.process.RunningConsumerProcesses.class
pl.allegro.tech.hermes.consumers.supervisor.process.RunningSubscriptionStatus.class
pl.allegro.tech.hermes.consumers.supervisor.process.Signal.class
pl.allegro.tech.hermes.consumers.supervisor.process.SignalsFilter.class
pl.allegro.tech.hermes.consumers.supervisor.workload.ConsumerWorkloadAlgorithm.class
pl.allegro.tech.hermes.consumers.supervisor.workload.SubscriptionAssignment.class
pl.allegro.tech.hermes.consumers.supervisor.workload.SubscriptionAssignmentAware.class
pl.allegro.tech.hermes.consumers.supervisor.workload.SubscriptionAssignmentCache.class
pl.allegro.tech.hermes.consumers.supervisor.workload.SubscriptionAssignmentPathSerializer.class
pl.allegro.tech.hermes.consumers.supervisor.workload.SubscriptionAssignmentRegistry.class
pl.allegro.tech.hermes.consumers.supervisor.workload.SubscriptionAssignmentRegistryFactory.class
pl.allegro.tech.hermes.consumers.supervisor.workload.SubscriptionAssignmentView.class
pl.allegro.tech.hermes.consumers.supervisor.workload.SupervisorController.class
pl.allegro.tech.hermes.consumers.supervisor.workload.SupervisorControllerFactory.class
pl.allegro.tech.hermes.consumers.supervisor.workload.WorkTracker.class
pl.allegro.tech.hermes.consumers.supervisor.workload.WorkTrackerFactory.class
pl.allegro.tech.hermes.consumers.supervisor.workload.mirror.MirroringSupervisorController.class
pl.allegro.tech.hermes.consumers.supervisor.workload.selective.AvailableWork.class
pl.allegro.tech.hermes.consumers.supervisor.workload.selective.BalancingJob.class
pl.allegro.tech.hermes.consumers.supervisor.workload.selective.ConsumerNodesRegistry.class
pl.allegro.tech.hermes.consumers.supervisor.workload.selective.SelectiveSupervisorController.class
pl.allegro.tech.hermes.consumers.supervisor.workload.selective.SelectiveWorkBalancer.class
pl.allegro.tech.hermes.consumers.supervisor.workload.selective.WorkBalancingResult.class
pl.allegro.tech.hermes.consumers.uri.InvalidHostException.class
pl.allegro.tech.hermes.consumers.uri.UriUtils.class