|
|||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use ActiveMQMessage | |
org.codehaus.activemq | The core JMS client implementation classes |
org.codehaus.activemq.broker | The API for the JMS Broker which is the server side of a JMS network though it may be deployed inside a client in peer style networks. |
org.codehaus.activemq.broker.impl | The default implementation of the JMS Broker |
org.codehaus.activemq.message | Message implementations |
org.codehaus.activemq.ra | JCA managed connections and resource adapters for working with ActiveMQ |
org.codehaus.activemq.security | Plugable Security Adapter framework along with default implementations such as the JAAS implementation. |
org.codehaus.activemq.service | The core services which make up the JMS Message Broker such as the Store, MessageContainer and MessageContainerManager |
org.codehaus.activemq.service.boundedvm | |
org.codehaus.activemq.service.impl | Default implementations of the services |
org.codehaus.activemq.store | The APIs which need to be implemented for persistent message stores for durable messaging |
org.codehaus.activemq.store.bdb | Message persistence implemented using Berkeley DB Java Edition |
org.codehaus.activemq.store.bdbn | Message persistence implemented using Berkeley DB, native C version |
org.codehaus.activemq.store.cache | |
org.codehaus.activemq.store.howl | Message persistence using a high performance transaction log via implemented using Howl whichi is used for short term persistence with longer term storage being used at checkpoints. |
org.codehaus.activemq.store.jdbc | Message persistence implemented using JDBC |
org.codehaus.activemq.store.jdbm | Message persistence implemented using JDBM which is the default persistence mechanism shipped with Geronimo (due to its BSD licence) |
org.codehaus.activemq.store.journal | Message persistence using a high performance transaction log via the Journal interface. |
org.codehaus.activemq.store.vm | VM based implementation of message persistence |
org.codehaus.activemq.transport.jabber |
Uses of ActiveMQMessage in org.codehaus.activemq |
Methods in org.codehaus.activemq that return ActiveMQMessage | |
static ActiveMQMessage |
ActiveMQMessageTransformation.transformMessage(Message message)
Creates a fast shallow copy of the current ActiveMQMessage or creates a whole new message instance from an available JMS message from another provider. |
(package private) ActiveMQMessage |
ActiveMQSessionExecutor.dequeueNoWait()
|
ActiveMQMessage |
ActiveMQConnectionConsumer.receive(long timeout)
Receives the next message that arrives within the specified timeout interval. |
Methods in org.codehaus.activemq with parameters of type ActiveMQMessage | |
protected void |
ActiveMQMessageConsumer.processMessage(ActiveMQMessage message)
Process a Message - passing either to the queue or message listener |
(package private) void |
ActiveMQSessionExecutor.execute(ActiveMQMessage message)
|
(package private) void |
ActiveMQSessionExecutor.executeFirst(ActiveMQMessage message)
|
boolean |
ActiveMQConnectionConsumer.isTarget(ActiveMQMessage message)
Tests to see if the Message Dispatcher is a target for this message |
void |
ActiveMQConnectionConsumer.dispatch(ActiveMQMessage message)
Dispatch an ActiveMQMessage |
boolean |
ActiveMQMessageDispatcher.isTarget(ActiveMQMessage message)
Tests to see if the Message Dispatcher is a target for this message |
void |
ActiveMQMessageDispatcher.dispatch(ActiveMQMessage message)
Dispatch an ActiveMQMessage |
boolean |
ActiveMQSession.isTarget(ActiveMQMessage message)
Tests to see if the Message Dispatcher is a target for this message |
void |
ActiveMQSession.dispatch(ActiveMQMessage message)
Dispatch an ActiveMQMessage |
protected void |
ActiveMQSession.messageDelivered(boolean sendAcknowledge,
ActiveMQMessage message,
boolean messageConsumed)
|
Uses of ActiveMQMessage in org.codehaus.activemq.broker |
Methods in org.codehaus.activemq.broker with parameters of type ActiveMQMessage | |
void |
Broker.sendMessage(BrokerClient client,
ActiveMQMessage message)
send a message to the broker |
void |
Broker.sendTransactedMessage(BrokerClient client,
String transactionId,
ActiveMQMessage message)
send a message to the broker within a transaction |
void |
BrokerClient.dispatch(ActiveMQMessage message)
Dispatch an ActiveMQMessage to the end client |
void |
BrokerConnector.sendTransactedMessage(BrokerClient client,
String transactionId,
ActiveMQMessage message)
send message with a transaction context |
void |
BrokerConnector.sendMessage(BrokerClient client,
ActiveMQMessage message)
Send a non-transacted message to the Broker |
void |
BrokerContainer.sendTransactedMessage(BrokerClient client,
String transactionId,
ActiveMQMessage message)
send message with a transaction context |
void |
BrokerContainer.sendMessage(BrokerClient client,
ActiveMQMessage message)
Send a non-transacted message to the Broker |
Uses of ActiveMQMessage in org.codehaus.activemq.broker.impl |
Methods in org.codehaus.activemq.broker.impl with parameters of type ActiveMQMessage | |
void |
DefaultBroker.sendMessage(BrokerClient client,
ActiveMQMessage message)
send a message to the broker |
void |
DefaultBroker.sendTransactedMessage(BrokerClient client,
String transactionId,
ActiveMQMessage message)
send a message to the broker within a transaction |
protected void |
DefaultBroker.doMessageSend(BrokerClient client,
ActiveMQMessage message)
|
void |
BrokerContainerImpl.sendTransactedMessage(BrokerClient client,
String transactionId,
ActiveMQMessage message)
send message with a transaction context |
void |
BrokerContainerImpl.sendMessage(BrokerClient client,
ActiveMQMessage message)
Send a non-transacted message to the Broker |
void |
BrokerConnectorImpl.sendTransactedMessage(BrokerClient client,
String transactionId,
ActiveMQMessage message)
send message with a transaction context |
void |
BrokerConnectorImpl.sendMessage(BrokerClient client,
ActiveMQMessage message)
Send a non-transacted message to the Broker |
void |
BrokerClientImpl.dispatch(ActiveMQMessage message)
Dispatch an ActiveMQMessage to the end client |
Uses of ActiveMQMessage in org.codehaus.activemq.message |
Subclasses of ActiveMQMessage in org.codehaus.activemq.message | |
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 |
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
A TextMessage object is used to send a message containing a
java.lang.String . |
Methods in org.codehaus.activemq.message that return ActiveMQMessage | |
ActiveMQMessage |
ActiveMQTextMessage.shallowCopy()
|
ActiveMQMessage |
ActiveMQTextMessage.deepCopy()
|
ActiveMQMessage |
ActiveMQStreamMessage.shallowCopy()
|
ActiveMQMessage |
ActiveMQStreamMessage.deepCopy()
|
ActiveMQMessage |
ActiveMQObjectMessage.shallowCopy()
|
ActiveMQMessage |
ActiveMQObjectMessage.deepCopy()
|
ActiveMQMessage |
ActiveMQMapMessage.shallowCopy()
|
ActiveMQMessage |
ActiveMQMapMessage.deepCopy()
|
ActiveMQMessage |
ActiveMQBytesMessage.shallowCopy()
|
ActiveMQMessage |
ActiveMQBytesMessage.deepCopy()
|
ActiveMQMessage |
ActiveMQMessage.shallowCopy()
|
ActiveMQMessage |
ActiveMQMessage.deepCopy()
|
Methods in org.codehaus.activemq.message with parameters of type ActiveMQMessage | |
int |
ActiveMQMessage.compareTo(ActiveMQMessage that)
Sorted by destination and then messageId |
protected void |
ActiveMQMessage.initializeOther(ActiveMQMessage other)
Initializes another message with current values from this instance |
Uses of ActiveMQMessage in org.codehaus.activemq.ra |
Fields in org.codehaus.activemq.ra declared as ActiveMQMessage | |
(package private) ActiveMQMessage |
ActiveMQPollingEndpointWorker.InboundEndpointWork.message
|
Uses of ActiveMQMessage in org.codehaus.activemq.security |
Methods in org.codehaus.activemq.security with parameters of type ActiveMQMessage | |
void |
SecurityAdapter.authorizeSendMessage(BrokerClient client,
ActiveMQMessage message)
Authorizes on a per message basis whether or not the client is allowed to send the given message. |
Uses of ActiveMQMessage in org.codehaus.activemq.service |
Methods in org.codehaus.activemq.service that return ActiveMQMessage | |
ActiveMQMessage[] |
Subscription.getMessagesToDispatch()
Retrieve messages to dispatch |
ActiveMQMessage |
MessageContainer.getMessage(MessageIdentity messageIdentity)
Return the ActiveMQMessage that matches the Id |
ActiveMQMessage |
QueueMessageContainer.poll()
Some implementations may need to poll to fill subscriptions this returns the next message in the container |
ActiveMQMessage |
QueueMessageContainer.peekNext(MessageIdentity messageIdentity)
Used for browsing a MessageContainer this returns the next message in the container after the messageId |
Methods in org.codehaus.activemq.service with parameters of type ActiveMQMessage | |
void |
MessageContainerManager.sendMessage(BrokerClient client,
ActiveMQMessage message)
|
boolean |
Subscription.isTarget(ActiveMQMessage message)
determines if the Subscription is interested in the message |
void |
Subscription.addMessage(MessageContainer container,
ActiveMQMessage message)
If the Subscription is a target for the message, the subscription will add a reference to the message and register an interest in the message to the container |
MessageIdentity |
MessageContainer.addMessage(ActiveMQMessage msg)
Add an ActiveMQMessage to the message container |
Uses of ActiveMQMessage in org.codehaus.activemq.service.boundedvm |
Methods in org.codehaus.activemq.service.boundedvm that return ActiveMQMessage | |
ActiveMQMessage |
TransientTopicBoundedMessageContainer.getMessage(MessageIdentity messageIdentity)
|
ActiveMQMessage |
TransientQueueSubscription.acknowledgeMessage(String id)
Acknowledge the receipt of a message by a consumer |
ActiveMQMessage |
TransientQueueBoundedMessageContainer.getMessage(MessageIdentity messageIdentity)
|
Methods in org.codehaus.activemq.service.boundedvm with parameters of type ActiveMQMessage | |
void |
TransientTopicBoundedMessageManager.sendMessage(BrokerClient client,
ActiveMQMessage message)
|
boolean |
TransientTopicSubscription.isTarget(ActiveMQMessage message)
determines if the Subscription is interested in the message |
boolean |
TransientTopicBoundedMessageContainer.targetAndDispatch(BrokerClient sender,
ActiveMQMessage message)
See if this container should get this message and dispatch it |
MessageIdentity |
TransientTopicBoundedMessageContainer.addMessage(ActiveMQMessage msg)
|
void |
TransientQueueBoundedMessageManager.sendMessage(BrokerClient client,
ActiveMQMessage message)
|
abstract boolean |
TransientSubscription.isTarget(ActiveMQMessage message)
determines if the Subscription is interested in the message |
boolean |
TransientQueueSubscription.isTarget(ActiveMQMessage message)
determines if the Subscription is interested in the message |
void |
TransientQueueSubscription.doDispatch(ActiveMQMessage message)
Dispatch a message to the Consumer |
void |
TransientQueueBoundedMessageContainer.enqueue(ActiveMQMessage message)
enqueue a message for dispatching |
void |
TransientQueueBoundedMessageContainer.enqueueFirst(ActiveMQMessage message)
enqueue a message for dispatching |
MessageIdentity |
TransientQueueBoundedMessageContainer.addMessage(ActiveMQMessage msg)
|
Uses of ActiveMQMessage in org.codehaus.activemq.service.impl |
Methods in org.codehaus.activemq.service.impl that return ActiveMQMessage | |
ActiveMQMessage |
MessageEntry.getMessage()
|
ActiveMQMessage[] |
SubscriptionImpl.getMessagesToDispatch()
Retrieve messages to dispatch |
protected ActiveMQMessage[] |
SubscriptionImpl.getMessagesWithPrefetch()
|
ActiveMQMessage |
DurableTopicMessageContainer.getMessage(MessageIdentity messageID)
|
ActiveMQMessage |
DurableQueueMessageContainer.getMessage(MessageIdentity messageID)
|
ActiveMQMessage |
DurableQueueMessageContainer.poll()
|
ActiveMQMessage |
DurableQueueMessageContainer.peekNext(MessageIdentity messageID)
|
Methods in org.codehaus.activemq.service.impl with parameters of type ActiveMQMessage | |
void |
DurableQueueMessageContainerManager.sendMessage(BrokerClient client,
ActiveMQMessage message)
|
void |
TransientTopicMessageContainerManager.sendMessage(BrokerClient client,
ActiveMQMessage message)
|
boolean |
SubscriptionImpl.isTarget(ActiveMQMessage message)
determines if the Subscription is interested in the message |
void |
SubscriptionImpl.addMessage(MessageContainer container,
ActiveMQMessage message)
If the Subscription is a target for the message, the subscription will add a reference to the message and register an interest in the message to the container |
protected boolean |
SubscriptionImpl.clientIDsEqual(ActiveMQMessage message)
|
void |
ProxyMessageContainerManager.sendMessage(BrokerClient client,
ActiveMQMessage message)
|
void |
InitialImageMessageContainerManager.sendMessage(BrokerClient client,
ActiveMQMessage message)
|
MessageIdentity |
DurableTopicMessageContainer.addMessage(ActiveMQMessage message)
|
MessageIdentity |
DurableQueueMessageContainer.addMessage(ActiveMQMessage message)
|
protected void |
MessageContainerManagerSupport.updateSendStats(BrokerClient client,
ActiveMQMessage message)
Updates the message sending stats |
void |
DurableTopicMessageContainerManager.sendMessage(BrokerClient client,
ActiveMQMessage message)
|
Constructors in org.codehaus.activemq.service.impl with parameters of type ActiveMQMessage | |
SendMessageTransactionTask(BrokerClient brokerClient,
ActiveMQMessage message)
|
|
MessageEntry(ActiveMQMessage msg)
|
Uses of ActiveMQMessage in org.codehaus.activemq.store |
Methods in org.codehaus.activemq.store that return ActiveMQMessage | |
ActiveMQMessage |
MessageStore.getMessage(MessageIdentity identity)
Looks up a message using either the String messageID or the messageNumber. |
Methods in org.codehaus.activemq.store with parameters of type ActiveMQMessage | |
MessageIdentity |
MessageStore.addMessage(ActiveMQMessage message)
Adds a message to the message store |
Uses of ActiveMQMessage in org.codehaus.activemq.store.bdb |
Methods in org.codehaus.activemq.store.bdb that return ActiveMQMessage | |
ActiveMQMessage |
BDbMessageStore.getMessage(MessageIdentity identity)
|
protected ActiveMQMessage |
BDbMessageStore.extractMessage(com.sleepycat.je.DatabaseEntry value)
|
Methods in org.codehaus.activemq.store.bdb with parameters of type ActiveMQMessage | |
MessageIdentity |
BDbMessageStore.addMessage(ActiveMQMessage message)
|
protected byte[] |
BDbMessageStore.asBytes(ActiveMQMessage message)
|
Uses of ActiveMQMessage in org.codehaus.activemq.store.bdbn |
Methods in org.codehaus.activemq.store.bdbn that return ActiveMQMessage | |
ActiveMQMessage |
BDbMessageStore.getMessage(MessageIdentity identity)
|
protected ActiveMQMessage |
BDbMessageStore.extractMessage(com.sleepycat.db.Dbt value)
|
Methods in org.codehaus.activemq.store.bdbn with parameters of type ActiveMQMessage | |
MessageIdentity |
BDbMessageStore.addMessage(ActiveMQMessage message)
|
protected byte[] |
BDbMessageStore.asBytes(ActiveMQMessage message)
|
Uses of ActiveMQMessage in org.codehaus.activemq.store.cache |
Methods in org.codehaus.activemq.store.cache that return ActiveMQMessage | |
ActiveMQMessage |
SimpleMessageCache.get(String msgid)
Gets a message that was previously put into this object. |
ActiveMQMessage |
MessageCache.get(String msgid)
Gets a message that was previously put into this object. |
ActiveMQMessage |
CacheMessageStore.getMessage(MessageIdentity identity)
Return the message from the cache or go to the longTermStore if it is not in there. |
Methods in org.codehaus.activemq.store.cache with parameters of type ActiveMQMessage | |
void |
SimpleMessageCache.put(String messageID,
ActiveMQMessage message)
Puts a message into the cache. |
void |
MessageCache.put(String messageID,
ActiveMQMessage message)
Puts a message into the cache. |
MessageIdentity |
CacheMessageStore.addMessage(ActiveMQMessage message)
Add the meessage to the long term store and cache it. |
Uses of ActiveMQMessage in org.codehaus.activemq.store.howl |
Methods in org.codehaus.activemq.store.howl that return ActiveMQMessage | |
ActiveMQMessage |
HowlMessageStore.getMessage(MessageIdentity identity)
Lets ensure that readers don't block writers so there only synchronization on the cache and checkpointStore. |
Methods in org.codehaus.activemq.store.howl with parameters of type ActiveMQMessage | |
MessageIdentity |
HowlMessageStore.addMessage(ActiveMQMessage message)
This method is synchronized to ensure that only 1 thread can write to the log and cache and possibly checkpoint at once, to preserve order across the transaction log, cache and checkpointStore. |
protected void |
HowlMessageStore.checkpoint(ActiveMQMessage message)
Writes the current RAM image of the transaction log to stable, checkpoint store |
protected boolean |
HowlMessageStore.addMessageToCache(ActiveMQMessage message)
Adds the given message to the cache if there is spare capacity |
Uses of ActiveMQMessage in org.codehaus.activemq.store.jdbc |
Methods in org.codehaus.activemq.store.jdbc that return ActiveMQMessage | |
ActiveMQMessage |
JDBCMessageStore.getMessage(MessageIdentity identity)
|
Methods in org.codehaus.activemq.store.jdbc with parameters of type ActiveMQMessage | |
MessageIdentity |
JDBCMessageStore.addMessage(ActiveMQMessage message)
|
Uses of ActiveMQMessage in org.codehaus.activemq.store.jdbm |
Methods in org.codehaus.activemq.store.jdbm that return ActiveMQMessage | |
ActiveMQMessage |
JdbmMessageStore.getMessage(MessageIdentity identity)
|
protected ActiveMQMessage |
JdbmMessageStore.getMessageBySequenceNumber(Long sequenceNumber)
Looks up the message using the given sequence number |
Methods in org.codehaus.activemq.store.jdbm with parameters of type ActiveMQMessage | |
MessageIdentity |
JdbmMessageStore.addMessage(ActiveMQMessage message)
|
Uses of ActiveMQMessage in org.codehaus.activemq.store.journal |
Methods in org.codehaus.activemq.store.journal that return ActiveMQMessage | |
ActiveMQMessage |
JournalMessageStore.getMessage(MessageIdentity identity)
|
Methods in org.codehaus.activemq.store.journal with parameters of type ActiveMQMessage | |
MessageIdentity |
JournalMessageStore.addMessage(ActiveMQMessage message)
Not synchronized since the Journal has better throughput if you increase the number of conncurrent writes that it is doing. |
Uses of ActiveMQMessage in org.codehaus.activemq.store.vm |
Methods in org.codehaus.activemq.store.vm that return ActiveMQMessage | |
ActiveMQMessage |
VMMessageStore.getMessage(MessageIdentity identity)
|
Methods in org.codehaus.activemq.store.vm with parameters of type ActiveMQMessage | |
MessageIdentity |
VMMessageStore.addMessage(ActiveMQMessage message)
|
Uses of ActiveMQMessage in org.codehaus.activemq.transport.jabber |
Methods in org.codehaus.activemq.transport.jabber with parameters of type ActiveMQMessage | |
protected void |
JabberWireFormat.writeMessage(ActiveMQMessage message,
String body,
DataOutput out)
|
protected String |
JabberWireFormat.getXmppType(ActiveMQMessage message)
|
|
|||||||||||
PREV NEXT | FRAMES NO FRAMES |