Examples of org.hornetq.core.server.ServerMessage

org.hornetq.core.server.ServerMessage
A ServerMessage @author Tim Fox @author Clebert Suconic


   private void move(final SimpleString address, final MessageReference ref, final boolean expiry, final boolean rejectDuplicate) throws Exception
   {
      Transaction tx = new TransactionImpl(storageManager);


      ServerMessage copyMessage = makeCopy(ref, expiry);


      copyMessage.setAddress(address);


      postOffice.route(copyMessage, tx, false, rejectDuplicate);


      acknowledge(tx, ref);

View Full Code Here

      {
         // nothing to be done
         return;
      }


      final ServerMessage message = ref.getMessage();


      boolean durableRef = message.isDurable() && queue.durable;


      try
      {
         message.decrementRefCount();
      }
      catch (Exception e)
      {
         QueueImpl.log.warn("Unable to decrement reference counting", e);
      }


      if (durableRef)
      {
         int count = message.decrementDurableRefCount();


         if (count == 0)
         {
            // Note - we MUST store the delete after the preceding ack has been committed to storage, we cannot combine
            // the last ack and delete into a single delete.
            // This is because otherwise we could have a situation where the same message is being acked concurrently
            // from two different queues on different sessions.
            // One decrements the ref count, then the other stores a delete, the delete gets committed, but the first
            // ack isn't committed, then the server crashes and on
            // recovery the message is deleted even though the other ack never committed


            // also note then when this happens as part of a transaction it is the tx commit of the ack that is 
            // important not this


            // Also note that this delete shouldn't sync to disk, or else we would build up the executor's queue
            // as we can't delete each messaging with sync=true while adding messages transactionally.
            // There is a startup check to remove non referenced messages case these deletes fail
            try
            {
               storageManager.deleteMessage(message.getMessageID());
            }
            catch (Exception e)
            {
               QueueImpl.log.warn("Unable to remove message id = " + message.getMessageID() + " please remove manually",
                                  e);
            }
         }
      }
   }

View Full Code Here

         message.putBytesProperty(MessageImpl.HDR_BRIDGE_DUPLICATE_ID, bytes);
      }


      if (transformer != null)
      {
         final ServerMessage transformedMessage = transformer.transform(message);
         if (transformedMessage != message)
         {
            if (HornetQServerLogger.LOGGER.isDebugEnabled())
            {
               HornetQServerLogger.LOGGER.debug("The transformer " + transformer +

View Full Code Here


         ref.handled();


         refs.add(ref);


         final ServerMessage message = beforeForward(ref.getMessage());


         final SimpleString dest;


         if (forwardingAddress != null)
         {
            dest = forwardingAddress;
         }
         else
         {
            // Preserve the original address
            dest = message.getAddress();
         }


         pendingAcks.countUp();


         try
         {
            if (message.isLargeMessage())
            {
               deliveringLargeMessage = true;
               deliverLargeMessage(dest, ref, (LargeServerMessage)message);
               return HandleStatus.HANDLED;
            }

View Full Code Here

            tx.markAsRollbackOnly(e);
         }
         throw e;
      }


      ServerMessage reply = managementService.handleMessage(message);


      SimpleString replyTo = message.getSimpleStringProperty(ClientMessageImpl.REPLYTO_HEADER_NAME);


      if (replyTo != null)
      {
         reply.setAddress(replyTo);


         doSend(reply, direct);
      }
   }

View Full Code Here

      // We make a copy of the message, then we strip out the unwanted routing id headers and leave
      // only
      // the one pertinent for the address node - this is important since different queues on different
      // nodes could have same queue ids
      // Note we must copy since same message may get routed to other nodes which require different headers
      ServerMessage messageCopy = message.copy();


      if (HornetQServerLogger.LOGGER.isTraceEnabled())
      {
         HornetQServerLogger.LOGGER.trace("Clustered bridge  copied message " + message + " as " + messageCopy + " before delivery");
      }


      // TODO - we can optimise this


      Set<SimpleString> propNames = new HashSet<SimpleString>(messageCopy.getPropertyNames());


      byte[] queueIds = message.getBytesProperty(idsHeaderName);


      if (queueIds == null)
      {
         // Sanity check only
         HornetQServerLogger.LOGGER.noQueueIdDefined(message, messageCopy, idsHeaderName);
         throw new IllegalStateException("no queueIDs defined");
      }


      for (SimpleString propName : propNames)
      {
         if (propName.startsWith(MessageImpl.HDR_ROUTE_TO_IDS))
         {
            messageCopy.removeProperty(propName);
         }
      }


      messageCopy.putBytesProperty(MessageImpl.HDR_ROUTE_TO_IDS, queueIds);


      messageCopy = super.beforeForward(messageCopy);


      return messageCopy;
   }

View Full Code Here

         pageSubscription.ack((PagedReference) ref);
         postAcknowledge(ref);
      }
      else
      {
         ServerMessage message = ref.getMessage();


         boolean durableRef = message.isDurable() && durable;


         if (durableRef)
         {
            storageManager.storeAcknowledge(id, message.getMessageID());
         }
         postAcknowledge(ref);
      }


   }

View Full Code Here


         getRefsOperation(tx).addAck(ref);
      }
      else
      {
         ServerMessage message = ref.getMessage();


         boolean durableRef = message.isDurable() && durable;


         if (durableRef)
         {
            storageManager.storeAcknowledgeTransactional(tx.getID(), id, message.getMessageID());


            tx.setContainsPersistent();
         }


         getRefsOperation(tx).addAck(ref);

View Full Code Here

      }
   }


   public void reacknowledge(final Transaction tx, final MessageReference ref) throws Exception
   {
      ServerMessage message = ref.getMessage();


      if (message.isDurable() && durable)
      {
         tx.setContainsPersistent();
      }


      getRefsOperation(tx).addAck(ref);

View Full Code Here

      }
   }


   public boolean checkRedelivery(final MessageReference reference, final long timeBase, final boolean ignoreRedeliveryDelay) throws Exception
   {
      ServerMessage message = reference.getMessage();


      if (internalQueue)
      {
         if (isTrace)
         {
            HornetQServerLogger.LOGGER.trace("Queue " + this.getName() + " is an internal queue, no checkRedelivery");
         }
         // no DLQ check on internal queues
         return true;
      }


      if (!internalQueue && message.isDurable() && durable && !reference.isPaged())
      {
         storageManager.updateDeliveryCount(reference);
      }


      AddressSettings addressSettings = addressSettingsRepository.getMatch(address.toString());


      int maxDeliveries = addressSettings.getMaxDeliveryAttempts();
      long redeliveryDelay = addressSettings.getRedeliveryDelay();
      int deliveryCount = reference.getDeliveryCount();


      // First check DLA
      if (maxDeliveries > 0 && deliveryCount >= maxDeliveries)
      {
         if (isTrace)
         {
            HornetQServerLogger.LOGGER.trace("Sending reference " + reference + " to DLA = " + addressSettings.getDeadLetterAddress() +  " since ref.getDeliveryCount=" + reference.getDeliveryCount() + "and maxDeliveries=" + maxDeliveries + " from queue=" + this.getName());
         }
         sendToDeadLetterAddress(reference, addressSettings.getDeadLetterAddress());


         return false;
      }
      else
      {
         // Second check Redelivery Delay
         if (!ignoreRedeliveryDelay && redeliveryDelay > 0)
         {
            redeliveryDelay = calculateRedeliveryDelay(addressSettings, deliveryCount);


            if (isTrace)
            {
               HornetQServerLogger.LOGGER.trace("Setting redeliveryDelay=" + redeliveryDelay + " on reference=" + reference);
            }


            reference.setScheduledDeliveryTime(timeBase + redeliveryDelay);


            if (!reference.isPaged() && message.isDurable() && durable)
            {
               storageManager.updateScheduledDeliveryTime(reference);
            }
         }

View Full Code Here

0 1 2 3 4 5 6 7 8 9

TOP

Related Classes of org.hornetq.core.server.ServerMessage

org.hornetq.core.paging.cursor.PagedReferenceImpl

org.hornetq.core.paging.impl.PagingStoreImpl

org.hornetq.core.persistence.impl.journal.DescribeJournal

org.hornetq.core.persistence.impl.journal.JournalStorageManager

org.hornetq.core.persistence.impl.journal.LargeServerMessageImpl

org.hornetq.core.postoffice.impl.PostOfficeImpl

org.hornetq.core.postoffice.impl.PostOfficeImpl$AddOperation

org.hornetq.core.protocol.proton.ProtonConsumer

org.hornetq.core.protocol.proton.ProtonProtocolManager

org.hornetq.core.protocol.stomp.StompSession

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.