|
|||||||||||
PREV NEXT | FRAMES NO FRAMES |
Uses of MessageStore in org.jboss.jms.server |
Fields in org.jboss.jms.server declared as MessageStore | |
protected MessageStore |
ServerPeer.messageStoreDelegate
|
Methods in org.jboss.jms.server that return MessageStore | |
MessageStore |
ServerPeer.getMessageStoreDelegate()
|
Uses of MessageStore in org.jboss.jms.server.plugin |
Methods in org.jboss.jms.server.plugin with parameters of type MessageStore | |
void |
JDBCChannelMapper.deployCoreDestination(boolean isQueue,
java.lang.String destName,
MessageStore ms,
PersistenceManager pm,
MemoryManager mm,
int fullSize,
int pageSize,
int downCacheSize)
|
void |
JDBCChannelMapper.deployTemporaryCoreDestination(boolean isQueue,
java.lang.String destName,
long id,
MessageStore ms,
PersistenceManager pm,
MemoryManager mm,
int fullSize,
int pageSize,
int downCacheSize)
|
DurableSubscription |
JDBCChannelMapper.getDurableSubscription(java.lang.String clientID,
java.lang.String subscriptionName,
MessageStore ms,
PersistenceManager pm,
MemoryManager mm)
|
DurableSubscription |
JDBCChannelMapper.createDurableSubscription(java.lang.String topicName,
java.lang.String clientID,
java.lang.String subscriptionName,
java.lang.String selector,
boolean noLocal,
MessageStore ms,
PersistenceManager pm,
MemoryManager mm)
|
Subscription |
JDBCChannelMapper.createSubscription(java.lang.String topicName,
java.lang.String selector,
boolean noLocal,
MessageStore ms,
PersistenceManager pm,
MemoryManager mm)
|
protected java.util.List |
JDBCChannelMapper.loadDurableSubscriptionsForTopic(java.lang.String topicName,
MessageStore ms,
PersistenceManager pm,
MemoryManager mm)
|
protected DurableSubscription |
JDBCChannelMapper.createDurableSubscriptionInternal(long id,
java.lang.String topicName,
java.lang.String clientID,
java.lang.String subscriptionName,
Selector selector,
boolean noLocal,
MessageStore ms,
PersistenceManager pm,
MemoryManager mm)
|
Uses of MessageStore in org.jboss.jms.server.plugin.contract |
Methods in org.jboss.jms.server.plugin.contract with parameters of type MessageStore | |
void |
ChannelMapper.deployCoreDestination(boolean isQueue,
java.lang.String destName,
MessageStore ms,
PersistenceManager pm,
MemoryManager mm,
int fullSize,
int pageSize,
int downCacheSize)
|
void |
ChannelMapper.deployTemporaryCoreDestination(boolean isQueue,
java.lang.String destName,
long id,
MessageStore ms,
PersistenceManager pm,
MemoryManager mm,
int fullSize,
int pageSize,
int downCacheSize)
|
DurableSubscription |
ChannelMapper.createDurableSubscription(java.lang.String topicName,
java.lang.String clientID,
java.lang.String subscriptionName,
java.lang.String selector,
boolean noLocal,
MessageStore ms,
PersistenceManager pm,
MemoryManager mm)
|
Subscription |
ChannelMapper.createSubscription(java.lang.String topicName,
java.lang.String selector,
boolean noLocal,
MessageStore ms,
PersistenceManager pm,
MemoryManager mm)
|
DurableSubscription |
ChannelMapper.getDurableSubscription(java.lang.String clientID,
java.lang.String subscriptionName,
MessageStore ms,
PersistenceManager pm,
MemoryManager mm)
|
Uses of MessageStore in org.jboss.jms.server.subscription |
Constructors in org.jboss.jms.server.subscription with parameters of type MessageStore | |
Subscription(long id,
Topic topic,
MessageStore ms,
PersistenceManager pm,
MemoryManager mm,
int fullSize,
int pageSize,
int downCacheSize,
QueuedExecutor executor,
Selector selector,
boolean isNoLocal)
|
|
Subscription(long id,
Topic topic,
MessageStore ms,
PersistenceManager pm,
MemoryManager mm,
boolean recoverable,
int fullSize,
int pageSize,
int downCacheSize,
QueuedExecutor executor,
Selector selector,
boolean isNoLocal)
|
|
DurableSubscription(long id,
Topic topic,
MessageStore ms,
PersistenceManager pm,
MemoryManager mm,
int fullSize,
int pageSize,
int downCacheSize,
QueuedExecutor executor,
Selector selector,
boolean isNoLocal,
java.lang.String name,
java.lang.String clientID)
|
Uses of MessageStore in org.jboss.messaging.core |
Fields in org.jboss.messaging.core declared as MessageStore | |
protected MessageStore |
ChannelSupport.ms
|
Constructors in org.jboss.messaging.core with parameters of type MessageStore | |
ChannelSupport(long channelID,
MessageStore ms,
PersistenceManager pm,
MemoryManager mm,
boolean acceptReliableMessages,
boolean recoverable,
int fullSize,
int pageSize,
int downCacheSize,
QueuedExecutor executor)
|
Uses of MessageStore in org.jboss.messaging.core.distributed.queue |
Constructors in org.jboss.messaging.core.distributed.queue with parameters of type MessageStore | |
DistributedQueue(java.lang.String name,
MessageStore ms,
RpcDispatcher dispatcher)
An non-recoverable queue peer. |
|
DistributedQueue(java.lang.String name,
MessageStore ms,
PersistenceManager tl,
RpcDispatcher dispatcher)
A recoverable queue peer. |
Uses of MessageStore in org.jboss.messaging.core.distributed.replicator |
Fields in org.jboss.messaging.core.distributed.replicator declared as MessageStore | |
protected MessageStore |
ReplicatorOutput.ms
|
protected MessageStore |
Replicator.ms
|
Constructors in org.jboss.messaging.core.distributed.replicator with parameters of type MessageStore | |
ReplicatorOutput(java.io.Serializable replicatorID,
RpcDispatcher dispatcher,
MessageStore ms,
Receiver receiver)
|
|
Replicator(java.io.Serializable replicatorID,
RpcDispatcher dispatcher,
MessageStore ms,
boolean cancelOnMessageRejection)
Creates a replicator peer. |
Uses of MessageStore in org.jboss.messaging.core.distributed.topic |
Fields in org.jboss.messaging.core.distributed.topic declared as MessageStore | |
protected MessageStore |
DistributedTopic.ms
|
Constructors in org.jboss.messaging.core.distributed.topic with parameters of type MessageStore | |
DistributedTopic(java.lang.String name,
MessageStore ms,
PersistenceManager pm,
RpcDispatcher dispatcher)
|
Uses of MessageStore in org.jboss.messaging.core.local |
Constructors in org.jboss.messaging.core.local with parameters of type MessageStore | |
Queue(long id,
MessageStore ms,
PersistenceManager pm,
MemoryManager mm,
boolean recoverable,
int fullSize,
int pageSize,
int downCacheSize,
QueuedExecutor executor)
|
|
Pipe(long id,
MessageStore ms,
PersistenceManager pm,
MemoryManager mm,
boolean acceptReliableMessages,
boolean recoverable,
int fullSize,
int pageSize,
int downCacheSize,
QueuedExecutor executor)
|
|
CoreSubscription(long id,
Topic topic,
MessageStore ms,
PersistenceManager pm,
MemoryManager mm,
boolean recoverable,
int fullSize,
int pageSize,
int downCacheSize,
QueuedExecutor executor,
Filter filter)
|
Uses of MessageStore in org.jboss.messaging.core.plugin |
Classes in org.jboss.messaging.core.plugin that implement MessageStore | |
class |
SimpleMessageStore
A MessageStore implementation. |
Fields in org.jboss.messaging.core.plugin declared as MessageStore | |
protected MessageStore |
SimpleMessageReference.ms
|
Constructors in org.jboss.messaging.core.plugin with parameters of type MessageStore | |
SimpleMessageReference(org.jboss.messaging.core.plugin.MessageHolder holder,
MessageStore ms)
Creates a reference based on a given message. |
|
SimpleMessageReference(long messageID,
boolean reliable,
long expiration,
long timestamp,
java.util.Map headers,
int deliveryCount,
byte priority,
MessageStore ms)
|
|
|||||||||||
PREV NEXT | FRAMES NO FRAMES |