Uses of Interface
org.jboss.messaging.core.contract.MessageReference

Packages that use MessageReference
org.jboss.jms.server.endpoint   
org.jboss.messaging.core.contract   
org.jboss.messaging.core.impl   
org.jboss.messaging.core.impl.message   
org.jboss.messaging.core.impl.postoffice   
 

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.
 Delivery Queue.handleMove(MessageReference ref, long sourceChannelID)
           
 void PersistenceManager.moveReference(long sourceChannelID, long destChannelID, MessageReference ref)
           
 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 PagingChannelSupport.removeFirstInMemory()
           
protected  MessageReference ChannelSupport.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)
           
 void NullPersistenceManager.addReference(long channelID, MessageReference ref, Transaction tx)
           
protected  void PagingChannelSupport.addReferenceInMemory(MessageReference ref)
           
protected  void ChannelSupport.addReferenceInMemory(MessageReference ref)
           
protected  void PagingChannelSupport.addToDownCache(MessageReference ref, boolean cancelling)
           
protected  void PagingChannelSupport.cancelInternal(MessageReference ref)
           
protected  void ChannelSupport.cancelInternal(MessageReference ref)
           
protected  boolean ChannelSupport.checkAndSchedule(MessageReference ref)
           
protected  boolean ChannelSupport.deliverScheduled(MessageReference ref)
           
static java.lang.String ChannelSupport.getRefText(MessageReference ref)
           
 Delivery FirstReceiverDistributor.handle(DeliveryObserver observer, MessageReference ref, Transaction tx)
           
 Delivery ClusterRoundRobinDistributor.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)
           
 Delivery ChannelSupport.handleMove(MessageReference ref, long sourceChannelID)
           
 int OrderingGroup.isAvailable(MessageReference ref)
          See if the ref be there and be the first Simply comparing the addresses simply doesn't work!
 int OrderingGroupMonitor.isAvailable(MessageReference ref)
          If ref is not in our registry, just return OK.
static boolean OrderingGroupMonitor.isOrderingGroupMessage(MessageReference ref)
          check if the message has a group name
 void OrderingGroup.markSending(MessageReference ref)
          Set the flag that the Message is being delivered.
 void OrderingGroupMonitor.markSending(MessageReference ref)
           
 boolean OrderingGroupMonitor.messageCompleted(MessageReference ref)
          This method indicates a messgae is completed.
 void JDBCPersistenceManager.moveReference(long sourceChannelID, long destChannelID, MessageReference ref)
           
 void NullPersistenceManager.moveReference(long sourceChannelID, long destChannelID, MessageReference ref)
           
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.
 boolean OrderingGroup.register(MessageReference ref)
          Adding a message to a list.
 void OrderingGroupMonitor.registerMessage(MessageReference ref)
          Check the message is it is a member of an ordering group, if so, put it in; if not, do nothing.
protected  void JDBCPersistenceManager.removeReference(long channelID, MessageReference ref, java.sql.PreparedStatement ps)
           
 void JDBCPersistenceManager.removeReference(long channelID, MessageReference ref, Transaction tx)
           
 void NullPersistenceManager.removeReference(long channelID, MessageReference ref, Transaction tx)
           
 void OrderingGroup.unmarkSending(MessageReference ref)
           
 void OrderingGroupMonitor.unmarkSending(MessageReference ref)
          reducing the refcount, if zero, remove it.
 void OrderingGroup.unregister(MessageReference ref)
          remove the message reference from the group Note: the ref will be removed if and only if the ref resides the first in the list, otherwise just ignore it.
 void JDBCPersistenceManager.updateDeliveryCount(long channelID, MessageReference ref)
           
 void NullPersistenceManager.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)
           
 



Copyright © 2006 JBoss Inc. All Rights Reserved.