|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use Message | |
---|---|
org.apache.activemq | The core JMS client API implementation classes. |
org.apache.activemq.broker | The core classes for the ActiveMQ Message Broker and its connectors. |
org.apache.activemq.broker.ft | Helper classes for implementing fault tolerance |
org.apache.activemq.broker.jmx | JMX MBeans for the broker and its core connectors. |
org.apache.activemq.broker.region | Region abstraction and implementations in the Broker. |
org.apache.activemq.broker.region.cursors | Cursors used to page persistent messages into the broker from the store |
org.apache.activemq.broker.region.policy | The policies which can be associated with a particular destination or wildcard. |
org.apache.activemq.broker.region.virtual | Implementation classes for Virtual Destinations |
org.apache.activemq.broker.util | Some utility Broker Plugins |
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.filter | Filter implementations for wildcards & JMS selectors |
org.apache.activemq.kaha | fast message persistence implementation |
org.apache.activemq.memory.list | |
org.apache.activemq.network | Support for federated networks of brokers. |
org.apache.activemq.plugin | |
org.apache.activemq.security | Plugable Security Adapter framework along with default implementations such as the JAAS implementation. |
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.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 |
org.apache.activemq.util | Some utility classes |
Uses of Message in org.apache.activemq |
---|
Methods in org.apache.activemq with parameters of type Message | |
---|---|
protected boolean |
ActiveMQConnection.isDuplicate(ActiveMQDispatcher dispatcher,
Message message)
|
protected void |
ActiveMQConnection.rollbackDuplicate(ActiveMQDispatcher dispatcher,
Message message)
|
Uses of Message in org.apache.activemq.broker |
---|
Methods in org.apache.activemq.broker with parameters of type Message | |
---|---|
Response |
TransportConnection.processMessage(Message messageSend)
|
void |
EmptyBroker.send(ProducerBrokerExchange producerExchange,
Message message)
|
void |
MutableBrokerFilter.send(ProducerBrokerExchange producerExchange,
Message messageSend)
|
void |
BrokerFilter.send(ProducerBrokerExchange producerExchange,
Message messageSend)
|
void |
TransactionBroker.send(ProducerBrokerExchange producerExchange,
Message message)
|
void |
BrokerBroadcaster.send(ProducerBrokerExchange producerExchange,
Message messageSend)
|
void |
ErrorBroker.send(ProducerBrokerExchange producerExchange,
Message message)
|
void |
CompositeDestinationBroker.send(ProducerBrokerExchange producerExchange,
Message message)
|
void |
UserIDBroker.send(ProducerBrokerExchange producerExchange,
Message messageSend)
|
Uses of Message in org.apache.activemq.broker.ft |
---|
Methods in org.apache.activemq.broker.ft with parameters of type Message | |
---|---|
void |
MasterBroker.send(ProducerBrokerExchange producerExchange,
Message message)
|
protected void |
MasterBroker.sendToSlave(Message message)
|
Uses of Message in org.apache.activemq.broker.jmx |
---|
Methods in org.apache.activemq.broker.jmx that return types with arguments of type Message | |
---|---|
protected List<Message> |
ManagedRegionBroker.getSubscriberMessages(SubscriptionView view)
|
Methods in org.apache.activemq.broker.jmx with parameters of type Message | |
---|---|
static CompositeData |
OpenTypeSupport.convert(Message message)
|
Method parameters in org.apache.activemq.broker.jmx with type arguments of type Message | |
---|---|
static org.apache.activemq.broker.jmx.OpenTypeSupport.OpenTypeFactory |
OpenTypeSupport.getFactory(Class<? extends Message> clazz)
|
Uses of Message in org.apache.activemq.broker.region |
---|
Methods in org.apache.activemq.broker.region that return Message | |
---|---|
Message[] |
Destination.browse()
|
Message[] |
Topic.browse()
|
Message[] |
DestinationFilter.browse()
|
Message[] |
Queue.browse()
|
Message |
MessageReference.getMessage()
|
Message |
IndirectMessageReference.getMessage()
|
Message |
Queue.getMessage(String id)
|
Message |
MessageReference.getMessageHardRef()
|
Message |
IndirectMessageReference.getMessageHardRef()
|
Message |
Topic.loadMessage(MessageId messageId)
|
Methods in org.apache.activemq.broker.region with parameters of type Message | |
---|---|
protected MessageDispatch |
PrefetchSubscription.createMessageDispatch(MessageReference node,
Message message)
|
protected MessageDispatch |
DurableTopicSubscription.createMessageDispatch(MessageReference node,
Message message)
|
protected void |
Topic.dispatch(ConnectionContext context,
Message message)
|
boolean |
Queue.moveMessageTo(ConnectionContext context,
Message m,
ActiveMQDestination dest)
Move a message |
protected void |
PrefetchSubscription.onDispatch(MessageReference node,
Message message)
|
protected void |
BaseDestination.onMessageWithNoConsumers(ConnectionContext context,
Message msg)
Provides a hook to allow messages with no consumer to be processed in some way - such as to send to a dead letter queue or something.. |
void |
Destination.send(ProducerBrokerExchange producerExchange,
Message messageSend)
|
void |
Region.send(ProducerBrokerExchange producerExchange,
Message message)
Send a message to the broker to using the specified destination. |
void |
Topic.send(ProducerBrokerExchange producerExchange,
Message message)
|
void |
AbstractRegion.send(ProducerBrokerExchange producerExchange,
Message messageSend)
|
void |
DestinationFilter.send(ProducerBrokerExchange context,
Message messageSend)
|
void |
RegionBroker.send(ProducerBrokerExchange producerExchange,
Message message)
|
void |
Queue.send(ProducerBrokerExchange producerExchange,
Message message)
|
protected void |
DestinationFilter.send(ProducerBrokerExchange context,
Message message,
ActiveMQDestination destination)
Sends a message to the given destination which may be a wildcard |
Method parameters in org.apache.activemq.broker.region with type arguments of type Message | |
---|---|
void |
Queue.doBrowse(List<Message> browseList,
int max)
|
Constructors in org.apache.activemq.broker.region with parameters of type Message | |
---|---|
IndirectMessageReference(Message message)
|
Uses of Message in org.apache.activemq.broker.region.cursors |
---|
Methods in org.apache.activemq.broker.region.cursors with parameters of type Message | |
---|---|
boolean |
AbstractStoreCursor.recoverMessage(Message message)
|
boolean |
AbstractStoreCursor.recoverMessage(Message message,
boolean cached)
|
Uses of Message in org.apache.activemq.broker.region.policy |
---|
Methods in org.apache.activemq.broker.region.policy that return Message | |
---|---|
Message[] |
SubscriptionRecoveryPolicy.browse(ActiveMQDestination dest)
|
Message[] |
FixedCountSubscriptionRecoveryPolicy.browse(ActiveMQDestination destination)
|
Message[] |
LastImageSubscriptionRecoveryPolicy.browse(ActiveMQDestination destination)
|
Message[] |
TimedSubscriptionRecoveryPolicy.browse(ActiveMQDestination destination)
|
Message[] |
FixedSizedSubscriptionRecoveryPolicy.browse(ActiveMQDestination destination)
|
Message[] |
NoSubscriptionRecoveryPolicy.browse(ActiveMQDestination dest)
|
Message[] |
QueryBasedSubscriptionRecoveryPolicy.browse(ActiveMQDestination dest)
|
Methods in org.apache.activemq.broker.region.policy with parameters of type Message | |
---|---|
boolean |
DeadLetterStrategy.isSendToDeadLetterQueue(Message message)
Allow pluggable strategy for deciding if message should be sent to a dead letter queue for example, you might not want to ignore expired or non-persistent messages |
boolean |
AbstractDeadLetterStrategy.isSendToDeadLetterQueue(Message message)
|
boolean |
MessageQuery.validateUpdate(Message message)
Returns true if the given update is valid and does not overlap with the initial message query. |
Uses of Message in org.apache.activemq.broker.region.virtual |
---|
Methods in org.apache.activemq.broker.region.virtual with parameters of type Message | |
---|---|
void |
VirtualTopicInterceptor.send(ProducerBrokerExchange context,
Message message)
|
void |
CompositeDestinationFilter.send(ProducerBrokerExchange context,
Message message)
|
Uses of Message in org.apache.activemq.broker.util |
---|
Methods in org.apache.activemq.broker.util with parameters of type Message | |
---|---|
void |
UDPTraceBrokerPlugin.send(ProducerBrokerExchange producerExchange,
Message messageSend)
|
void |
LoggingBrokerPlugin.send(ProducerBrokerExchange producerExchange,
Message messageSend)
|
void |
TimeStampingBrokerPlugin.send(ProducerBrokerExchange producerExchange,
Message message)
|
Uses of Message in org.apache.activemq.broker.view |
---|
Methods in org.apache.activemq.broker.view with parameters of type Message | |
---|---|
void |
ConnectionDotFileInterceptor.send(ProducerBrokerExchange producerExchange,
Message messageSend)
|
Uses of Message in org.apache.activemq.command |
---|
Subclasses of Message in org.apache.activemq.command | |
---|---|
class |
ActiveMQBlobMessage
An implementation of BlobMessage for out of band BLOB transfer |
class |
ActiveMQBytesMessage
A BytesMessage object is used to send a message containing a
stream of uninterpreted bytes. |
class |
ActiveMQMapMessage
A MapMessage object is used to send a set of name-value pairs. |
class |
ActiveMQMessage
|
class |
ActiveMQObjectMessage
An ObjectMessage object is used to send a message that
contains a serializable object in the Java programming language ("Java
object"). |
class |
ActiveMQStreamMessage
A StreamMessage object is used to send a stream of primitive
types in the Java programming language. |
class |
ActiveMQTextMessage
|
Fields in org.apache.activemq.command declared as Message | |
---|---|
protected Message |
MessageDispatch.message
|
Methods in org.apache.activemq.command that return Message | |
---|---|
abstract Message |
Message.copy()
|
Message |
ActiveMQMessage.copy()
|
Message |
ActiveMQBlobMessage.copy()
|
Message |
ActiveMQBytesMessage.copy()
|
Message |
ActiveMQMapMessage.copy()
|
Message |
ActiveMQTextMessage.copy()
|
Message |
ActiveMQObjectMessage.copy()
|
Message |
ActiveMQStreamMessage.copy()
|
Message |
MessageDispatch.getMessage()
|
Message |
Message.getMessage()
|
Message |
Message.getMessageHardRef()
|
Methods in org.apache.activemq.command with parameters of type Message | |
---|---|
protected void |
Message.copy(Message copy)
|
protected boolean |
NetworkBridgeFilter.matchesForwardingFilter(Message message)
|
void |
MessageDispatch.setMessage(Message message)
|
Uses of Message in org.apache.activemq.filter |
---|
Fields in org.apache.activemq.filter declared as Message | |
---|---|
protected Message |
MessageEvaluationContext.message
|
Methods in org.apache.activemq.filter that return Message | |
---|---|
Message |
MessageEvaluationContext.getMessage()
|
Message |
NonCachedMessageEvaluationContext.getMessage()
|
Methods in org.apache.activemq.filter with parameters of type Message | |
---|---|
boolean |
JAXPXPathEvaluator.evaluate(Message message)
|
boolean |
XMLBeansXPathEvaluator.evaluate(Message message)
|
Object |
PropertyExpression.evaluate(Message message)
|
boolean |
XalanXPathEvaluator.evaluate(Message m)
|
boolean |
XPathExpression.XPathEvaluator.evaluate(Message message)
|
static String[] |
DestinationPath.getDestinationPaths(Message message)
|
Uses of Message in org.apache.activemq.kaha |
---|
Methods in org.apache.activemq.kaha that return Message | |
---|---|
Message |
MessageMarshaller.readPayload(DataInput dataIn)
Read the entry from the RawContainer |
Methods in org.apache.activemq.kaha with parameters of type Message | |
---|---|
void |
MessageMarshaller.writePayload(Message message,
DataOutput dataOut)
Write the payload of this entry to the RawContainer |
Uses of Message in org.apache.activemq.memory.list |
---|
Methods in org.apache.activemq.memory.list that return Message | |
---|---|
Message[] |
DestinationBasedMessageList.browse(ActiveMQDestination destination)
|
Message[] |
MessageList.browse(ActiveMQDestination destination)
|
Message[] |
SimpleMessageList.browse(ActiveMQDestination destination)
|
Uses of Message in org.apache.activemq.network |
---|
Methods in org.apache.activemq.network that return Message | |
---|---|
protected Message |
DemandForwardingBridgeSupport.configureMessage(MessageDispatch md)
|
Uses of Message in org.apache.activemq.plugin |
---|
Methods in org.apache.activemq.plugin with parameters of type Message | |
---|---|
void |
ForcePersistencyModeBroker.send(ProducerBrokerExchange producerExchange,
Message messageSend)
Sets the persistence mode |
void |
StatisticsBroker.send(ProducerBrokerExchange producerExchange,
Message messageSend)
Sets the persistence mode |
Uses of Message in org.apache.activemq.security |
---|
Methods in org.apache.activemq.security with parameters of type Message | |
---|---|
boolean |
MessageAuthorizationPolicy.isAllowedToConsume(ConnectionContext context,
Message message)
Returns true if the given message is able to be dispatched to the connection performing any user |
void |
AuthorizationBroker.send(ProducerBrokerExchange producerExchange,
Message messageSend)
|
Uses of Message in org.apache.activemq.state |
---|
Methods in org.apache.activemq.state with parameters of type Message | |
---|---|
Response |
CommandVisitor.processMessage(Message send)
|
Response |
CommandVisitorAdapter.processMessage(Message send)
|
Response |
ConnectionStateTracker.processMessage(Message send)
|
Uses of Message in org.apache.activemq.store |
---|
Methods in org.apache.activemq.store that return Message | |
---|---|
Message |
MessageStore.getMessage(MessageId identity)
Looks up a message using either the String messageID or the messageNumber. |
Message |
ProxyMessageStore.getMessage(MessageId identity)
|
Message |
ProxyTopicMessageStore.getMessage(MessageId identity)
|
Methods in org.apache.activemq.store with parameters of type Message | |
---|---|
void |
MessageStore.addMessage(ConnectionContext context,
Message message)
Adds a message to the message store |
void |
ProxyMessageStore.addMessage(ConnectionContext context,
Message message)
|
void |
ProxyTopicMessageStore.addMessage(ConnectionContext context,
Message message)
|
void |
TransactionRecoveryListener.recover(XATransactionId xid,
Message[] addedMessages,
MessageAck[] aks)
|
boolean |
MessageRecoveryListener.recoverMessage(Message message)
|
Uses of Message in org.apache.activemq.store.amq |
---|
Methods in org.apache.activemq.store.amq that return Message | |
---|---|
Message |
AMQMessageStore.getMessage(MessageId identity)
|
Message[] |
AMQTx.getMessages()
|
Methods in org.apache.activemq.store.amq with parameters of type Message | |
---|---|
void |
AMQTx.add(AMQMessageStore store,
Message msg,
Location location)
|
void |
AMQMessageStore.addMessage(ConnectionContext context,
Message message)
Not synchronize since the Journal has better throughput if you increase the number of concurrent writes that it is doing. |
boolean |
AMQMessageStore.replayAddMessage(ConnectionContext context,
Message message,
Location location)
|
Uses of Message in org.apache.activemq.store.jdbc |
---|
Methods in org.apache.activemq.store.jdbc that return Message | |
---|---|
Message |
JDBCMessageStore.getMessage(MessageId messageId)
|
Methods in org.apache.activemq.store.jdbc with parameters of type Message | |
---|---|
void |
JDBCMessageStore.addMessage(ConnectionContext context,
Message message)
|
Uses of Message in org.apache.activemq.store.journal |
---|
Methods in org.apache.activemq.store.journal that return Message | |
---|---|
Message |
JournalMessageStore.getMessage(MessageId identity)
|
Message[] |
JournalTransactionStore.Tx.getMessages()
|
Methods in org.apache.activemq.store.journal with parameters of type Message | |
---|---|
void |
JournalTransactionStore.Tx.add(JournalMessageStore store,
Message msg)
|
void |
JournalMessageStore.addMessage(ConnectionContext context,
Message message)
Not synchronized since the Journal has better throughput if you increase the number of concurrent writes that it is doing. |
void |
JournalTopicMessageStore.addMessage(ConnectionContext context,
Message message)
|
void |
JournalMessageStore.replayAddMessage(ConnectionContext context,
Message message)
|
Uses of Message in org.apache.activemq.store.kahadaptor |
---|
Fields in org.apache.activemq.store.kahadaptor with type parameters of type Message | |
---|---|
protected MapContainer<MessageId,Message> |
KahaMessageStore.messageContainer
|
Methods in org.apache.activemq.store.kahadaptor that return Message | |
---|---|
Message |
KahaReferenceStore.getMessage(MessageId identity)
|
Message |
KahaMessageStore.getMessage(MessageId identity)
|
Message |
KahaTopicReferenceStore.getMessage(MessageId identity)
|
Methods in org.apache.activemq.store.kahadaptor that return types with arguments of type Message | |
---|---|
protected MapContainer<MessageId,Message> |
KahaPersistenceAdapter.getMapContainer(Object id,
String containerName)
|
Methods in org.apache.activemq.store.kahadaptor with parameters of type Message | |
---|---|
void |
KahaReferenceStore.addMessage(ConnectionContext context,
Message message)
|
void |
KahaMessageStore.addMessage(ConnectionContext context,
Message message)
|
void |
KahaTopicMessageStore.addMessage(ConnectionContext context,
Message message)
|
void |
KahaTopicReferenceStore.addMessage(ConnectionContext context,
Message message)
|
protected boolean |
KahaMessageStore.recoverMessage(MessageRecoveryListener listener,
Message msg)
|
Constructor parameters in org.apache.activemq.store.kahadaptor with type arguments of type Message | |
---|---|
KahaMessageStore(MapContainer<MessageId,Message> container,
ActiveMQDestination destination)
|
|
KahaTopicMessageStore(Store store,
MapContainer<MessageId,Message> messageContainer,
ListContainer<TopicSubAck> ackContainer,
MapContainer<String,SubscriptionInfo> subsContainer,
ActiveMQDestination destination)
|
Uses of Message in org.apache.activemq.store.kahadb |
---|
Methods in org.apache.activemq.store.kahadb that return Message | |
---|---|
Message |
KahaDBStore.KahaDBMessageStore.getMessage(MessageId identity)
|
Message |
TempKahaDBStore.KahaDBMessageStore.getMessage(MessageId identity)
|
Methods in org.apache.activemq.store.kahadb with parameters of type Message | |
---|---|
void |
KahaDBStore.KahaDBMessageStore.addMessage(ConnectionContext context,
Message message)
|
void |
TempKahaDBStore.KahaDBMessageStore.addMessage(ConnectionContext context,
Message message)
|
Uses of Message in org.apache.activemq.store.memory |
---|
Fields in org.apache.activemq.store.memory with type parameters of type Message | |
---|---|
protected Map<MessageId,Message> |
MemoryMessageStore.messageTable
|
Methods in org.apache.activemq.store.memory that return Message | |
---|---|
Message |
MemoryTransactionStore.AddMessageCommand.getMessage()
|
Message |
MemoryMessageStore.getMessage(MessageId identity)
|
Message[] |
MemoryTransactionStore.Tx.getMessages()
|
Methods in org.apache.activemq.store.memory with parameters of type Message | |
---|---|
void |
MemoryMessageStore.addMessage(ConnectionContext context,
Message message)
|
void |
MemoryTopicMessageStore.addMessage(ConnectionContext context,
Message message)
|
Constructor parameters in org.apache.activemq.store.memory with type arguments of type Message | |
---|---|
MemoryMessageStore(ActiveMQDestination destination,
Map<MessageId,Message> messageTable)
|
|
MemoryTopicMessageStore(ActiveMQDestination destination,
Map<MessageId,Message> messageTable,
Map<SubscriptionKey,SubscriptionInfo> subscriberDatabase)
|
Uses of Message in org.apache.activemq.util |
---|
Methods in org.apache.activemq.util with parameters of type Message | |
---|---|
static void |
BrokerSupport.doResend(ConnectionContext context,
Message originalMessage,
ActiveMQDestination deadLetterDestination,
boolean copy)
|
static void |
BrokerSupport.resend(ConnectionContext context,
Message originalMessage,
ActiveMQDestination deadLetterDestination)
|
static void |
BrokerSupport.resendNoCopy(ConnectionContext context,
Message originalMessage,
ActiveMQDestination deadLetterDestination)
|
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |