Package org.hornetq.core.postoffice

Examples of org.hornetq.core.postoffice.Bindings

1566
1567
1568
1569
1570
1571
1572
1573
1574
1575
1576
1577
1578
   {
      SimpleString deadLetterAddress = addressSettingsRepository.getMatch(address.toString()).getDeadLetterAddress();

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

         if (bindingList.getBindings().isEmpty())
         {
            QueueImpl.log.warn("Message has exceeded max delivery attempts. No bindings for Dead Letter Address " + deadLetterAddress +
                               " so dropping it");
         }
         else
View Full Code Here
1329
1330
1331
1332
1333
1334
1335
1336
1337
1338
         }
         catch (Exception ignore)
         {
         }

         Bindings theBindings = postOffice.getBindingsForAddress(queueAddress);

         theBindings.setRouteWhenNoConsumers(routeWhenNoConsumers);

      }
View Full Code Here
608
609
610
611
612
613
614
615
616
617
618
619
620
      if (address.equals(managementAddress))
      {
         return new BindingQueryResult(true, names);
      }

      Bindings bindings = postOffice.getMatchingBindings(address);

      for (Binding binding : bindings.getBindings())
      {
         if (binding.getType() == BindingType.LOCAL_QUEUE || binding.getType() == BindingType.REMOTE_QUEUE)
         {
            names.add(binding.getUniqueName());
         }
View Full Code Here
83
84
85
86
87
88
89
90
91
92
93
94
95
   public String[] getQueueNames() throws Exception
   {
      clearIO();
      try
      {
         Bindings bindings = postOffice.getBindingsForAddress(address);
         List<String> queueNames = new ArrayList<String>();
         for (Binding binding : bindings.getBindings())
         {
            if (binding instanceof QueueBinding)
            {
               queueNames.add(binding.getUniqueName().toString());
            }
View Full Code Here
109
110
111
112
113
114
115
116
117
118
119
120
121
122
   public String[] getBindingNames() throws Exception
   {
      clearIO();
      try
      {
         Bindings bindings = postOffice.getBindingsForAddress(address);
         String[] bindingNames = new String[bindings.getBindings().size()];
         int i = 0;
         for (Binding binding : bindings.getBindings())
         {
               bindingNames[i++] = binding.getUniqueName().toString();
         }
         return bindingNames;
      }
View Full Code Here
209
210
211
212
213
214
215
216
217
218
219
220
221
   {
      clearIO();
      long totalMsgs = 0;
      try
      {
         Bindings bindings = postOffice.getBindingsForAddress(address);
         List<String> queueNames = new ArrayList<String>();
         for (Binding binding : bindings.getBindings())
         {
            if (binding instanceof QueueBinding)
            {
               totalMsgs += ((QueueBinding) binding).getQueue().getMessageCount();
            }
View Full Code Here
607
608
609
610
611
612
613
614
615
616
617
618
619
      if (address.equals(managementAddress))
      {
         return new BindingQueryResult(true, names);
      }

      Bindings bindings = postOffice.getMatchingBindings(address);

      for (Binding binding : bindings.getBindings())
      {
         if (binding.getType() == BindingType.LOCAL_QUEUE || binding.getType() == BindingType.REMOTE_QUEUE)
         {
            names.add(binding.getUniqueName());
         }
View Full Code Here
2300
2301
2302
2303
2304
2305
2306
2307
2308
2309
2310
2311
2312
   {
      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
2329
2330
2331
2332
2333
2334
2335
2336
2337
2338
2339
2340
2341
   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
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.