Package org.hornetq.core.postoffice

Examples of org.hornetq.core.postoffice.Bindings

624
625
626
627
628
629
630
631
632
633
634
635
636
637
638
         // but we don't do it every time, otherwise it wouldn't be optimal
         cleanupInternalPropertiesBeforeRouting(message);
      }


      Bindings bindings = addressManager.getBindingsForRoutingAddress(address);

      if (bindings != null)
      {
         bindings.route(message, context);
      }
      else
      {
        // this is a debug and not warn because this could be a regular scenario on publish-subscribe queues (or topic subscriptions on JMS)
        if (HornetQServerLogger.LOGGER.isDebugEnabled())
View Full Code Here
759
760
761
762
763
764
765
766
767
768
769
770
771
772
773
774
775
      // 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());

      if (bindings != null)
      {
         RoutingContext context = new RoutingContextImpl(tx);

         boolean routed = bindings.redistribute(copyRedistribute, originatingQueue, context);

         if (routed)
         {
            return new Pair<RoutingContext, ServerMessage> (context, copyRedistribute);
         }
View Full Code Here
2299
2300
2301
2302
2303
2304
2305
2306
2307
2308
2309
2310
2311
   {
      SimpleString expiryAddress = addressSettingsRepository.getMatch(address.toString()).getExpiryAddress();

      if (expiryAddress != null)
      {
         Bindings bindingList = postOffice.getBindingsForAddress(expiryAddress);

         if (bindingList.getBindings().isEmpty())
         {
            HornetQServerLogger.LOGGER.errorExpiringReferencesNoBindings(expiryAddress);
         }
         else
         {
View Full Code Here
2328
2329
2330
2331
2332
2333
2334
2335
2336
2337
2338
2339
2340
   private void sendToDeadLetterAddress(final MessageReference ref, final  SimpleString deadLetterAddress) throws Exception
   {
      if (deadLetterAddress != null)
      {
         Bindings bindingList = postOffice.getBindingsForAddress(deadLetterAddress);

         if (bindingList.getBindings().isEmpty())
         {
            HornetQServerLogger.LOGGER.messageExceededMaxDelivery(ref, deadLetterAddress);
            acknowledge(ref);
         }
         else
View Full Code Here
542
543
544
545
546
547
548
549
550
551
552
      return binding;
   }

   public Bindings getBindingsForAddress(final SimpleString address) throws Exception
   {
      Bindings bindings = addressManager.getBindingsForRoutingAddress(address);

      if (bindings == null)
      {
         bindings = createBindings(address);
      }
View Full Code Here
624
625
626
627
628
629
630
631
632
633
634
635
636
637
638
         // but we don't do it every time, otherwise it wouldn't be optimal
         cleanupInternalPropertiesBeforeRouting(message);
      }


      Bindings bindings = addressManager.getBindingsForRoutingAddress(address);

      if (bindings != null)
      {
         bindings.route(message, context);
      }
      else
      {
        // this is a debug and not warn because this could be a regular scenario on publish-subscribe queues (or topic subscriptions on JMS)
        if (HornetQServerLogger.LOGGER.isDebugEnabled())
View Full Code Here
754
755
756
757
758
759
760
761
762
763
764
765
766
767
768
769
770
      // 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());

      if (bindings != null)
      {
         RoutingContext context = new RoutingContextImpl(tx);

         boolean routed = bindings.redistribute(copyRedistribute, originatingQueue, context);

         if (routed)
         {
            return new Pair<RoutingContext, ServerMessage> (context, copyRedistribute);
         }
View Full Code Here
2017
2018
2019
2020
2021
2022
2023
2024
2025
2026
2027
2028
2029
   {
      SimpleString expiryAddress = addressSettingsRepository.getMatch(address.toString()).getExpiryAddress();

      if (expiryAddress != null)
      {
         Bindings bindingList = postOffice.getBindingsForAddress(expiryAddress);

         if (bindingList.getBindings().isEmpty())
         {
            QueueImpl.log.warn("Message has expired. No bindings for Expiry Address " + expiryAddress +
                               " so dropping it");
         }
         else
View Full Code Here
2047
2048
2049
2050
2051
2052
2053
2054
2055
2056
2057
2058
2059
  
   private void sendToDeadLetterAddress(final MessageReference ref, final  SimpleString deadLetterAddress) throws Exception
   {
      if (deadLetterAddress != null)
      {
         Bindings bindingList = postOffice.getBindingsForAddress(deadLetterAddress);

         if (bindingList.getBindings().isEmpty())
         {
            QueueImpl.log.warn("Message " + ref + " has exceeded max delivery attempts. No bindings for Dead Letter Address " + deadLetterAddress +
                               " so dropping it");
         }
         else
View Full Code Here
1443
1444
1445
1446
1447
1448
1449
1450
1451
1452
         }
         catch (Exception ignore)
         {
         }

         Bindings theBindings = postOffice.getBindingsForAddress(queueAddress);

         theBindings.setRouteWhenNoConsumers(routeWhenNoConsumers);

      }
View Full Code Here
TOP

Related Classes of org.hornetq.core.postoffice.Bindings

  • org.hornetq.api.core.SimpleString
  • org.hornetq.core.filter.Filter
  • org.hornetq.core.management.impl.AddressControlImpl
  • org.hornetq.core.postoffice.impl.PostOfficeImpl
  • org.hornetq.core.postoffice.impl.SimpleAddressManager
  • org.hornetq.core.postoffice.impl.WildcardAddressManager
  • org.hornetq.core.protocol.stomp.StompProtocolManager
  • org.hornetq.core.server.cluster.impl.ClusterConnectionImpl
  • org.hornetq.core.server.cluster.impl.ClusterConnectionImpl$MessageFlowRecordImpl
  • org.hornetq.core.server.group.impl.Proposal
    • 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.