|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use ActiveMQTopic | |
---|---|
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.region | Region abstraction and implementations in the Broker. |
org.apache.activemq.console.filter | |
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.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 ActiveMQTopic in org.apache.activemq.advisory |
---|
Fields in org.apache.activemq.advisory declared as ActiveMQTopic | |
---|---|
static ActiveMQTopic |
AdvisorySupport.ALL_DESTINATIONS_COMPOSITE_ADVISORY_TOPIC
|
static ActiveMQTopic |
AdvisorySupport.CONNECTION_ADVISORY_TOPIC
|
static ActiveMQTopic |
AdvisorySupport.QUEUE_ADVISORY_TOPIC
|
static ActiveMQTopic |
AdvisorySupport.TEMP_DESTINATION_COMPOSITE_ADVISORY_TOPIC
|
static ActiveMQTopic |
AdvisorySupport.TEMP_QUEUE_ADVISORY_TOPIC
|
static ActiveMQTopic |
AdvisorySupport.TEMP_TOPIC_ADVISORY_TOPIC
|
static ActiveMQTopic |
AdvisorySupport.TOPIC_ADVISORY_TOPIC
|
Methods in org.apache.activemq.advisory that return types with arguments of type ActiveMQTopic | |
---|---|
java.util.Set<ActiveMQTopic> |
DestinationSource.getTopics()
Returns the current topics on the broker |
Methods in org.apache.activemq.advisory with parameters of type ActiveMQTopic | |
---|---|
protected void |
AdvisoryBroker.fireAdvisory(ConnectionContext context,
ActiveMQTopic topic,
Command command)
|
protected void |
AdvisoryBroker.fireAdvisory(ConnectionContext context,
ActiveMQTopic topic,
Command command,
ConsumerId targetConsumerId)
|
protected void |
AdvisoryBroker.fireAdvisory(ConnectionContext context,
ActiveMQTopic topic,
Command command,
ConsumerId targetConsumerId,
ActiveMQMessage advisoryMessage)
|
protected void |
AdvisoryBroker.fireConsumerAdvisory(ConnectionContext context,
ActiveMQDestination consumerDestination,
ActiveMQTopic topic,
Command command)
|
protected void |
AdvisoryBroker.fireConsumerAdvisory(ConnectionContext context,
ActiveMQDestination consumerDestination,
ActiveMQTopic topic,
Command command,
ConsumerId targetConsumerId)
|
protected void |
AdvisoryBroker.fireProducerAdvisory(ConnectionContext context,
ActiveMQDestination producerDestination,
ActiveMQTopic topic,
Command command)
|
protected void |
AdvisoryBroker.fireProducerAdvisory(ConnectionContext context,
ActiveMQDestination producerDestination,
ActiveMQTopic topic,
Command command,
ConsumerId targetConsumerId)
|
Uses of ActiveMQTopic in org.apache.activemq.broker.region |
---|
Methods in org.apache.activemq.broker.region with parameters of type ActiveMQTopic | |
---|---|
abstract SubscriptionInfo[] |
DestinationFactory.getAllDurableSubscriptions(ActiveMQTopic topic)
Lists all the durable subscirptions for a given destination. |
SubscriptionInfo[] |
DestinationFactoryImpl.getAllDurableSubscriptions(ActiveMQTopic topic)
|
Uses of ActiveMQTopic in org.apache.activemq.console.filter |
---|
Methods in org.apache.activemq.console.filter with parameters of type ActiveMQTopic | |
---|---|
protected java.util.List |
AmqMessagesQueryFilter.queryMessages(ActiveMQTopic topic,
java.lang.String selector)
Query the messages of a topic destination using a message consumer |
Uses of ActiveMQTopic in org.apache.activemq.store |
---|
Methods in org.apache.activemq.store with parameters of type ActiveMQTopic | |
---|---|
TopicMessageStore |
PersistenceAdapter.createTopicMessageStore(ActiveMQTopic destination)
Factory method to create a new topic message store with the given destination name |
TopicReferenceStore |
ReferenceStoreAdapter.createTopicReferenceStore(ActiveMQTopic destination)
Factory method to create a new topic message store with the given destination name |
void |
PersistenceAdapter.removeTopicMessageStore(ActiveMQTopic destination)
Cleanup method to remove any state associated with the given destination This method does not stop the message store (it might not be cached). |
Uses of ActiveMQTopic in org.apache.activemq.store.amq |
---|
Methods in org.apache.activemq.store.amq with parameters of type ActiveMQTopic | |
---|---|
TopicMessageStore |
AMQPersistenceAdapter.createTopicMessageStore(ActiveMQTopic destinationName)
|
void |
AMQPersistenceAdapter.removeTopicMessageStore(ActiveMQTopic destination)
Cleanup method to remove any state associated with the given destination |
Constructors in org.apache.activemq.store.amq with parameters of type ActiveMQTopic | |
---|---|
AMQTopicMessageStore(AMQPersistenceAdapter adapter,
TopicReferenceStore topicReferenceStore,
ActiveMQTopic destinationName)
|
Uses of ActiveMQTopic in org.apache.activemq.store.jdbc |
---|
Methods in org.apache.activemq.store.jdbc with parameters of type ActiveMQTopic | |
---|---|
TopicMessageStore |
JDBCPersistenceAdapter.createTopicMessageStore(ActiveMQTopic destination)
|
void |
JDBCPersistenceAdapter.removeTopicMessageStore(ActiveMQTopic destination)
Cleanup method to remove any state associated with the given destination No state retained.... |
Constructors in org.apache.activemq.store.jdbc with parameters of type ActiveMQTopic | |
---|---|
JDBCTopicMessageStore(JDBCPersistenceAdapter persistenceAdapter,
JDBCAdapter adapter,
WireFormat wireFormat,
ActiveMQTopic topic,
ActiveMQMessageAudit audit)
|
Uses of ActiveMQTopic in org.apache.activemq.store.journal |
---|
Methods in org.apache.activemq.store.journal with parameters of type ActiveMQTopic | |
---|---|
TopicMessageStore |
JournalPersistenceAdapter.createTopicMessageStore(ActiveMQTopic destinationName)
|
void |
JournalPersistenceAdapter.removeTopicMessageStore(ActiveMQTopic destination)
Cleanup method to remove any state associated with the given destination |
Constructors in org.apache.activemq.store.journal with parameters of type ActiveMQTopic | |
---|---|
JournalTopicMessageStore(JournalPersistenceAdapter adapter,
TopicMessageStore checkpointStore,
ActiveMQTopic destinationName)
|
Uses of ActiveMQTopic in org.apache.activemq.store.kahadaptor |
---|
Fields in org.apache.activemq.store.kahadaptor with type parameters of type ActiveMQTopic | |
---|---|
protected java.util.concurrent.ConcurrentHashMap<ActiveMQTopic,TopicMessageStore> |
KahaPersistenceAdapter.topics
|
Methods in org.apache.activemq.store.kahadaptor with parameters of type ActiveMQTopic | |
---|---|
TopicMessageStore |
KahaReferenceStoreAdapter.createTopicMessageStore(ActiveMQTopic destination)
|
TopicMessageStore |
KahaPersistenceAdapter.createTopicMessageStore(ActiveMQTopic destination)
|
TopicReferenceStore |
KahaReferenceStoreAdapter.createTopicReferenceStore(ActiveMQTopic destination)
|
void |
KahaPersistenceAdapter.removeTopicMessageStore(ActiveMQTopic destination)
Cleanup method to remove any state associated with the given destination |
Uses of ActiveMQTopic in org.apache.activemq.store.kahadb |
---|
Methods in org.apache.activemq.store.kahadb with parameters of type ActiveMQTopic | |
---|---|
TopicMessageStore |
TempKahaDBStore.createTopicMessageStore(ActiveMQTopic destination)
|
TopicMessageStore |
KahaDBPersistenceAdapter.createTopicMessageStore(ActiveMQTopic destination)
|
TopicMessageStore |
KahaDBStore.createTopicMessageStore(ActiveMQTopic destination)
|
TopicMessageStore |
MultiKahaDBPersistenceAdapter.createTopicMessageStore(ActiveMQTopic destination)
|
void |
TempKahaDBStore.removeTopicMessageStore(ActiveMQTopic destination)
Cleanup method to remove any state associated with the given destination This method does not stop the message store (it might not be cached). |
void |
KahaDBPersistenceAdapter.removeTopicMessageStore(ActiveMQTopic destination)
|
void |
KahaDBStore.removeTopicMessageStore(ActiveMQTopic destination)
Cleanup method to remove any state associated with the given destination This method does not stop the message store (it might not be cached). |
void |
MultiKahaDBPersistenceAdapter.removeTopicMessageStore(ActiveMQTopic destination)
|
Uses of ActiveMQTopic in org.apache.activemq.store.memory |
---|
Methods in org.apache.activemq.store.memory with parameters of type ActiveMQTopic | |
---|---|
TopicMessageStore |
MemoryPersistenceAdapter.createTopicMessageStore(ActiveMQTopic destination)
|
void |
MemoryPersistenceAdapter.removeTopicMessageStore(ActiveMQTopic destination)
Cleanup method to remove any state associated with the given destination |
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |