jar

com.qunar.qmq : qmq

Maven & Gradle

Apr 12, 2023
2 usages
2.4k stars

qmq-client-deploy · build all in one module

Table Of Contents

Latest Version

Download com.qunar.qmq : qmq JAR file - Latest Versions:

All Versions

Download com.qunar.qmq : qmq JAR file - All Versions:

Version Vulnerabilities Size Updated
1.1.x
1..x
1.0.x

View Java Class Source Code in JAR file

  1. Download JD-GUI to open JAR file and explore Java source code file (.class .java)
  2. Click menu "File → Open File..." or just drag-and-drop the JAR file in the JD-GUI window qmq-1.1.43.jar file.
    Once you open a JAR file, all the java classes in the JAR file will be displayed.

qunar.tc.qmq.consumer.pull.exception

├─ qunar.tc.qmq.consumer.pull.exception.AckException.class - [JAR]

├─ qunar.tc.qmq.consumer.pull.exception.PullException.class - [JAR]

├─ qunar.tc.qmq.consumer.pull.exception.SendMessageBackException.class - [JAR]

qunar.tc.qmq.protocol.consumer

├─ qunar.tc.qmq.protocol.consumer.AckRequest.class - [JAR]

├─ qunar.tc.qmq.protocol.consumer.AckRequestPayloadHolder.class - [JAR]

├─ qunar.tc.qmq.protocol.consumer.MetaInfoRequest.class - [JAR]

├─ qunar.tc.qmq.protocol.consumer.MetaInfoRequestPayloadHolder.class - [JAR]

├─ qunar.tc.qmq.protocol.consumer.MetaInfoResponse.class - [JAR]

├─ qunar.tc.qmq.protocol.consumer.PullFilter.class - [JAR]

├─ qunar.tc.qmq.protocol.consumer.PullFilterType.class - [JAR]

├─ qunar.tc.qmq.protocol.consumer.PullRequest.class - [JAR]

├─ qunar.tc.qmq.protocol.consumer.PullRequestPayloadHolder.class - [JAR]

├─ qunar.tc.qmq.protocol.consumer.PullRequestSerde.class - [JAR]

├─ qunar.tc.qmq.protocol.consumer.SubEnvIsolationPullFilter.class - [JAR]

├─ qunar.tc.qmq.protocol.consumer.TagPullFilter.class - [JAR]

qunar.tc.qmq.utils

├─ qunar.tc.qmq.utils.Bytes.class - [JAR]

├─ qunar.tc.qmq.utils.CharsetUtils.class - [JAR]

├─ qunar.tc.qmq.utils.Checksums.class - [JAR]

├─ qunar.tc.qmq.utils.Crc32.class - [JAR]

├─ qunar.tc.qmq.utils.DelayUtil.class - [JAR]

├─ qunar.tc.qmq.utils.Flags.class - [JAR]

├─ qunar.tc.qmq.utils.ListUtils.class - [JAR]

├─ qunar.tc.qmq.utils.NetworkUtils.class - [JAR]

├─ qunar.tc.qmq.utils.ObjectUtils.class - [JAR]

├─ qunar.tc.qmq.utils.PayloadHolderUtils.class - [JAR]

├─ qunar.tc.qmq.utils.PidUtil.class - [JAR]

├─ qunar.tc.qmq.utils.RetrySubjectUtils.class - [JAR]

├─ qunar.tc.qmq.utils.SubjectUtils.class - [JAR]

qunar.tc.qmq.config

├─ qunar.tc.qmq.config.NettyClientConfigManager.class - [JAR]

├─ qunar.tc.qmq.config.PullSubjectsConfig.class - [JAR]

qunar.tc.qmq.consumer.pull

├─ qunar.tc.qmq.consumer.pull.AbstractPullConsumer.class - [JAR]

├─ qunar.tc.qmq.consumer.pull.AbstractPullEntry.class - [JAR]

├─ qunar.tc.qmq.consumer.pull.AckEntry.class - [JAR]

├─ qunar.tc.qmq.consumer.pull.AckHelper.class - [JAR]

├─ qunar.tc.qmq.consumer.pull.AckHook.class - [JAR]

├─ qunar.tc.qmq.consumer.pull.AckSendEntry.class - [JAR]

├─ qunar.tc.qmq.consumer.pull.AckSendInfo.class - [JAR]

├─ qunar.tc.qmq.consumer.pull.AckSendQueue.class - [JAR]

├─ qunar.tc.qmq.consumer.pull.AckService.class - [JAR]

├─ qunar.tc.qmq.consumer.pull.AlwaysPullStrategy.class - [JAR]

├─ qunar.tc.qmq.consumer.pull.ConsumeParam.class - [JAR]

├─ qunar.tc.qmq.consumer.pull.DefaultPullConsumer.class - [JAR]

├─ qunar.tc.qmq.consumer.pull.DefaultPullEntry.class - [JAR]

├─ qunar.tc.qmq.consumer.pull.DelayMessageService.class - [JAR]

├─ qunar.tc.qmq.consumer.pull.ParallelPullEntry.class - [JAR]

├─ qunar.tc.qmq.consumer.pull.PlainPullEntry.class - [JAR]

├─ qunar.tc.qmq.consumer.pull.PullConsumerFactory.class - [JAR]

├─ qunar.tc.qmq.consumer.pull.PullEntry.class - [JAR]

├─ qunar.tc.qmq.consumer.pull.PullMessageFuture.class - [JAR]

├─ qunar.tc.qmq.consumer.pull.PullParam.class - [JAR]

├─ qunar.tc.qmq.consumer.pull.PullRegister.class - [JAR]

├─ qunar.tc.qmq.consumer.pull.PullResult.class - [JAR]

├─ qunar.tc.qmq.consumer.pull.PullService.class - [JAR]

├─ qunar.tc.qmq.consumer.pull.PullStrategy.class - [JAR]

├─ qunar.tc.qmq.consumer.pull.PulledMessage.class - [JAR]

├─ qunar.tc.qmq.consumer.pull.PulledMessageFilter.class - [JAR]

├─ qunar.tc.qmq.consumer.pull.PushConsumer.class - [JAR]

├─ qunar.tc.qmq.consumer.pull.PushConsumerImpl.class - [JAR]

├─ qunar.tc.qmq.consumer.pull.PushConsumerParam.class - [JAR]

├─ qunar.tc.qmq.consumer.pull.SendMessageBack.class - [JAR]

├─ qunar.tc.qmq.consumer.pull.SendMessageBackImpl.class - [JAR]

├─ qunar.tc.qmq.consumer.pull.WeightLoadBalance.class - [JAR]

qunar.tc.qmq.producer.tx

├─ qunar.tc.qmq.producer.tx.DefaultSqlStatementProvider.class - [JAR]

├─ qunar.tc.qmq.producer.tx.DefaultTransactionListener.class - [JAR]

├─ qunar.tc.qmq.producer.tx.MessageTracker.class - [JAR]

├─ qunar.tc.qmq.producer.tx.SqlStatementProvider.class - [JAR]

├─ qunar.tc.qmq.producer.tx.TransactionMessageHolder.class - [JAR]

qunar.tc.qmq.netty.exception

├─ qunar.tc.qmq.netty.exception.BrokerRejectException.class - [JAR]

├─ qunar.tc.qmq.netty.exception.ClientSendException.class - [JAR]

├─ qunar.tc.qmq.netty.exception.EncodeException.class - [JAR]

├─ qunar.tc.qmq.netty.exception.RemoteBusyException.class - [JAR]

├─ qunar.tc.qmq.netty.exception.RemoteException.class - [JAR]

├─ qunar.tc.qmq.netty.exception.RemoteResponseUnreadableException.class - [JAR]

├─ qunar.tc.qmq.netty.exception.RemoteTimeoutException.class - [JAR]

├─ qunar.tc.qmq.netty.exception.SubjectNotAssignedException.class - [JAR]

qunar.tc.qmq.producer

├─ qunar.tc.qmq.producer.ConfigCenter.class - [JAR]

├─ qunar.tc.qmq.producer.MessageProducerProvider.class - [JAR]

├─ qunar.tc.qmq.producer.ProduceMessageImpl.class - [JAR]

├─ qunar.tc.qmq.producer.QueueSender.class - [JAR]

├─ qunar.tc.qmq.producer.RegistryResolver.class - [JAR]

├─ qunar.tc.qmq.producer.SendErrorHandler.class - [JAR]

qunar.tc.qmq.metrics

├─ qunar.tc.qmq.metrics.Metrics.class - [JAR]

├─ qunar.tc.qmq.metrics.MetricsConstants.class - [JAR]

├─ qunar.tc.qmq.metrics.MockRegistry.class - [JAR]

├─ qunar.tc.qmq.metrics.QmqCounter.class - [JAR]

├─ qunar.tc.qmq.metrics.QmqMeter.class - [JAR]

├─ qunar.tc.qmq.metrics.QmqMetricRegistry.class - [JAR]

├─ qunar.tc.qmq.metrics.QmqTimer.class - [JAR]

qunar.tc.qmq.producer.tx.spring

├─ qunar.tc.qmq.producer.tx.spring.DefaultMessageStore.class - [JAR]

├─ qunar.tc.qmq.producer.tx.spring.RouterSelector.class - [JAR]

├─ qunar.tc.qmq.producer.tx.spring.SpringTransactionProvider.class - [JAR]

qunar.tc.qmq.service.exceptions

├─ qunar.tc.qmq.service.exceptions.BlockMessageException.class - [JAR]

├─ qunar.tc.qmq.service.exceptions.DuplicateMessageException.class - [JAR]

├─ qunar.tc.qmq.service.exceptions.MessageException.class - [JAR]

qunar.tc.qmq.broker

├─ qunar.tc.qmq.broker.BrokerClusterInfo.class - [JAR]

├─ qunar.tc.qmq.broker.BrokerGroupInfo.class - [JAR]

├─ qunar.tc.qmq.broker.BrokerLoadBalance.class - [JAR]

├─ qunar.tc.qmq.broker.BrokerService.class - [JAR]

├─ qunar.tc.qmq.broker.CircuitBreaker.class - [JAR]

qunar.tc.qmq.consumer.annotation

├─ qunar.tc.qmq.consumer.annotation.ConsumerAnnotationScanner.class - [JAR]

├─ qunar.tc.qmq.consumer.annotation.EnableQmq.class - [JAR]

├─ qunar.tc.qmq.consumer.annotation.GeneratedListener.class - [JAR]

├─ qunar.tc.qmq.consumer.annotation.QmqClientBeanDefinitionParser.class - [JAR]

├─ qunar.tc.qmq.consumer.annotation.QmqClientNamespaceHandler.class - [JAR]

├─ qunar.tc.qmq.consumer.annotation.QmqConsumer.class - [JAR]

├─ qunar.tc.qmq.consumer.annotation.QmqConsumerRegister.class - [JAR]

qunar.tc.qmq.configuration

├─ qunar.tc.qmq.configuration.DynamicConfig.class - [JAR]

├─ qunar.tc.qmq.configuration.DynamicConfigFactory.class - [JAR]

├─ qunar.tc.qmq.configuration.DynamicConfigLoader.class - [JAR]

├─ qunar.tc.qmq.configuration.Listener.class - [JAR]

qunar.tc.qmq.protocol.producer

├─ qunar.tc.qmq.protocol.producer.MessageProducerCode.class - [JAR]

├─ qunar.tc.qmq.protocol.producer.SendResult.class - [JAR]

qunar.tc.qmq.meta

├─ qunar.tc.qmq.meta.BrokerCluster.class - [JAR]

├─ qunar.tc.qmq.meta.BrokerGroup.class - [JAR]

├─ qunar.tc.qmq.meta.BrokerGroupKind.class - [JAR]

├─ qunar.tc.qmq.meta.BrokerState.class - [JAR]

├─ qunar.tc.qmq.meta.MetaServerLocator.class - [JAR]

qunar.tc.qmq.consumer

├─ qunar.tc.qmq.consumer.BaseMessageHandler.class - [JAR]

├─ qunar.tc.qmq.consumer.ConsumeMessage.class - [JAR]

├─ qunar.tc.qmq.consumer.MessageConsumerProvider.class - [JAR]

qunar.tc.qmq

├─ qunar.tc.qmq.BaseConsumer.class - [JAR]

├─ qunar.tc.qmq.Filter.class - [JAR]

├─ qunar.tc.qmq.FilterAttachable.class - [JAR]

├─ qunar.tc.qmq.IdempotentAttachable.class - [JAR]

├─ qunar.tc.qmq.IdempotentChecker.class - [JAR]

├─ qunar.tc.qmq.ListenerHolder.class - [JAR]

├─ qunar.tc.qmq.Message.class - [JAR]

├─ qunar.tc.qmq.MessageConsumer.class - [JAR]

├─ qunar.tc.qmq.MessageListener.class - [JAR]

├─ qunar.tc.qmq.MessageProducer.class - [JAR]

├─ qunar.tc.qmq.MessageSendStateListener.class - [JAR]

├─ qunar.tc.qmq.MessageStore.class - [JAR]

├─ qunar.tc.qmq.NeedRetryException.class - [JAR]

├─ qunar.tc.qmq.ProduceMessage.class - [JAR]

├─ qunar.tc.qmq.PullConsumer.class - [JAR]

├─ qunar.tc.qmq.SubscribeParam.class - [JAR]

├─ qunar.tc.qmq.TagType.class - [JAR]

├─ qunar.tc.qmq.TransactionListener.class - [JAR]

├─ qunar.tc.qmq.TransactionProvider.class - [JAR]

qunar.tc.qmq.batch

├─ qunar.tc.qmq.batch.BatchExecutor.class - [JAR]

├─ qunar.tc.qmq.batch.MpscLinkedQueue.class - [JAR]

├─ qunar.tc.qmq.batch.MpscLinkedQueueHeadRef.class - [JAR]

├─ qunar.tc.qmq.batch.MpscLinkedQueueNode.class - [JAR]

├─ qunar.tc.qmq.batch.MpscLinkedQueuePad0.class - [JAR]

├─ qunar.tc.qmq.batch.MpscLinkedQueuePad1.class - [JAR]

├─ qunar.tc.qmq.batch.MpscLinkedQueueTailRef.class - [JAR]

├─ qunar.tc.qmq.batch.MultipleQueueFlusher.class - [JAR]

├─ qunar.tc.qmq.batch.Processor.class - [JAR]

qunar.tc.qmq.netty

├─ qunar.tc.qmq.netty.DecodeHandler.class - [JAR]

├─ qunar.tc.qmq.netty.EncodeHandler.class - [JAR]

├─ qunar.tc.qmq.netty.NettyClientConfig.class - [JAR]

qunar.tc.qmq.protocol

├─ qunar.tc.qmq.protocol.CommandCode.class - [JAR]

├─ qunar.tc.qmq.protocol.Datagram.class - [JAR]

├─ qunar.tc.qmq.protocol.MessagesPayloadHolder.class - [JAR]

├─ qunar.tc.qmq.protocol.PayloadHolder.class - [JAR]

├─ qunar.tc.qmq.protocol.QMQSerializer.class - [JAR]

├─ qunar.tc.qmq.protocol.RemotingCommand.class - [JAR]

├─ qunar.tc.qmq.protocol.RemotingCommandType.class - [JAR]

├─ qunar.tc.qmq.protocol.RemotingHeader.class - [JAR]

qunar.tc.qmq.consumer.register

├─ qunar.tc.qmq.consumer.register.ConsumerRegister.class - [JAR]

├─ qunar.tc.qmq.consumer.register.RegistParam.class - [JAR]

qunar.tc.qmq.consumer.handler

├─ qunar.tc.qmq.consumer.handler.IdempotentCheckerFilter.class - [JAR]

├─ qunar.tc.qmq.consumer.handler.MessageDistributor.class - [JAR]

├─ qunar.tc.qmq.consumer.handler.QTraceFilter.class - [JAR]

qunar.tc.qmq.consumer.exception

├─ qunar.tc.qmq.consumer.exception.CreatePullConsumerException.class - [JAR]

├─ qunar.tc.qmq.consumer.exception.DuplicateListenerException.class - [JAR]

qunar.tc.qmq.util

├─ qunar.tc.qmq.util.ChannelUtil.class - [JAR]

├─ qunar.tc.qmq.util.RemoteHelper.class - [JAR]

├─ qunar.tc.qmq.util.RemotingBuilder.class - [JAR]

qunar.tc.qmq.metainfoclient

├─ qunar.tc.qmq.metainfoclient.ConsumerStateChangedListener.class - [JAR]

├─ qunar.tc.qmq.metainfoclient.MetaInfo.class - [JAR]

├─ qunar.tc.qmq.metainfoclient.MetaInfoClient.class - [JAR]

├─ qunar.tc.qmq.metainfoclient.MetaInfoClientHandler.class - [JAR]

├─ qunar.tc.qmq.metainfoclient.MetaInfoClientNettyImpl.class - [JAR]

├─ qunar.tc.qmq.metainfoclient.MetaInfoService.class - [JAR]

qunar.tc.qmq.tracing

├─ qunar.tc.qmq.tracing.QmqMessageExtractAdapter.class - [JAR]

├─ qunar.tc.qmq.tracing.QmqMessageInjectAdapter.class - [JAR]

├─ qunar.tc.qmq.tracing.TraceUtil.class - [JAR]

qunar.tc.qmq.netty.client

├─ qunar.tc.qmq.netty.client.AbstractNettyClient.class - [JAR]

├─ qunar.tc.qmq.netty.client.ChannelWrapper.class - [JAR]

├─ qunar.tc.qmq.netty.client.HttpResponseCallback.class - [JAR]

├─ qunar.tc.qmq.netty.client.NettyClient.class - [JAR]

├─ qunar.tc.qmq.netty.client.NettyClientHandler.class - [JAR]

├─ qunar.tc.qmq.netty.client.NettyConnectManageHandler.class - [JAR]

├─ qunar.tc.qmq.netty.client.Response.class - [JAR]

├─ qunar.tc.qmq.netty.client.ResponseFuture.class - [JAR]

qunar.tc.qmq.producer.idgenerator

├─ qunar.tc.qmq.producer.idgenerator.IdGenerator.class - [JAR]

├─ qunar.tc.qmq.producer.idgenerator.TimestampAndHostIdGenerator.class - [JAR]

qunar.tc.qmq.broker.impl

├─ qunar.tc.qmq.broker.impl.BrokerServiceImpl.class - [JAR]

├─ qunar.tc.qmq.broker.impl.PollBrokerLoadBalance.class - [JAR]

qunar.tc.qmq.base

├─ qunar.tc.qmq.base.BaseMessage.class - [JAR]

├─ qunar.tc.qmq.base.ClientRequestType.class - [JAR]

├─ qunar.tc.qmq.base.LargeStringUtil.class - [JAR]

├─ qunar.tc.qmq.base.MessageHeader.class - [JAR]

├─ qunar.tc.qmq.base.OnOfflineState.class - [JAR]

├─ qunar.tc.qmq.base.RawMessage.class - [JAR]

├─ qunar.tc.qmq.base.RemoteMessageQuery.class - [JAR]

qunar.tc.qmq.consumer.idempotent

├─ qunar.tc.qmq.consumer.idempotent.AbstractIdempotentChecker.class - [JAR]

├─ qunar.tc.qmq.consumer.idempotent.JdbcIdempotentChecker.class - [JAR]

├─ qunar.tc.qmq.consumer.idempotent.TransactionalJdbcIdempotentChecker.class - [JAR]

qunar.tc.qmq.producer.sender

├─ qunar.tc.qmq.producer.sender.AbstractRouterManager.class - [JAR]

├─ qunar.tc.qmq.producer.sender.Connection.class - [JAR]

├─ qunar.tc.qmq.producer.sender.MessageSenderGroup.class - [JAR]

├─ qunar.tc.qmq.producer.sender.NettyConnection.class - [JAR]

├─ qunar.tc.qmq.producer.sender.NettyProducerClient.class - [JAR]

├─ qunar.tc.qmq.producer.sender.NettyRouter.class - [JAR]

├─ qunar.tc.qmq.producer.sender.NettyRouterManager.class - [JAR]

├─ qunar.tc.qmq.producer.sender.NopRoute.class - [JAR]

├─ qunar.tc.qmq.producer.sender.RPCQueueSender.class - [JAR]

├─ qunar.tc.qmq.producer.sender.Route.class - [JAR]

├─ qunar.tc.qmq.producer.sender.Router.class - [JAR]

├─ qunar.tc.qmq.producer.sender.RouterManager.class - [JAR]

qunar.tc.qmq.configuration.local

├─ qunar.tc.qmq.configuration.local.ConfigWatcher.class - [JAR]

├─ qunar.tc.qmq.configuration.local.LocalDynamicConfig.class - [JAR]

├─ qunar.tc.qmq.configuration.local.LocalDynamicConfigFactory.class - [JAR]

qunar.tc.qmq.concurrent

├─ qunar.tc.qmq.concurrent.NamedThreadFactory.class - [JAR]

qunar.tc.qmq.common

├─ qunar.tc.qmq.common.AtomicConfig.class - [JAR]

├─ qunar.tc.qmq.common.AtomicIntegerConfig.class - [JAR]

├─ qunar.tc.qmq.common.ClientIdProvider.class - [JAR]

├─ qunar.tc.qmq.common.ClientIdProviderFactory.class - [JAR]

├─ qunar.tc.qmq.common.ClientInfo.class - [JAR]

├─ qunar.tc.qmq.common.ClientType.class - [JAR]

├─ qunar.tc.qmq.common.DefaultClientIdProvider.class - [JAR]

├─ qunar.tc.qmq.common.Disposable.class - [JAR]

├─ qunar.tc.qmq.common.EnvProvider.class - [JAR]

├─ qunar.tc.qmq.common.MapKeyBuilder.class - [JAR]

├─ qunar.tc.qmq.common.StatusSource.class - [JAR]

├─ qunar.tc.qmq.common.SwitchWaiter.class - [JAR]

├─ qunar.tc.qmq.common.TimerUtil.class - [JAR]

Advertisement

Dependencies from Group

qmq
Apr 12, 2023
2 usages
2.4k stars
Apr 12, 2023
2.7k stars
Apr 12, 2023
2.4k stars
Apr 12, 2023
2.4k stars
Apr 12, 2023
2.4k stars

Discover Dependencies

Dec 26, 2022
2 usages
123 stars
Mar 09, 2023
0 stars
Dec 12, 2018
9 stars
Aug 28, 2020
59.1k stars
Dec 12, 2018
66 stars
Jun 22, 2020
9 usages
Jun 22, 2020
2 stars
Dec 29, 2021
12 usages
Dec 11, 2018
5 usages