Examples of org.hornetq.core.server.ServerMessage

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

      {
         // Reverse the ref counts, and paging sizes


         for (MessageReference ref : refs)
         {
            ServerMessage message = ref.getMessage();


            if (message.isDurable() && ref.getQueue().isDurable())
            {
               message.decrementDurableRefCount();
            }


            message.decrementRefCount();
         }
      }

View Full Code Here

   {


      // We have to copy the message and store it separately, otherwise we may lose remote bindings in case of restart before the message
      // arrived the target node
      // as described on https://issues.jboss.org/browse/JBPAPP-6130
      ServerMessage copyRedistribute = message.copy(storageManager.generateUniqueID());
      
      Bindings bindings = addressManager.getBindingsForRoutingAddress(message.getAddress());


      boolean res = false;

View Full Code Here

      // Need to lock to make sure all queue info and notifications are in the correct order with no gaps
      synchronized (notificationLock)
      {
         // First send a reset message


         ServerMessage message = new ServerMessageImpl(storageManager.generateUniqueID(), 50);


         message.setAddress(queueName);
         message.putBooleanProperty(PostOfficeImpl.HDR_RESET_QUEUE_DATA, true);
         routeQueueInfo(message, queue, false);


         for (QueueInfo info : queueInfos.values())
         {
            if (log.isTraceEnabled())
            {
               log.trace("QueueInfo on sendQueueInfoToQueue = " + info);
            }
            if (info.getAddress().startsWith(address))
            {
               message = createQueueInfoMessage(NotificationType.BINDING_ADDED, queueName);


               message.putStringProperty(ManagementHelper.HDR_ADDRESS, info.getAddress());
               message.putStringProperty(ManagementHelper.HDR_CLUSTER_NAME, info.getClusterName());
               message.putStringProperty(ManagementHelper.HDR_ROUTING_NAME, info.getRoutingName());
               message.putLongProperty(ManagementHelper.HDR_BINDING_ID, info.getID());
               message.putStringProperty(ManagementHelper.HDR_FILTERSTRING, info.getFilterString());
               message.putIntProperty(ManagementHelper.HDR_DISTANCE, info.getDistance());


               routeQueueInfo(message, queue, true);


               int consumersWithFilters = info.getFilterStrings() != null ? info.getFilterStrings().size() : 0;


               for (int i = 0; i < info.getNumberOfConsumers() - consumersWithFilters; i++)
               {
                  message = createQueueInfoMessage(NotificationType.CONSUMER_CREATED, queueName);


                  message.putStringProperty(ManagementHelper.HDR_ADDRESS, info.getAddress());
                  message.putStringProperty(ManagementHelper.HDR_CLUSTER_NAME, info.getClusterName());   
                  message.putStringProperty(ManagementHelper.HDR_ROUTING_NAME, info.getRoutingName());
                  message.putIntProperty(ManagementHelper.HDR_DISTANCE, info.getDistance());


                  routeQueueInfo(message, queue, true);
               }


               if (info.getFilterStrings() != null)
               {
                  for (SimpleString filterString : info.getFilterStrings())
                  {
                     message = createQueueInfoMessage(NotificationType.CONSUMER_CREATED, queueName);


                     message.putStringProperty(ManagementHelper.HDR_ADDRESS, info.getAddress());
                     message.putStringProperty(ManagementHelper.HDR_CLUSTER_NAME, info.getClusterName());
                     message.putStringProperty(ManagementHelper.HDR_ROUTING_NAME, info.getRoutingName());
                     message.putStringProperty(ManagementHelper.HDR_FILTERSTRING, filterString);
                     message.putIntProperty(ManagementHelper.HDR_DISTANCE, info.getDistance());


                     routeQueueInfo(message, queue, true);
                  }
               }
            }

View Full Code Here

      }
   }


   private ServerMessage createQueueInfoMessage(final NotificationType type, final SimpleString queueName)
   {
      ServerMessage message = new ServerMessageImpl(storageManager.generateUniqueID(), 50);


      message.setAddress(queueName);


      String uid = UUIDGenerator.getInstance().generateStringUUID();


      message.putStringProperty(ManagementHelper.HDR_NOTIFICATION_TYPE, new SimpleString(type.toString()));
      message.putLongProperty(ManagementHelper.HDR_NOTIFICATION_TIMESTAMP, System.currentTimeMillis());


      message.putStringProperty(new SimpleString("foobar"), new SimpleString(uid));


      return message;
   }

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) throws Exception
   {
      ServerMessage message = reference.getMessage();


      if (internalQueue)
      {
         if (isTrace)
         {
            log.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();


      // First check DLA
      if (maxDeliveries > 0 && reference.getDeliveryCount() >= maxDeliveries)
      {
         if (isTrace)
         {
            log.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
         long redeliveryDelay = addressSettings.getRedeliveryDelay();


         if (redeliveryDelay > 0)
         {
            if (isTrace)
            {
               log.trace("Setting redeliveryDelay=" + redeliveryDelay + " on reference=" + reference);
            }
            reference.setScheduledDeliveryTime(timeBase + redeliveryDelay);
            
            if (!reference.isPaged() && message.isDurable() && durable)
            {
               storageManager.updateScheduledDeliveryTime(reference);
            }
         }

View Full Code Here

                     final Transaction tx,
                     final MessageReference ref,
                     final boolean expiry,
                     final boolean rejectDuplicate) throws Exception
   {
      ServerMessage copyMessage = makeCopy(ref, expiry);


      copyMessage.setAddress(toAddress);


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


      acknowledge(tx, ref);
   }

View Full Code Here

      acknowledge(tx, ref);
   }


   private ServerMessage makeCopy(final MessageReference ref, final boolean expiry) throws Exception
   {
      ServerMessage message = ref.getMessage();
      /*
       We copy the message and send that to the dla/expiry queue - this is
       because otherwise we may end up with a ref with the same message id in the
       queue more than once which would barf - this might happen if the same message had been
       expire from multiple subscriptions of a topic for example
       We set headers that hold the original message address, expiry time
       and original message id
      */


      long newID = storageManager.generateUniqueID();


      ServerMessage copy = message.makeCopyForExpiryOrDLA(newID, expiry);


      return copy;
   }

View Full Code Here


   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;


      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);
            }
         }
      }


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

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.