Overview | Package | Class | Use | Tree | Deprecated | Index | Help
PREV NEXT | FRAMES NO FRAMES

## Uses of Class
org.codehaus.activemq.message.ActiveMQMessage

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.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.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.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)`
`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
`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, boolean doRemove)`
`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
`protected void` | `ActiveMQMessageConsumer.processMessage(ActiveMQMessage message)` Process a Message - passing either to the queue or message listener
`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

Uses of ActiveMQMessage in org.codehaus.activemq.broker

Methods in org.codehaus.activemq.broker with parameters of type ActiveMQMessage
`void` | `BrokerContainer.sendTransactedMessage(BrokerClient client, java.lang.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
`void` | `BrokerConnector.sendTransactedMessage(BrokerClient client, java.lang.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` | `BrokerClient.dispatch(ActiveMQMessage message)` Dispatch an ActiveMQMessage to the end client
`void` | `Broker.sendMessage(BrokerClient client, ActiveMQMessage message)` send a message to the broker
`void` | `Broker.sendTransactedMessage(BrokerClient client, java.lang.String transactionId, ActiveMQMessage message)` send a message to the broker within a transaction

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, java.lang.String transactionId, ActiveMQMessage message)` send a message to the broker within a transaction
`void` | `BrokerContainerImpl.sendTransactedMessage(BrokerClient client, java.lang.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, java.lang.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` | `ActiveMQMessage.shallowCopy()`
`ActiveMQMessage` | `ActiveMQMessage.deepCopy()`
`ActiveMQMessage` | `ActiveMQMapMessage.shallowCopy()`
`ActiveMQMessage` | `ActiveMQMapMessage.deepCopy()`
`ActiveMQMessage` | `ActiveMQBytesMessage.shallowCopy()`
`ActiveMQMessage` | `ActiveMQBytesMessage.deepCopy()`

Methods in org.codehaus.activemq.message with parameters of type ActiveMQMessage
`protected void` | `ActiveMQMessageWriter.writeMessage(ActiveMQMessage msg, java.io.DataOutput dataOut)`
`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.service

Methods in org.codehaus.activemq.service that return ActiveMQMessage
`ActiveMQMessage[]` | `Subscription.getMessagesToDispatch()` Retrieve messages to dispatch
`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
`ActiveMQMessage` | `MessageContainer.getMessage(MessageIdentity messageIdentity)` Return the ActiveMQMessage that matches the Id

Methods in org.codehaus.activemq.service with parameters of type ActiveMQMessage
`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
`void` | `MessageContainerManager.sendMessage(BrokerClient client, ActiveMQMessage message)`
`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 with parameters of type ActiveMQMessage
`boolean` | `TransientTopicSubscription.isTarget(ActiveMQMessage message)` determines if the Subscription is interested in the message
`void` | `TransientTopicBoundedMessageManager.sendMessage(BrokerClient client, ActiveMQMessage message)`
`boolean` | `TransientTopicBoundedMessageContainer.targetAndDispatch(ActiveMQMessage message)` See if this container should get this message and dispatch it

Uses of ActiveMQMessage in org.codehaus.activemq.service.impl

Methods in org.codehaus.activemq.service.impl that return ActiveMQMessage
`ActiveMQMessage[]` | `SubscriptionImpl.getMessagesToDispatch()` Retrieve messages to dispatch
`protected ActiveMQMessage[]` | `SubscriptionImpl.getMessagesWithPrefetch()`
`ActiveMQMessage` | `MessageEntry.getMessage()`
`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` | `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` | `QueueMessageContainerManager.sendMessage(BrokerClient client, ActiveMQMessage message)`
`void` | `ProxyMessageContainerManager.sendMessage(BrokerClient client, ActiveMQMessage message)`
`void` | `InitialImageMessageContainerManager.sendMessage(BrokerClient client, ActiveMQMessage message)`
`void` | `DurableTopicMessageContainerManager.sendMessage(BrokerClient client, ActiveMQMessage message)`
`MessageIdentity` | `DurableTopicMessageContainer.addMessage(ActiveMQMessage message)`
`MessageIdentity` | `DurableQueueMessageContainer.addMessage(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)`

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.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(java.lang.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.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, java.lang.String body, java.io.DataOutput out)`
`protected java.lang.String` | `JabberWireFormat.getXmppType(ActiveMQMessage message)`

Overview | Package | Class | Use | Tree | Deprecated | Index | Help
PREV NEXT | FRAMES NO FRAMES

Copyright © 2004 Protique, Ltd.. All Rights Reserved.