|
|||||||||||
PREV NEXT | FRAMES NO FRAMES |
Uses of MessageReference in org.jboss.jms.server |
Methods in org.jboss.jms.server with parameters of type MessageReference | |
boolean |
JMSCondition.matches(Condition routingCondition,
MessageReference ref)
|
Uses of MessageReference in org.jboss.jms.server.endpoint |
Methods in org.jboss.jms.server.endpoint with parameters of type MessageReference | |
Delivery |
ServerConsumerEndpoint.handle(DeliveryObserver observer,
MessageReference ref,
Transaction tx)
|
Uses of MessageReference in org.jboss.messaging.core |
Fields in org.jboss.messaging.core declared as MessageReference | |
protected MessageReference |
SimpleDelivery.reference
|
Methods in org.jboss.messaging.core that return MessageReference | |
MessageReference |
Delivery.getReference()
|
protected MessageReference |
ChannelSupport.removeFirstInMemory()
|
MessageReference |
SimpleDelivery.getReference()
|
protected MessageReference |
PagingChannelSupport.removeFirstInMemory()
|
protected MessageReference |
PagingChannelSupport.addFromRefInfo(PersistenceManager.ReferenceInfo info,
java.util.Map refMap)
|
Methods in org.jboss.messaging.core with parameters of type MessageReference | |
Delivery |
Receiver.handle(DeliveryObserver observer,
MessageReference reference,
Transaction tx)
A receiver can return an active, "done" or null delivery. |
Delivery |
ChannelSupport.handle(DeliveryObserver sender,
MessageReference ref,
Transaction tx)
|
protected void |
ChannelSupport.cancelInternal(MessageReference ref)
|
protected boolean |
ChannelSupport.deliverScheduled(MessageReference ref)
|
protected Delivery |
ChannelSupport.handleInternal(DeliveryObserver sender,
MessageReference ref,
Transaction tx,
boolean persist)
|
protected boolean |
ChannelSupport.checkAndSchedule(MessageReference ref)
|
protected void |
ChannelSupport.addReferenceInMemory(MessageReference ref)
|
protected void |
ChannelSupport.processMessageBeforeStorage(MessageReference reference)
Give subclass a chance to process the message before storing it internally. |
protected void |
PagingChannelSupport.cancelInternal(MessageReference ref)
|
protected void |
PagingChannelSupport.addReferenceInMemory(MessageReference ref)
|
protected void |
PagingChannelSupport.addToDownCache(MessageReference ref,
boolean cancelling)
|
Constructors in org.jboss.messaging.core with parameters of type MessageReference | |
SimpleDelivery(DeliveryObserver observer,
MessageReference reference)
|
|
SimpleDelivery(MessageReference reference,
boolean done)
|
|
SimpleDelivery(DeliveryObserver observer,
MessageReference reference,
boolean done)
|
|
SimpleDelivery(DeliveryObserver observer,
MessageReference reference,
boolean done,
boolean selectorAccepted)
|
Uses of MessageReference in org.jboss.messaging.core.local |
Methods in org.jboss.messaging.core.local with parameters of type MessageReference | |
Delivery |
PagingFilteredQueue.handle(DeliveryObserver sender,
MessageReference ref,
Transaction tx)
|
Delivery |
FirstReceiverPointToPointRouter.handle(DeliveryObserver observer,
MessageReference ref,
Transaction tx)
|
Delivery |
RoundRobinPointToPointRouter.handle(DeliveryObserver observer,
MessageReference ref,
Transaction tx)
|
Uses of MessageReference in org.jboss.messaging.core.message |
Classes in org.jboss.messaging.core.message that implement MessageReference | |
class |
SimpleMessageReference
A Simple MessageReference implementation. |
Methods in org.jboss.messaging.core.message that return MessageReference | |
MessageReference |
MessageReference.copy()
|
MessageReference |
SimpleMessageReference.copy()
|
MessageReference |
SimpleMessageStore.reference(Message m)
|
MessageReference |
SimpleMessageStore.reference(long messageID)
|
Uses of MessageReference in org.jboss.messaging.core.plugin |
Methods in org.jboss.messaging.core.plugin with parameters of type MessageReference | |
void |
JDBCPersistenceManager.addReference(long channelID,
MessageReference ref,
Transaction tx)
|
void |
JDBCPersistenceManager.updateDeliveryCount(long channelID,
MessageReference ref)
|
void |
JDBCPersistenceManager.removeReference(long channelID,
MessageReference ref,
Transaction tx)
|
protected void |
JDBCPersistenceManager.addReference(long channelID,
MessageReference ref,
java.sql.PreparedStatement ps,
boolean paged)
|
protected void |
JDBCPersistenceManager.removeReference(long channelID,
MessageReference ref,
java.sql.PreparedStatement ps)
|
protected void |
JDBCPersistenceManager.prepareToAddReference(long channelID,
MessageReference ref,
Transaction tx,
java.sql.PreparedStatement ps)
|
protected void |
JDBCPersistenceManager.prepareToRemoveReference(long channelID,
MessageReference ref,
Transaction tx,
java.sql.PreparedStatement ps)
|
Uses of MessageReference in org.jboss.messaging.core.plugin.contract |
Methods in org.jboss.messaging.core.plugin.contract that return MessageReference | |
MessageReference |
MessageStore.reference(Message m)
Message m is stored in the store if it is not already known to the store, then a new MessageReference is returned for the Message |
MessageReference |
MessageStore.reference(long messageID)
Return a new reference for a message already stored in the store and identified by |
Methods in org.jboss.messaging.core.plugin.contract with parameters of type MessageReference | |
boolean |
Condition.matches(Condition routingCondition,
MessageReference ref)
|
boolean |
PostOffice.route(MessageReference ref,
Condition condition,
Transaction tx)
Route a reference. |
void |
PersistenceManager.addReference(long channelID,
MessageReference ref,
Transaction tx)
|
void |
PersistenceManager.removeReference(long channelID,
MessageReference ref,
Transaction tx)
|
void |
PersistenceManager.updateDeliveryCount(long channelID,
MessageReference ref)
|
Uses of MessageReference in org.jboss.messaging.core.plugin.postoffice |
Methods in org.jboss.messaging.core.plugin.postoffice with parameters of type MessageReference | |
boolean |
DefaultPostOffice.route(MessageReference ref,
Condition condition,
Transaction tx)
|
Uses of MessageReference in org.jboss.messaging.core.plugin.postoffice.cluster |
Methods in org.jboss.messaging.core.plugin.postoffice.cluster with parameters of type MessageReference | |
Delivery |
RemoteQueueStub.handle(DeliveryObserver observer,
MessageReference reference,
Transaction tx)
|
boolean |
DefaultClusteredPostOffice.route(MessageReference ref,
Condition condition,
Transaction tx)
|
Delivery |
DefaultRouter.handle(DeliveryObserver observer,
MessageReference ref,
Transaction tx)
|
Delivery |
RoundRobinRouter.handle(DeliveryObserver observer,
MessageReference ref,
Transaction tx)
|
Delivery |
LocalClusteredQueue.handleFromCluster(MessageReference ref)
|
|
|||||||||||
PREV NEXT | FRAMES NO FRAMES |