|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use ProducerId | |
---|---|
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 system |
org.apache.activemq.command | Command objects used via the Command Pattern to communicate among nodes |
org.apache.activemq.plugin | |
org.apache.activemq.state | |
org.apache.activemq.store | The APIs which need to be implemented for persistent message stores for durable messaging |
org.apache.activemq.store.amq | The default Store implementation for ActiveMQ |
org.apache.activemq.store.jdbc | Message persistence implemented using JDBC |
org.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.kahadaptor | kaha implementation of message persistence for the broker |
org.apache.activemq.store.kahadb | |
org.apache.activemq.store.memory | VM based implementation of message persistence |
Uses of ProducerId in org.apache.activemq |
---|
Methods in org.apache.activemq that return ProducerId | |
---|---|
protected ProducerId |
ActiveMQSession.getNextProducerId()
|
Methods in org.apache.activemq with parameters of type ProducerId | |
---|---|
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 | |
---|---|
ActiveMQMessageProducer(ActiveMQSession session,
ProducerId producerId,
ActiveMQDestination destination,
int sendTimeout)
|
|
ActiveMQOutputStream(ActiveMQConnection connection,
ProducerId producerId,
ActiveMQDestination destination,
java.util.Map<java.lang.String,java.lang.Object> properties,
int deliveryMode,
int priority,
long timeToLive)
|
Uses of ProducerId in org.apache.activemq.advisory |
---|
Fields in org.apache.activemq.advisory declared as ProducerId | |
---|---|
protected ProducerId |
AdvisoryBroker.advisoryProducerId
|
Fields in org.apache.activemq.advisory with type parameters of type ProducerId | |
---|---|
protected java.util.concurrent.ConcurrentHashMap<ProducerId,ProducerInfo> |
AdvisoryBroker.producers
|
Methods in org.apache.activemq.advisory that return ProducerId | |
---|---|
ProducerId |
ProducerEvent.getProducerId()
|
Methods in org.apache.activemq.advisory that return types with arguments of type ProducerId | |
---|---|
java.util.Map<ProducerId,ProducerInfo> |
AdvisoryBroker.getAdvisoryProducers()
|
Constructors in org.apache.activemq.advisory with parameters of type ProducerId | |
---|---|
ProducerEvent(ProducerEventSource source,
javax.jms.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 | |
---|---|
TransportConnectionState |
SingleTransportConnectionStateRegister.lookupConnectionState(ProducerId id)
|
TransportConnectionState |
MapTransportConnectionStateRegister.lookupConnectionState(ProducerId id)
|
TransportConnectionState |
TransportConnectionStateRegister.lookupConnectionState(ProducerId id)
|
protected TransportConnectionState |
TransportConnection.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 | |
---|---|
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 | |
---|---|
protected void |
ConnectionDotFileInterceptor.printProducers(java.io.PrintWriter writer,
java.util.Map<java.lang.String,java.lang.String> clients,
java.util.Map<java.lang.String,java.lang.String> queues,
java.util.Map<java.lang.String,java.lang.String> topics,
ProducerId producerId,
java.util.Set destinationSet)
|
Uses of ProducerId in org.apache.activemq.command |
---|
Fields in org.apache.activemq.command declared as ProducerId | |
---|---|
protected ProducerId |
MessageId.producerId
|
protected ProducerId |
ProducerAck.producerId
|
protected ProducerId |
Message.producerId
|
protected ProducerId |
ProducerInfo.producerId
|
Methods in org.apache.activemq.command that return ProducerId | |
---|---|
ProducerId |
MessageId.getProducerId()
|
ProducerId |
ProducerAck.getProducerId()
The producer id that this ack message is destined for. |
ProducerId |
Message.getProducerId()
|
ProducerId |
ProducerInfo.getProducerId()
|
Methods in org.apache.activemq.command with parameters of type ProducerId | |
---|---|
void |
ActiveMQMessage.setJMSMessageID(ProducerId producerId,
long producerSequenceId)
This will create an object of MessageId. |
void |
MessageId.setProducerId(ProducerId producerId)
|
void |
ProducerAck.setProducerId(ProducerId producerId)
|
void |
Message.setProducerId(ProducerId producerId)
|
void |
ProducerInfo.setProducerId(ProducerId producerId)
|
Constructors in org.apache.activemq.command with parameters of type ProducerId | |
---|---|
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 | |
---|---|
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 | |
---|---|
java.util.Set<ProducerId> |
SessionState.getProducerIds()
|
java.util.Map<ProducerId,ProducerState> |
TransactionState.getProducerStates()
|
Methods in org.apache.activemq.state with parameters of type ProducerId | |
---|---|
ProducerState |
SessionState.getProducerState(ProducerId producerId)
|
Response |
CommandVisitorAdapter.processRemoveProducer(ProducerId id)
|
Response |
ConnectionStateTracker.processRemoveProducer(ProducerId id)
|
Response |
CommandVisitor.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 | |
---|---|
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.amq |
---|
Methods in org.apache.activemq.store.amq with parameters of type ProducerId | |
---|---|
long |
AMQPersistenceAdapter.getLastProducerSequenceId(ProducerId id)
|
Uses of ProducerId in org.apache.activemq.store.jdbc |
---|
Methods in org.apache.activemq.store.jdbc with parameters of type ProducerId | |
---|---|
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 | |
---|---|
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 | |
---|---|
long |
JournalPersistenceAdapter.getLastProducerSequenceId(ProducerId id)
|
Uses of ProducerId in org.apache.activemq.store.kahadaptor |
---|
Methods in org.apache.activemq.store.kahadaptor with parameters of type ProducerId | |
---|---|
long |
KahaPersistenceAdapter.getLastProducerSequenceId(ProducerId id)
|
Uses of ProducerId in org.apache.activemq.store.kahadb |
---|
Methods in org.apache.activemq.store.kahadb with parameters of type ProducerId | |
---|---|
long |
TempKahaDBStore.getLastProducerSequenceId(ProducerId id)
|
long |
KahaDBPersistenceAdapter.getLastProducerSequenceId(ProducerId id)
|
long |
KahaDBStore.getLastProducerSequenceId(ProducerId id)
|
Uses of ProducerId in org.apache.activemq.store.memory |
---|
Methods in org.apache.activemq.store.memory with parameters of type ProducerId | |
---|---|
long |
MemoryPersistenceAdapter.getLastProducerSequenceId(ProducerId id)
|
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |