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 ProducerId
ActiveMQSession. getNextProducerId()
Methods in org.apache.activemq with parameters of type ProducerId Modifier and Type Method Description void
ActiveMQConnection. addProducer(ProducerId producerId, ActiveMQMessageProducer producer)
long
ActiveMQMessageAuditNoSync. getLastSeqId(ProducerId id)
void
ActiveMQConnection. 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 ProducerId
AdvisoryBroker. advisoryProducerId
Fields in org.apache.activemq.advisory with type parameters of type ProducerId Modifier and Type Field Description protected ConcurrentMap<ProducerId,ProducerInfo>
AdvisoryBroker. producers
Methods in org.apache.activemq.advisory that return ProducerId Modifier and Type Method Description ProducerId
ProducerEvent. 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 TransportConnectionState
MapTransportConnectionStateRegister. lookupConnectionState(ProducerId id)
TransportConnectionState
SingleTransportConnectionStateRegister. lookupConnectionState(ProducerId id)
protected TransportConnectionState
TransportConnection. lookupConnectionState(ProducerId id)
TransportConnectionState
TransportConnectionStateRegister. lookupConnectionState(ProducerId id)
Response
TransportConnection. 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 ProducerId
QueryBasedSubscriptionRecoveryPolicy. 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 void
ConnectionDotFileInterceptor. 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 ProducerId
Message. producerId
protected ProducerId
MessageId. producerId
protected ProducerId
ProducerAck. producerId
protected ProducerId
ProducerInfo. producerId
Methods in org.apache.activemq.command that return ProducerId Modifier and Type Method Description ProducerId
Message. getProducerId()
ProducerId
MessageId. getProducerId()
ProducerId
ProducerAck. getProducerId()
The producer id that this ack message is destined for.ProducerId
ProducerInfo. getProducerId()
Methods in org.apache.activemq.command with parameters of type ProducerId Modifier and Type Method Description void
ActiveMQMessage. setJMSMessageID(ProducerId producerId, long producerSequenceId)
This will create an object of MessageId.void
Message. setProducerId(ProducerId producerId)
void
MessageId. setProducerId(ProducerId producerId)
void
ProducerAck. setProducerId(ProducerId producerId)
void
ProducerInfo. 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 ProducerId
StatisticsBroker. 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 ProducerState
SessionState. getProducerState(ProducerId producerId)
Response
CommandVisitor. processRemoveProducer(ProducerId id)
Response
CommandVisitorAdapter. processRemoveProducer(ProducerId id)
Response
ConnectionStateTracker. processRemoveProducer(ProducerId id)
ProducerState
SessionState. 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 long
PersistenceAdapter. 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 long
JDBCAdapter. doGetLastProducerSequenceId(TransactionContext c, ProducerId id)
long
JDBCPersistenceAdapter. 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 long
DefaultJDBCAdapter. 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 long
JournalPersistenceAdapter. 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 long
KahaDBPersistenceAdapter. getLastProducerSequenceId(ProducerId id)
long
KahaDBStore. getLastProducerSequenceId(ProducerId id)
long
MultiKahaDBPersistenceAdapter. getLastProducerSequenceId(ProducerId id)
long
TempKahaDBStore. 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 long
MemoryPersistenceAdapter. 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 ProducerId
AmqpReceiver. getProducerId()
-