|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
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.contract |
---|
Methods in org.jboss.messaging.core.contract that return MessageReference | |
---|---|
MessageReference |
MessageReference.copy()
|
MessageReference |
Message.createReference()
|
MessageReference |
Delivery.getReference()
|
MessageReference |
MessageStore.reference(long messageID)
|
MessageReference |
MessageStore.reference(Message message)
|
Methods in org.jboss.messaging.core.contract with parameters of type MessageReference | |
---|---|
void |
PersistenceManager.addReference(long channelID,
MessageReference ref,
Transaction tx)
|
Delivery |
Receiver.handle(DeliveryObserver observer,
MessageReference reference,
Transaction tx)
A receiver can return an active, "done" or null delivery. |
void |
PersistenceManager.removeReference(long channelID,
MessageReference ref,
Transaction tx)
|
boolean |
PostOffice.route(MessageReference ref,
Condition condition,
Transaction tx)
Route a reference. |
void |
PersistenceManager.updateDeliveryCount(long channelID,
MessageReference ref)
|
Uses of MessageReference in org.jboss.messaging.core.impl |
---|
Methods in org.jboss.messaging.core.impl that return MessageReference | |
---|---|
protected MessageReference |
PagingChannelSupport.addFromRefInfo(PersistenceManager.ReferenceInfo info,
java.util.Map refMap)
|
MessageReference |
SimpleDelivery.getReference()
|
protected MessageReference |
ChannelSupport.removeFirstInMemory()
|
protected MessageReference |
PagingChannelSupport.removeFirstInMemory()
|
Methods in org.jboss.messaging.core.impl with parameters of type MessageReference | |
---|---|
protected void |
JDBCPersistenceManager.addReference(long channelID,
MessageReference ref,
java.sql.PreparedStatement ps,
boolean paged)
|
void |
JDBCPersistenceManager.addReference(long channelID,
MessageReference ref,
Transaction tx)
|
protected void |
ChannelSupport.addReferenceInMemory(MessageReference ref)
|
protected void |
PagingChannelSupport.addReferenceInMemory(MessageReference ref)
|
protected void |
PagingChannelSupport.addToDownCache(MessageReference ref,
boolean cancelling)
|
protected void |
ChannelSupport.cancelInternal(MessageReference ref)
|
protected void |
PagingChannelSupport.cancelInternal(MessageReference ref)
|
protected boolean |
ChannelSupport.checkAndSchedule(MessageReference ref)
|
protected boolean |
ChannelSupport.deliverScheduled(MessageReference ref)
|
Delivery |
ClusterRoundRobinDistributor.handle(DeliveryObserver observer,
MessageReference ref,
Transaction tx)
|
Delivery |
FirstReceiverDistributor.handle(DeliveryObserver observer,
MessageReference ref,
Transaction tx)
|
Delivery |
MessagingQueue.DistributorWrapper.handle(DeliveryObserver observer,
MessageReference reference,
Transaction tx)
|
Delivery |
RoundRobinDistributor.handle(DeliveryObserver observer,
MessageReference ref,
Transaction tx)
|
Delivery |
ChannelSupport.handle(DeliveryObserver sender,
MessageReference ref,
Transaction tx)
|
protected Delivery |
ChannelSupport.handleInternal(DeliveryObserver sender,
MessageReference ref,
Transaction tx,
boolean persist)
|
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)
|
protected void |
ChannelSupport.processMessageBeforeStorage(MessageReference reference)
Give subclass a chance to process the message before storing it internally. |
protected void |
JDBCPersistenceManager.removeReference(long channelID,
MessageReference ref,
java.sql.PreparedStatement ps)
|
void |
JDBCPersistenceManager.removeReference(long channelID,
MessageReference ref,
Transaction tx)
|
void |
JDBCPersistenceManager.updateDeliveryCount(long channelID,
MessageReference ref)
|
Constructors in org.jboss.messaging.core.impl with parameters of type MessageReference | |
---|---|
SimpleDelivery(DeliveryObserver observer,
MessageReference reference)
|
|
SimpleDelivery(DeliveryObserver observer,
MessageReference reference,
boolean selectorAccepted,
boolean recovered)
|
Uses of MessageReference in org.jboss.messaging.core.impl.message |
---|
Classes in org.jboss.messaging.core.impl.message that implement MessageReference | |
---|---|
class |
SimpleMessageReference
A Simple MessageReference implementation. |
Methods in org.jboss.messaging.core.impl.message that return MessageReference | |
---|---|
MessageReference |
SimpleMessageReference.copy()
|
MessageReference |
MessageSupport.createReference()
|
MessageReference |
SimpleMessageStore.reference(long messageID)
|
MessageReference |
SimpleMessageStore.reference(Message m)
|
Uses of MessageReference in org.jboss.messaging.core.impl.postoffice |
---|
Methods in org.jboss.messaging.core.impl.postoffice with parameters of type MessageReference | |
---|---|
boolean |
MessagingPostOffice.route(MessageReference ref,
Condition condition,
Transaction tx)
|
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |