|
|||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use MessageContainer | |
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.cache | |
org.codehaus.activemq.store.vm | VM based implementation of message persistence |
Uses of MessageContainer in org.codehaus.activemq.service |
Subinterfaces of MessageContainer in org.codehaus.activemq.service | |
interface |
QueueMessageContainer
A Queue based MessageContainer |
interface |
TopicMessageContainer
A Topic based MessageContainer |
Methods in org.codehaus.activemq.service that return MessageContainer | |
MessageContainer |
MessageContainerManager.getContainer(String physicalName)
Allows the lookup of a specific named message container |
Methods in org.codehaus.activemq.service with parameters of type MessageContainer | |
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 |
Subscription.redeliverMessage(MessageContainer container,
MessageAck ack)
Forces the given message to be redelivered |
Uses of MessageContainer in org.codehaus.activemq.service.boundedvm |
Classes in org.codehaus.activemq.service.boundedvm that implement MessageContainer | |
class |
TransientQueueBoundedMessageContainer
A MessageContainer for transient queues |
class |
TransientTopicBoundedMessageContainer
A MessageContainer for transient topics One of these exists for every active Connection consuming transient Topic messages |
Methods in org.codehaus.activemq.service.boundedvm that return MessageContainer | |
MessageContainer |
TransientTopicBoundedMessageManager.getContainer(String physicalName)
For Transient topics - a MessageContainer maps on to the messages to be dispatched through a BrokerClient, not a destination |
MessageContainer |
TransientQueueBoundedMessageManager.getContainer(String physicalName)
|
Uses of MessageContainer in org.codehaus.activemq.service.impl |
Classes in org.codehaus.activemq.service.impl that implement MessageContainer | |
class |
DurableQueueMessageContainer
A default implemenation of a Durable Queue based MessageContainer
which acts as an adapter between the MessageContainerManager
requirements and those of the persistent MessageStore implementations. |
class |
DurableTopicMessageContainer
A default implemenation of a Durable Topic based MessageContainer
which acts as an adapter between the MessageContainerManager
requirements and those of the persistent TopicMessageStore implementations. |
Methods in org.codehaus.activemq.service.impl that return MessageContainer | |
protected MessageContainer |
DurableTopicMessageContainerManager.createContainer(String destinationName)
|
MessageContainer |
ProxyMessageContainerManager.getContainer(String physicalName)
|
MessageContainer |
DurableQueueMessageContainerManager.getContainer(String destinationName)
|
protected MessageContainer |
DurableQueueMessageContainerManager.createContainer(String destinationName)
|
MessageContainer |
MessageContainerManagerSupport.getContainer(String destinationName)
|
protected abstract MessageContainer |
MessageContainerManagerSupport.createContainer(String destinationName)
Factory method to create a new MessageContainer |
Methods in org.codehaus.activemq.service.impl with parameters of type MessageContainer | |
void |
DurableTopicSubscription.redeliverMessage(MessageContainer container,
MessageAck ack)
|
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 |
void |
SubscriptionImpl.redeliverMessage(MessageContainer container,
MessageAck ack)
|
Uses of MessageContainer in org.codehaus.activemq.store |
Methods in org.codehaus.activemq.store with parameters of type MessageContainer | |
void |
TopicMessageStore.setMessageContainer(MessageContainer container)
Called before the service is started so that the store can communicate with the container when recovering |
Uses of MessageContainer in org.codehaus.activemq.store.cache |
Methods in org.codehaus.activemq.store.cache with parameters of type MessageContainer | |
void |
CacheTopicMessageStore.setMessageContainer(MessageContainer container)
|
Uses of MessageContainer in org.codehaus.activemq.store.vm |
Methods in org.codehaus.activemq.store.vm with parameters of type MessageContainer | |
void |
VMTopicMessageStore.setMessageContainer(MessageContainer container)
|
|
|||||||||||
PREV NEXT | FRAMES NO FRAMES |