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 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
|
Modifier and Type | Method and Description |
---|---|
protected ProducerId |
ActiveMQSession.getNextProducerId() |
Modifier and Type | Method and Description |
---|---|
void |
ActiveMQConnection.addProducer(ProducerId producerId,
ActiveMQMessageProducer producer) |
long |
ActiveMQMessageAuditNoSync.getLastSeqId(ProducerId id) |
void |
ActiveMQConnection.removeProducer(ProducerId producerId) |
Constructor and Description |
---|
ActiveMQMessageProducer(ActiveMQSession session,
ProducerId producerId,
ActiveMQDestination destination,
int sendTimeout) |
ActiveMQOutputStream(ActiveMQConnection connection,
ProducerId producerId,
ActiveMQDestination destination,
Map<String,Object> properties,
int deliveryMode,
int priority,
long timeToLive) |
Modifier and Type | Field and Description |
---|---|
protected ProducerId |
AdvisoryBroker.advisoryProducerId |
Modifier and Type | Field and Description |
---|---|
protected ConcurrentHashMap<ProducerId,ProducerInfo> |
AdvisoryBroker.producers |
Modifier and Type | Method and Description |
---|---|
ProducerId |
ProducerEvent.getProducerId() |
Modifier and Type | Method and Description |
---|---|
Map<ProducerId,ProducerInfo> |
AdvisoryBroker.getAdvisoryProducers() |
Constructor and Description |
---|
ProducerEvent(ProducerEventSource source,
javax.jms.Destination destination,
ProducerId producerId,
int producerCount) |
ProducerStoppedEvent(ProducerEventSource source,
ActiveMQDestination destination,
ProducerId consumerId,
int count) |
Modifier and Type | Method and Description |
---|---|
TransportConnectionState |
SingleTransportConnectionStateRegister.lookupConnectionState(ProducerId id) |
TransportConnectionState |
TransportConnectionStateRegister.lookupConnectionState(ProducerId id) |
protected TransportConnectionState |
TransportConnection.lookupConnectionState(ProducerId id) |
TransportConnectionState |
MapTransportConnectionStateRegister.lookupConnectionState(ProducerId id) |
Response |
TransportConnection.processRemoveProducer(ProducerId id) |
Modifier and Type | Method and Description |
---|---|
protected ProducerId |
QueryBasedSubscriptionRecoveryPolicy.createProducerId() |
Modifier and Type | Method and Description |
---|---|
protected void |
ConnectionDotFileInterceptor.printProducers(PrintWriter writer,
Map<String,String> clients,
Map<String,String> queues,
Map<String,String> topics,
ProducerId producerId,
Set destinationSet) |
Modifier and Type | Field and Description |
---|---|
protected ProducerId |
ProducerAck.producerId |
protected ProducerId |
Message.producerId |
protected ProducerId |
MessageId.producerId |
protected ProducerId |
ProducerInfo.producerId |
Modifier and Type | Method and Description |
---|---|
ProducerId |
ProducerAck.getProducerId()
The producer id that this ack message is destined for.
|
ProducerId |
Message.getProducerId() |
ProducerId |
MessageId.getProducerId() |
ProducerId |
ProducerInfo.getProducerId() |
Modifier and Type | Method and Description |
---|---|
void |
ActiveMQMessage.setJMSMessageID(ProducerId producerId,
long producerSequenceId)
This will create an object of MessageId.
|
void |
ProducerAck.setProducerId(ProducerId producerId) |
void |
Message.setProducerId(ProducerId producerId) |
void |
MessageId.setProducerId(ProducerId producerId) |
void |
ProducerInfo.setProducerId(ProducerId producerId) |
Constructor and Description |
---|
ConnectionId(ProducerId id) |
MessageId(ProducerId producerId,
long producerSequenceId) |
ProducerAck(ProducerId producerId,
int size) |
ProducerId(ProducerId id) |
ProducerInfo(ProducerId producerId) |
SessionId(ProducerId id) |
Modifier and Type | Field and Description |
---|---|
protected ProducerId |
StatisticsBroker.advisoryProducerId |
Modifier and Type | Method and Description |
---|---|
Set<ProducerId> |
SessionState.getProducerIds() |
Map<ProducerId,ProducerState> |
TransactionState.getProducerStates() |
Modifier and Type | Method and Description |
---|---|
ProducerState |
SessionState.getProducerState(ProducerId producerId) |
Response |
CommandVisitor.processRemoveProducer(ProducerId id) |
Response |
ConnectionStateTracker.processRemoveProducer(ProducerId id) |
Response |
CommandVisitorAdapter.processRemoveProducer(ProducerId id) |
ProducerState |
SessionState.removeProducer(ProducerId id) |
Modifier and Type | Method and 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
|
Modifier and Type | Method and Description |
---|---|
long |
AMQPersistenceAdapter.getLastProducerSequenceId(ProducerId id) |
Modifier and Type | Method and Description |
---|---|
long |
JDBCAdapter.doGetLastProducerSequenceId(TransactionContext c,
ProducerId id) |
long |
JDBCPersistenceAdapter.getLastProducerSequenceId(ProducerId id) |
Modifier and Type | Method and Description |
---|---|
long |
DefaultJDBCAdapter.doGetLastProducerSequenceId(TransactionContext c,
ProducerId id) |
Modifier and Type | Method and Description |
---|---|
long |
JournalPersistenceAdapter.getLastProducerSequenceId(ProducerId id) |
Modifier and Type | Method and Description |
---|---|
long |
KahaPersistenceAdapter.getLastProducerSequenceId(ProducerId id) |
Modifier and Type | Method and Description |
---|---|
long |
KahaDBPersistenceAdapter.getLastProducerSequenceId(ProducerId id) |
long |
TempKahaDBStore.getLastProducerSequenceId(ProducerId id) |
long |
KahaDBStore.getLastProducerSequenceId(ProducerId id) |
long |
MultiKahaDBPersistenceAdapter.getLastProducerSequenceId(ProducerId id) |
Modifier and Type | Method and Description |
---|---|
long |
MemoryPersistenceAdapter.getLastProducerSequenceId(ProducerId id) |
Copyright © 2005–2015. All rights reserved.