|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use ActiveMQMessage | |
---|---|
org.activemq | The core JMS client implementation classes |
org.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.activemq.broker.impl | The default implementation of the JMS Broker |
org.activemq.io.util | |
org.activemq.message | Message implementations |
org.activemq.security | Plugable Security Adapter framework along with default implementations such as the JAAS implementation. |
org.activemq.security.jassjacc | |
org.activemq.service | The core services which make up the JMS Message Broker such as the Store, MessageContainer and MessageContainerManager |
org.activemq.service.boundedvm | |
org.activemq.service.impl | Default implementations of the services |
org.activemq.store | The APIs which need to be implemented for persistent message stores for durable messaging |
org.activemq.store.cache | |
org.activemq.store.jdbc | Message persistence implemented using JDBC |
org.activemq.store.journal | Message persistence using a high performance transaction log via the Journal interface. |
org.activemq.store.vm | VM based implementation of message persistence |
org.activemq.transport.jabber | A transport using Jabber (XMPP) |
Uses of ActiveMQMessage in org.activemq |
---|
Methods in org.activemq that return ActiveMQMessage | |
---|---|
ActiveMQMessage |
ActiveMQConnectionConsumer.receive(long timeout)
Receives the next message that arrives within the specified timeout interval. |
Methods in org.activemq with parameters of type ActiveMQMessage | |
---|---|
void |
ActiveMQSession.acknowledge(ActiveMQMessage caller)
Acknowledges all consumed messages of the session of this consumed message. |
protected void |
ActiveMQConnection.addToTransientConsumedRedeliverCache(ActiveMQMessage message)
|
protected void |
ActiveMQSession.afterMessageDelivered(boolean sendAcknowledge,
ActiveMQMessage message,
boolean messageConsumed,
boolean messageExpired,
boolean beforeCalled)
|
protected void |
ActiveMQSession.beforeMessageDelivered(ActiveMQMessage message)
|
void |
ActiveMQSession.dispatch(ActiveMQMessage message)
Dispatch an ActiveMQMessage |
void |
ActiveMQMessageDispatcher.dispatch(ActiveMQMessage message)
Dispatch an ActiveMQMessage |
void |
ActiveMQConnectionConsumer.dispatch(ActiveMQMessage message)
Dispatch an ActiveMQMessage |
boolean |
ActiveMQSession.isTarget(ActiveMQMessage message)
Tests to see if the Message Dispatcher is a target for this message |
boolean |
ActiveMQMessageDispatcher.isTarget(ActiveMQMessage message)
Tests to see if the Message Dispatcher is a target for this message |
boolean |
ActiveMQConnectionConsumer.isTarget(ActiveMQMessage message)
Tests to see if the Message Dispatcher is a target for this message |
protected void |
ActiveMQMessageConsumer.processMessage(ActiveMQMessage message)
Process a Message - passing either to the queue or message listener |
Uses of ActiveMQMessage in org.activemq.broker |
---|
Methods in org.activemq.broker with parameters of type ActiveMQMessage | |
---|---|
void |
BrokerClient.dispatch(ActiveMQMessage message)
Dispatch an ActiveMQMessage to the end client |
void |
BrokerContainer.sendMessage(BrokerClient client,
ActiveMQMessage message)
Send a non-transacted message to the Broker |
void |
Broker.sendMessage(BrokerClient client,
ActiveMQMessage message)
send a message to the broker |
void |
BrokerConnector.sendMessage(BrokerClient client,
ActiveMQMessage message)
Send a non-transacted message to the Broker |
void |
Broker.sendToDeadLetterQueue(String deadLetterName,
ActiveMQMessage message)
Add a message to a dead letter queue |
Uses of ActiveMQMessage in org.activemq.broker.impl |
---|
Methods in org.activemq.broker.impl with parameters of type ActiveMQMessage | |
---|---|
void |
BrokerClientImpl.dispatch(ActiveMQMessage message)
Dispatch an ActiveMQMessage to the end client |
protected void |
DefaultBroker.doMessageSend(BrokerClient client,
ActiveMQMessage message)
|
void |
DefaultBroker.sendMessage(BrokerClient client,
ActiveMQMessage message)
send a message to the broker |
void |
BrokerContainerImpl.sendMessage(BrokerClient client,
ActiveMQMessage message)
Send a non-transacted message to the Broker |
void |
BrokerConnectorImpl.sendMessage(BrokerClient client,
ActiveMQMessage message)
Send a non-transacted message to the Broker |
void |
DefaultBroker.sendToDeadLetterQueue(String deadLetterName,
ActiveMQMessage expiredMessage)
Add a message to a dead letter queue |
Uses of ActiveMQMessage in org.activemq.io.util |
---|
Methods in org.activemq.io.util that return ActiveMQMessage | |
---|---|
ActiveMQMessage |
SpooledBoundedActiveMQMessageQueue.dequeue()
|
ActiveMQMessage |
SpooledBoundedActiveMQMessageQueue.dequeue(long timeInMillis)
|
ActiveMQMessage |
SpooledBoundedActiveMQMessageQueue.dequeueNoWait()
|
ActiveMQMessage |
MemoryBoundedMessageCache.get(String msgid)
Gets a message that was previously put into this object. |
Methods in org.activemq.io.util with parameters of type ActiveMQMessage | |
---|---|
void |
SpooledBoundedActiveMQMessageQueue.enqueue(ActiveMQMessage packet)
Place a ActiveMQMessage at the head of the Queue |
void |
SpooledBoundedActiveMQMessageQueue.enqueueNoBlock(ActiveMQMessage packet)
Enqueue a ActiveMQMessage without checking usage limits |
void |
MemoryBoundedMessageCache.put(String messageID,
ActiveMQMessage message)
Puts a message into the cache. |
Uses of ActiveMQMessage in org.activemq.message |
---|
Subclasses of ActiveMQMessage in org.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.activemq.message that return ActiveMQMessage | |
---|---|
ActiveMQMessage |
ActiveMQMessage.deepCopy()
|
ActiveMQMessage |
ActiveMQBytesMessage.deepCopy()
|
ActiveMQMessage |
ActiveMQMapMessage.deepCopy()
|
ActiveMQMessage |
ActiveMQObjectMessage.deepCopy()
|
ActiveMQMessage |
ActiveMQStreamMessage.deepCopy()
|
ActiveMQMessage |
ActiveMQTextMessage.deepCopy()
|
ActiveMQMessage |
ActiveMQMessage.shallowCopy()
|
ActiveMQMessage |
ActiveMQBytesMessage.shallowCopy()
|
ActiveMQMessage |
ActiveMQMapMessage.shallowCopy()
|
ActiveMQMessage |
ActiveMQObjectMessage.shallowCopy()
|
ActiveMQMessage |
ActiveMQStreamMessage.shallowCopy()
|
ActiveMQMessage |
ActiveMQTextMessage.shallowCopy()
|
Methods in org.activemq.message with parameters of type ActiveMQMessage | |
---|---|
void |
MessageAcknowledge.acknowledge(ActiveMQMessage caller)
Acknowledge receipt of this message |
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.activemq.security |
---|
Methods in org.activemq.security with parameters of type ActiveMQMessage | |
---|---|
boolean |
SecurityAdapter.authorizeReceive(BrokerClient client,
ActiveMQMessage message)
Returns true if the given client is authorized to receive the given message. |
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.activemq.security.jassjacc |
---|
Methods in org.activemq.security.jassjacc with parameters of type ActiveMQMessage | |
---|---|
boolean |
JassJaccSecurityAdapter.authorizeReceive(BrokerClient client,
ActiveMQMessage message)
|
void |
JassJaccSecurityAdapter.authorizeSendMessage(BrokerClient client,
ActiveMQMessage message)
|
Uses of ActiveMQMessage in org.activemq.service |
---|
Methods in org.activemq.service that return ActiveMQMessage | |
---|---|
protected ActiveMQMessage |
DeadLetterPolicy.createDeadLetterMessage(String dlqName,
ActiveMQMessage message)
|
ActiveMQMessage |
MessageContainer.getMessage(MessageIdentity messageIdentity)
Return the ActiveMQMessage that matches the Id |
ActiveMQMessage[] |
Subscription.getMessagesToDispatch()
Retrieve messages to dispatch |
ActiveMQMessage |
QueueMessageContainer.peekNext(MessageIdentity messageIdentity)
Used for browsing a MessageContainer this returns the next message in the container after the messageId |
ActiveMQMessage |
QueueMessageContainer.poll()
Some implementations may need to poll to fill subscriptions this returns the next message in the container |
Methods in org.activemq.service with parameters of type ActiveMQMessage | |
---|---|
void |
MessageContainer.addMessage(ActiveMQMessage msg)
Add an ActiveMQMessage to the message container |
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 |
protected ActiveMQMessage |
DeadLetterPolicy.createDeadLetterMessage(String dlqName,
ActiveMQMessage message)
|
boolean |
Subscription.isTarget(ActiveMQMessage message)
determines if the Subscription is interested in the message |
void |
MessageContainerManager.sendMessage(BrokerClient client,
ActiveMQMessage message)
|
void |
DeadLetterPolicy.sendToDeadLetter(ActiveMQMessage message)
Send a message to a dead letter queue |
void |
QueueMessageContainerManager.sendToDeadLetterQueue(String deadLetterName,
ActiveMQMessage message)
Add a message to a dead letter queue |
Uses of ActiveMQMessage in org.activemq.service.boundedvm |
---|
Methods in org.activemq.service.boundedvm that return ActiveMQMessage | |
---|---|
ActiveMQMessage |
TransientQueueSubscription.acknowledgeMessage(String id)
Acknowledge the receipt of a message by a consumer |
ActiveMQMessage |
DurableMessagePointer.getMessage()
|
ActiveMQMessage |
TransientQueueBoundedMessageContainer.getMessage(MessageIdentity messageIdentity)
|
ActiveMQMessage |
TransientTopicBoundedMessageContainer.getMessage(MessageIdentity messageIdentity)
|
Methods in org.activemq.service.boundedvm with parameters of type ActiveMQMessage | |
---|---|
void |
TransientQueueSubscription.addAckedMessage(ActiveMQMessage message)
Add an acked message. |
void |
TransientQueueBoundedMessageContainer.addMessage(ActiveMQMessage msg)
|
void |
TransientTopicBoundedMessageContainer.addMessage(ActiveMQMessage msg)
|
void |
TransientQueueSubscription.doDispatch(ActiveMQMessage message)
Dispatch a message to the Consumer |
void |
TransientQueueBoundedMessageContainer.enqueue(ActiveMQMessage message)
enqueue a message for dispatching |
void |
DurableQueueBoundedMessageContainer.enqueue(ActiveMQMessage message)
enqueue a message for dispatching |
boolean |
TransientQueueSubscription.isTarget(ActiveMQMessage message)
determines if the Subscription is interested in the message |
abstract boolean |
TransientSubscription.isTarget(ActiveMQMessage message)
determines if the Subscription is interested in the message |
boolean |
DurableQueueSubscription.isTarget(ActiveMQMessage message)
determines if the Subscription is interested in the message |
abstract boolean |
DurableSubscription.isTarget(ActiveMQMessage message)
determines if the Subscription is interested in the message |
boolean |
TransientTopicSubscription.isTarget(ActiveMQMessage message)
determines if the Subscription is interested in the message |
void |
TransientQueueBoundedMessageContainer.redeliver(ActiveMQMessage message)
re-enqueue a message for dispatching |
void |
TransientQueueBoundedMessageManager.sendMessage(BrokerClient client,
ActiveMQMessage message)
|
void |
DurableQueueBoundedMessageManager.sendMessage(BrokerClient client,
ActiveMQMessage message)
|
void |
TransientTopicBoundedMessageManager.sendMessage(BrokerClient client,
ActiveMQMessage message)
|
void |
DurableQueueBoundedMessageManager.sendToDeadLetterQueue(String deadLetterName,
ActiveMQMessage message)
|
boolean |
TransientTopicBoundedMessageContainer.targetAndDispatch(BrokerClient sender,
ActiveMQMessage message)
See if this container should get this message and dispatch it |
Constructors in org.activemq.service.boundedvm with parameters of type ActiveMQMessage | |
---|---|
DurableMessagePointer(MessageStore messageStore,
ActiveMQDestination destination,
ActiveMQMessage message)
|
Uses of ActiveMQMessage in org.activemq.service.impl |
---|
Methods in org.activemq.service.impl that return ActiveMQMessage | |
---|---|
ActiveMQMessage |
MessageEntry.getMessage()
|
ActiveMQMessage |
DurableQueueMessageContainer.getMessage(MessageIdentity messageID)
|
ActiveMQMessage |
DurableTopicMessageContainer.getMessage(MessageIdentity messageID)
|
ActiveMQMessage[] |
SubscriptionImpl.getMessagesToDispatch()
Retrieve messages to dispatch |
protected ActiveMQMessage[] |
SubscriptionImpl.getMessagesWithPrefetch()
|
ActiveMQMessage |
DurableQueueMessageContainer.peekNext(MessageIdentity messageID)
|
ActiveMQMessage |
DurableQueueMessageContainer.poll()
|
Methods in org.activemq.service.impl with parameters of type ActiveMQMessage | |
---|---|
void |
DurableQueueMessageContainer.addMessage(ActiveMQMessage message)
|
void |
DurableTopicMessageContainer.addMessage(ActiveMQMessage 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)
|
protected boolean |
SubscriptionImpl.isAuthorizedForMessage(ActiveMQMessage message)
Returns whether or not the consumer can receive the given message |
boolean |
SubscriptionImpl.isTarget(ActiveMQMessage message)
determines if the Subscription is interested in the message |
void |
DurableQueueMessageContainerManager.sendMessage(BrokerClient client,
ActiveMQMessage message)
|
void |
DurableTopicMessageContainerManager.sendMessage(BrokerClient client,
ActiveMQMessage message)
|
void |
InitialImageMessageContainerManager.sendMessage(BrokerClient client,
ActiveMQMessage message)
|
void |
ProxyMessageContainerManager.sendMessage(BrokerClient client,
ActiveMQMessage message)
|
void |
TransientTopicMessageContainerManager.sendMessage(BrokerClient client,
ActiveMQMessage message)
|
void |
DurableQueueMessageContainerManager.sendToDeadLetterQueue(String deadLetterName,
ActiveMQMessage message)
Add a message to a dead letter queue |
protected void |
MessageContainerManagerSupport.updateSendStats(BrokerClient client,
ActiveMQMessage message)
Updates the message sending stats |
Constructors in org.activemq.service.impl with parameters of type ActiveMQMessage | |
---|---|
MessageEntry(ActiveMQMessage msg)
|
Uses of ActiveMQMessage in org.activemq.store |
---|
Methods in org.activemq.store that return ActiveMQMessage | |
---|---|
ActiveMQMessage |
MessageStore.getMessage(MessageIdentity identity)
Looks up a message using either the String messageID or the messageNumber. |
ActiveMQMessage |
ProxyMessageStore.getMessage(MessageIdentity identity)
|
ActiveMQMessage |
ProxyTopicMessageStore.getMessage(MessageIdentity identity)
|
Methods in org.activemq.store with parameters of type ActiveMQMessage | |
---|---|
void |
MessageStore.addMessage(ActiveMQMessage message)
Adds a message to the message store |
void |
ProxyMessageStore.addMessage(ActiveMQMessage message)
|
void |
ProxyTopicMessageStore.addMessage(ActiveMQMessage message)
|
void |
TransactionStore.RecoveryListener.recover(ActiveMQXid xid,
ActiveMQMessage[] addedMessages,
MessageAck[] aks)
|
Uses of ActiveMQMessage in org.activemq.store.cache |
---|
Methods in org.activemq.store.cache that return ActiveMQMessage | |
---|---|
ActiveMQMessage |
MessageCache.get(String msgid)
Gets a message that was previously put into this object. |
ActiveMQMessage |
SimpleMessageCache.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.activemq.store.cache with parameters of type ActiveMQMessage | |
---|---|
void |
CacheMessageStore.addMessage(ActiveMQMessage message)
Add the meessage to the long term store and cache it. |
void |
MessageCache.put(String messageID,
ActiveMQMessage message)
Puts a message into the cache. |
void |
SimpleMessageCache.put(String messageID,
ActiveMQMessage message)
Puts a message into the cache. |
Uses of ActiveMQMessage in org.activemq.store.jdbc |
---|
Methods in org.activemq.store.jdbc that return ActiveMQMessage | |
---|---|
ActiveMQMessage |
JDBCMessageStore.getMessage(MessageIdentity identity)
|
Methods in org.activemq.store.jdbc with parameters of type ActiveMQMessage | |
---|---|
void |
JDBCMessageStore.addMessage(ActiveMQMessage message)
|
protected void |
JDBCPersistenceAdapter.sendToDeadLetter(ActiveMQMessage message)
|
Uses of ActiveMQMessage in org.activemq.store.journal |
---|
Methods in org.activemq.store.journal that return ActiveMQMessage | |
---|---|
ActiveMQMessage |
JournalTransactionStore.AddMessageCommand.getMessage()
|
ActiveMQMessage |
JournalMessageStore.getMessage(MessageIdentity identity)
|
ActiveMQMessage[] |
JournalTransactionStore.Tx.getMessages()
|
Methods in org.activemq.store.journal with parameters of type ActiveMQMessage | |
---|---|
void |
JournalTransactionStore.Tx.add(JournalMessageStore store,
ActiveMQMessage msg)
|
void |
JournalMessageStore.addMessage(ActiveMQMessage message)
Not synchronized since the Journal has better throughput if you increase the number of conncurrent writes that it is doing. |
void |
JournalMessageStore.replayAddMessage(ActiveMQMessage msg)
|
Uses of ActiveMQMessage in org.activemq.store.vm |
---|
Methods in org.activemq.store.vm that return ActiveMQMessage | |
---|---|
ActiveMQMessage |
VMTransactionStore.AddMessageCommand.getMessage()
|
ActiveMQMessage |
VMMessageStore.getMessage(MessageIdentity identity)
|
ActiveMQMessage[] |
VMTransactionStore.Tx.getMessages()
|
Methods in org.activemq.store.vm with parameters of type ActiveMQMessage | |
---|---|
void |
VMMessageStore.addMessage(ActiveMQMessage message)
|
Uses of ActiveMQMessage in org.activemq.transport.jabber |
---|
Methods in org.activemq.transport.jabber with parameters of type ActiveMQMessage | |
---|---|
protected String |
JabberWireFormat.getXmppType(ActiveMQMessage message)
|
protected void |
JabberWireFormat.writeMessage(ActiveMQMessage message,
String body,
DataOutput out)
|
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |