Examples of org.hornetq.core.transaction.impl.BindingsTransactionImpl

Package org.hornetq.core.transaction.impl

Examples of org.hornetq.core.transaction.impl.BindingsTransactionImpl

org.hornetq.core.transaction.impl.BindingsTransactionImpl
A BindingsTransactionImpl @author clebertsuconic

      synchronized (this)
      {
         this.queueDestroyed = true;
      }
      
      Transaction tx = new BindingsTransactionImpl(storageManager);
      
      try
      {
         postOffice.removeBinding(name, tx);
         
         deleteAllReferences();
   
         destroyPaging();
   
         if (isDurable())
         {
            storageManager.deleteQueueBinding(tx.getID(), getID());
            tx.setContainsPersistent();
         }
         
         tx.commit();
      }
      catch (Exception e)
      {
         tx.rollback();
         throw e;
      }


   }

View Full Code Here

      synchronized (this)
      {
         this.queueDestroyed = true;
      }


      Transaction tx = new BindingsTransactionImpl(storageManager);


      try
      {
         postOffice.removeBinding(name, tx);


         deleteAllReferences();


         destroyPaging();


         if (removeConsumers)
         {
            for (ConsumerHolder consumerHolder : consumerList)
            {
               consumerHolder.consumer.disconnect();
            }
         }


         if (isDurable())
         {
            storageManager.deleteQueueBinding(tx.getID(), getID());
            tx.setContainsPersistent();
         }


         tx.commit();
      }
      catch (Exception e)
      {
         tx.rollback();
         throw e;
      }


   }

View Full Code Here

      synchronized (this)
      {
         this.queueDestroyed = true;
      }


      Transaction tx = new BindingsTransactionImpl(storageManager);


      try
      {
         postOffice.removeBinding(name, tx);


         deleteAllReferences();


         destroyPaging();


         if (isDurable())
         {
            storageManager.deleteQueueBinding(tx.getID(), getID());
            tx.setContainsPersistent();
         }


         tx.commit();
      }
      catch (Exception e)
      {
         tx.rollback();
         throw e;
      }


   }

View Full Code Here

      synchronized (this)
      {
         this.queueDestroyed = true;
      }


      Transaction tx = new BindingsTransactionImpl(storageManager);


      try
      {
         postOffice.removeBinding(name, tx);


         deleteAllReferences();


         destroyPaging();


         if (removeConsumers)
         {
            for (ConsumerHolder consumerHolder : consumerList)
            {
               consumerHolder.consumer.disconnect();
            }
         }


         if (isDurable())
         {
            storageManager.deleteQueueBinding(tx.getID(), getID());
            tx.setContainsPersistent();
         }


         tx.commit();
      }
      catch (Exception e)
      {
         tx.rollback();
         throw e;
      }


   }

View Full Code Here

      synchronized (this)
      {
         this.queueDestroyed = true;
      }


      Transaction tx = new BindingsTransactionImpl(storageManager);


      try
      {
         postOffice.removeBinding(name, tx);


         deleteAllReferences();


         destroyPaging();


         if (isDurable())
         {
            storageManager.deleteQueueBinding(tx.getID(), getID());
            tx.setContainsPersistent();
         }


         tx.commit();
      }
      catch (Exception e)
      {
         tx.rollback();
         throw e;
      }


   }

View Full Code Here

      synchronized (this)
      {
         this.queueDestroyed = true;
      }


      Transaction tx = new BindingsTransactionImpl(storageManager);


      try
      {
         postOffice.removeBinding(name, tx);


         deleteAllReferences();


         destroyPaging();


         if (isDurable())
         {
            storageManager.deleteQueueBinding(tx.getID(), getID());
            tx.setContainsPersistent();
         }


         tx.commit();
      }
      catch (Exception e)
      {
         tx.rollback();
         throw e;
      }


   }

View Full Code Here

      synchronized (this)
      {
         this.queueDestroyed = true;
      }


      Transaction tx = new BindingsTransactionImpl(storageManager);


      try
      {
         postOffice.removeBinding(name, tx);


         deleteAllReferences();


         destroyPaging();


         if (isDurable())
         {
            storageManager.deleteQueueBinding(tx.getID(), getID());
            tx.setContainsPersistent();
         }


         tx.commit();
      }
      catch (Exception e)
      {
         tx.rollback();
         throw e;
      }


   }

View Full Code Here

      synchronized (this)
      {
         this.queueDestroyed = true;
      }


      Transaction tx = new BindingsTransactionImpl(storageManager);


      try
      {
         postOffice.removeBinding(name, tx);


         deleteAllReferences();


         destroyPaging();


         if (isDurable())
         {
            storageManager.deleteQueueBinding(tx.getID(), getID());
            tx.setContainsPersistent();
         }


         tx.commit();
      }
      catch (Exception e)
      {
         tx.rollback();
         throw e;
      }


   }

View Full Code Here

      synchronized (this)
      {
         this.queueDestroyed = true;
      }


      Transaction tx = new BindingsTransactionImpl(storageManager);


      try
      {
         postOffice.removeBinding(name, tx);


         deleteAllReferences();


         destroyPaging();


         if (isDurable())
         {
            storageManager.deleteQueueBinding(tx.getID(), getID());
            tx.setContainsPersistent();
         }


         tx.commit();
      }
      catch (Exception e)
      {
         tx.rollback();
         throw e;
      }


   }

View Full Code Here

      synchronized (this)
      {
         this.queueDestroyed = true;
      }


      Transaction tx = new BindingsTransactionImpl(storageManager);


      try
      {
         postOffice.removeBinding(name, tx);


         deleteAllReferences();


         destroyPaging();


         if (isDurable())
         {
            storageManager.deleteQueueBinding(tx.getID(), getID());
            tx.setContainsPersistent();
         }


         tx.commit();
      }
      catch (Exception e)
      {
         tx.rollback();
         throw e;
      }


   }

View Full Code Here

0 1

TOP

Related Classes of org.hornetq.core.transaction.impl.BindingsTransactionImpl

org.hornetq.core.server.impl.QueueImpl

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.