Uses of Class
org.apache.activemq.command.ProducerId
-
Packages that use ProducerId Package Description org.apache.activemq The core JMS client API implementation classes.org.apache.activemq.advisory Support for JMS Advisory messages as well as some helper listeners to listen to the clients, producers and consumers available.org.apache.activemq.broker The core classes for the ActiveMQ Message Broker and its connectors.org.apache.activemq.broker.region.policy The policies which can be associated with a particular destination or wildcard.org.apache.activemq.broker.view Broker Plugins for visualising the current systemorg.apache.activemq.command Command objects used via the Command Pattern to communicate among nodesorg.apache.activemq.plugin org.apache.activemq.state org.apache.activemq.store The APIs which need to be implemented for persistent message stores for durable messagingorg.apache.activemq.store.jdbc Message persistence implemented using JDBCorg.apache.activemq.store.jdbc.adapter Implements database/driver apapters to compensate for the wide differences in the BLOB handing of JDBC drivers.org.apache.activemq.store.journal Message persistence using a high performance transaction log via the Journal interface.org.apache.activemq.store.kahadb org.apache.activemq.store.memory VM based implementation of message persistenceorg.apache.activemq.transport.amqp.protocol -
-
Uses of ProducerId in org.apache.activemq
Methods in org.apache.activemq that return ProducerId Modifier and Type Method Description protected ProducerIdActiveMQSession. getNextProducerId()Methods in org.apache.activemq with parameters of type ProducerId Modifier and Type Method Description voidActiveMQConnection. addProducer(ProducerId producerId, ActiveMQMessageProducer producer)longActiveMQMessageAuditNoSync. getLastSeqId(ProducerId id)voidActiveMQConnection. removeProducer(ProducerId producerId)Constructors in org.apache.activemq with parameters of type ProducerId Constructor Description ActiveMQMessageProducer(ActiveMQSession session, ProducerId producerId, ActiveMQDestination destination, int sendTimeout) -
Uses of ProducerId in org.apache.activemq.advisory
Fields in org.apache.activemq.advisory declared as ProducerId Modifier and Type Field Description protected ProducerIdAdvisoryBroker. advisoryProducerIdFields in org.apache.activemq.advisory with type parameters of type ProducerId Modifier and Type Field Description protected ConcurrentMap<ProducerId,ProducerInfo>AdvisoryBroker. producersMethods in org.apache.activemq.advisory that return ProducerId Modifier and Type Method Description ProducerIdProducerEvent. getProducerId()Methods in org.apache.activemq.advisory that return types with arguments of type ProducerId Modifier and Type Method Description Map<ProducerId,ProducerInfo>AdvisoryBroker. getAdvisoryProducers()Constructors in org.apache.activemq.advisory with parameters of type ProducerId Constructor Description ProducerEvent(ProducerEventSource source, Destination destination, ProducerId producerId, int producerCount)ProducerStoppedEvent(ProducerEventSource source, ActiveMQDestination destination, ProducerId consumerId, int count) -
Uses of ProducerId in org.apache.activemq.broker
Methods in org.apache.activemq.broker with parameters of type ProducerId Modifier and Type Method Description TransportConnectionStateMapTransportConnectionStateRegister. lookupConnectionState(ProducerId id)TransportConnectionStateSingleTransportConnectionStateRegister. lookupConnectionState(ProducerId id)protected TransportConnectionStateTransportConnection. lookupConnectionState(ProducerId id)TransportConnectionStateTransportConnectionStateRegister. lookupConnectionState(ProducerId id)ResponseTransportConnection. processRemoveProducer(ProducerId id) -
Uses of ProducerId in org.apache.activemq.broker.region.policy
Methods in org.apache.activemq.broker.region.policy that return ProducerId Modifier and Type Method Description protected ProducerIdQueryBasedSubscriptionRecoveryPolicy. createProducerId() -
Uses of ProducerId in org.apache.activemq.broker.view
Methods in org.apache.activemq.broker.view with parameters of type ProducerId Modifier and Type Method Description protected voidConnectionDotFileInterceptor. printProducers(PrintWriter writer, Map<String,String> clients, Map<String,String> queues, Map<String,String> topics, ProducerId producerId, Set destinationSet) -
Uses of ProducerId in org.apache.activemq.command
Fields in org.apache.activemq.command declared as ProducerId Modifier and Type Field Description protected ProducerIdMessage. producerIdprotected ProducerIdMessageId. producerIdprotected ProducerIdProducerAck. producerIdprotected ProducerIdProducerInfo. producerIdMethods in org.apache.activemq.command that return ProducerId Modifier and Type Method Description ProducerIdMessage. getProducerId()ProducerIdMessageId. getProducerId()ProducerIdProducerAck. getProducerId()The producer id that this ack message is destined for.ProducerIdProducerInfo. getProducerId()Methods in org.apache.activemq.command with parameters of type ProducerId Modifier and Type Method Description voidActiveMQMessage. setJMSMessageID(ProducerId producerId, long producerSequenceId)This will create an object of MessageId.voidMessage. setProducerId(ProducerId producerId)voidMessageId. setProducerId(ProducerId producerId)voidProducerAck. setProducerId(ProducerId producerId)voidProducerInfo. setProducerId(ProducerId producerId)Constructors in org.apache.activemq.command with parameters of type ProducerId Constructor Description ConnectionId(ProducerId id)MessageId(ProducerId producerId, long producerSequenceId)ProducerAck(ProducerId producerId, int size)ProducerId(ProducerId id)ProducerInfo(ProducerId producerId)SessionId(ProducerId id) -
Uses of ProducerId in org.apache.activemq.plugin
Fields in org.apache.activemq.plugin declared as ProducerId Modifier and Type Field Description protected ProducerIdStatisticsBroker. advisoryProducerId -
Uses of ProducerId in org.apache.activemq.state
Methods in org.apache.activemq.state that return types with arguments of type ProducerId Modifier and Type Method Description Set<ProducerId>SessionState. getProducerIds()Map<ProducerId,ProducerState>TransactionState. getProducerStates()Methods in org.apache.activemq.state with parameters of type ProducerId Modifier and Type Method Description ProducerStateSessionState. getProducerState(ProducerId producerId)ResponseCommandVisitor. processRemoveProducer(ProducerId id)ResponseCommandVisitorAdapter. processRemoveProducer(ProducerId id)ResponseConnectionStateTracker. processRemoveProducer(ProducerId id)ProducerStateSessionState. removeProducer(ProducerId id) -
Uses of ProducerId in org.apache.activemq.store
Methods in org.apache.activemq.store with parameters of type ProducerId Modifier and Type Method Description longPersistenceAdapter. getLastProducerSequenceId(ProducerId id)return the last stored producer sequenceId for this producer Id used to suppress duplicate sends on failover reconnect at the transport when a reconnect occurs -
Uses of ProducerId in org.apache.activemq.store.jdbc
Methods in org.apache.activemq.store.jdbc with parameters of type ProducerId Modifier and Type Method Description longJDBCAdapter. doGetLastProducerSequenceId(TransactionContext c, ProducerId id)longJDBCPersistenceAdapter. getLastProducerSequenceId(ProducerId id) -
Uses of ProducerId in org.apache.activemq.store.jdbc.adapter
Methods in org.apache.activemq.store.jdbc.adapter with parameters of type ProducerId Modifier and Type Method Description longDefaultJDBCAdapter. doGetLastProducerSequenceId(TransactionContext c, ProducerId id) -
Uses of ProducerId in org.apache.activemq.store.journal
Methods in org.apache.activemq.store.journal with parameters of type ProducerId Modifier and Type Method Description longJournalPersistenceAdapter. getLastProducerSequenceId(ProducerId id) -
Uses of ProducerId in org.apache.activemq.store.kahadb
Methods in org.apache.activemq.store.kahadb with parameters of type ProducerId Modifier and Type Method Description longKahaDBPersistenceAdapter. getLastProducerSequenceId(ProducerId id)longKahaDBStore. getLastProducerSequenceId(ProducerId id)longMultiKahaDBPersistenceAdapter. getLastProducerSequenceId(ProducerId id)longTempKahaDBStore. getLastProducerSequenceId(ProducerId id) -
Uses of ProducerId in org.apache.activemq.store.memory
Methods in org.apache.activemq.store.memory with parameters of type ProducerId Modifier and Type Method Description longMemoryPersistenceAdapter. getLastProducerSequenceId(ProducerId id) -
Uses of ProducerId in org.apache.activemq.transport.amqp.protocol
Methods in org.apache.activemq.transport.amqp.protocol that return ProducerId Modifier and Type Method Description ProducerIdAmqpReceiver. getProducerId()
-