Package org.hornetq.core.server.impl.QueueImpl

Examples of org.hornetq.core.server.impl.QueueImpl.RefsOperation

1625
1626
1627
1628
1629
1630
1631
1632
1633
1634
1635
1636
1637
1638
1639
1640
1641
1642
1643
   @Override
   public List<MessageReference> getInTXMessagesForConsumer(long consumerId)
   {
      if (this.tx != null)
      {
         RefsOperation oper = (RefsOperation)tx.getProperty(TransactionPropertyIndexes.REFS_OPERATION);
        
         if (oper == null)
         {
            return Collections.emptyList();
         }
         else
         {
            return oper.getListOnConsumer(consumerId);
         }
      }
      else
      {
         return Collections.emptyList();
View Full Code Here
TOP

Related Classes of org.hornetq.core.server.impl.QueueImpl.RefsOperation

  • org.hornetq.core.server.impl.ServerSessionImpl
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.