Examples of org.hornetq.core.server.ServerMessage

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

      // 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

                         ", can't deliver reference " +
                         ref);
            }
            return HandleStatus.BUSY;
         }
         final ServerMessage message = ref.getMessage();


         if (filter != null && !filter.match(message))
         {
            if (log.isTraceEnabled())
            {
               log.trace("Reference " + ref + " is a noMatch on consumer " + this);
            }
            return HandleStatus.NO_MATCH;
         }


         if (log.isTraceEnabled())
         {
            log.trace("Handling reference " + ref);
         }


         if (!browseOnly)
         {
            if (!preAcknowledge)
            {
               deliveringRefs.add(ref);
            }


            ref.handled();


            ref.incrementDeliveryCount();


            // If updateDeliveries = false (set by strict-update),
            // the updateDeliveryCount would still be updated after c
            if (strictUpdateDeliveryCount && !ref.isPaged())
            {
               if (ref.getMessage().isDurable() && ref.getQueue().isDurable() &&
                   !ref.getQueue().isInternalQueue() &&
                   !ref.isPaged())
               {
                  storageManager.updateDeliveryCount(ref);
               }
            }


            if (preAcknowledge)
            {
               if (message.isLargeMessage())
               {
                  // we must hold one reference, or the file will be deleted before it could be delivered
                  ((LargeServerMessage)message).incrementDelayDeletionCount();
               }

View Full Code Here

   {
      try
      {
         synchronized (deliveryGuard)
         {
            ServerMessage message = reference.getMessage();


            if (message.isLargeMessage())
            {
               if (largeMessageDeliverer == null)
               {
                  // This can't really happen as handle had already crated the deliverer
                  // instead of throwing an exception in weird cases there is no problem on just go ahead and create it

View Full Code Here

                        }
                     });
                  }
                  else
                  {
                     ServerMessage forcedDeliveryMessage = new ServerMessageImpl(storageManager.generateUniqueID(), 50);


                     forcedDeliveryMessage.putLongProperty(ClientConsumerImpl.FORCED_DELIVERY_MESSAGE, sequence);
                     forcedDeliveryMessage.setAddress(messageQueue.getName());


                     callback.sendMessage(forcedDeliveryMessage, id, 0);
                  }
               }
            }

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

      }
   }


   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

   /*
   * handle an incoming Ack from Proton, basically pass to HornetQ to handle
   * */
   public void onMessage(Delivery delivery) throws HornetQAMQPException
   {
      ServerMessage message = (ServerMessage) delivery.getContext();


      boolean preSettle = sender.getRemoteSenderSettleMode() == SenderSettleMode.SETTLED;




      DeliveryState remoteState = delivery.getRemoteState();


      if (remoteState != null)
      {
         if (remoteState instanceof Accepted)
         {
            //we have to individual ack as we can't guarantee we will get the delivery updates (including acks) in order
            // from proton, a perf hit but a must
            try
            {
               protonSession.getServerSession().individualAcknowledge(consumerID, message.getMessageID());
            }
            catch (Exception e)
            {
               throw HornetQAMQPProtocolMessageBundle.BUNDLE.errorAcknowledgingMessage(message.getMessageID(), e.getMessage());
            }
         }
         else if (remoteState instanceof Released)
         {
            try
            {
               protonSession.getServerSession().individualCancel(consumerID, message.getMessageID(), false);
            }
            catch (Exception e)
            {
               throw HornetQAMQPProtocolMessageBundle.BUNDLE.errorCancellingMessage(message.getMessageID(), e.getMessage());
            }
         }
         else if (remoteState instanceof Rejected || remoteState instanceof Modified)
         {
            try
            {
               protonSession.getServerSession().individualCancel(consumerID, message.getMessageID(), true);
            }
            catch (Exception e)
            {
               throw HornetQAMQPProtocolMessageBundle.BUNDLE.errorCancellingMessage(message.getMessageID(), e.getMessage());
            }
         }


         synchronized (connection.getDeliveryLock())
         {

View Full Code Here

         receiver.advance();
         byte[] bytes = new byte[buffer.readableBytes()];
         buffer.readBytes(bytes);
         buffer.clear();
         EncodedMessage encodedMessage = new EncodedMessage(delivery.getMessageFormat(), bytes, 0, bytes.length);
         ServerMessage message = ProtonUtils.INBOUND.transform(connection, encodedMessage);
         //use the address on the receiver if not null, if null let's hope it was set correctly on the message
         if (address != null)
         {
            message.setAddress(new SimpleString(address));
         }
         //todo decide on whether to deliver direct
         protonSession.getServerSession().send(message, true);
         server.getStorageManager().afterCompleteOperations(new IOAsyncTask()
         {

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

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.