Examples of org.hornetq.core.postoffice.Binding

org.hornetq.core.postoffice.Binding
A Binding @author Tim Fox

         return;
      }


      Transformer transformer = instantiateTransformer(config.getTransformerClassName());


      Binding binding = postOffice.getBinding(new SimpleString(config.getQueueName()));


      if (binding == null)
      {
         ClusterManagerImpl.log.warn("No queue found with name " + config.getQueueName() +
                                     " bridge will not be deployed.");


         return;
      }


      Queue queue = (Queue)binding.getBindable();


      ServerLocatorInternal serverLocator;


      if (config.getDiscoveryGroupName() != null)
      {

View Full Code Here

      return createQueue(address, queueName, filterString, durable, temporary, false);
   }


   public Queue locateQueue(SimpleString queueName) throws Exception
   {
      Binding binding = postOffice.getBinding(queueName);


      if (binding == null)
      {
         return null;
      }


      Bindable queue = binding.getBindable();


      if (!(queue instanceof Queue))
      {
         throw new IllegalStateException("locateQueue should only be used to locate queues");
      }


      return (Queue)binding.getBindable();
   }

View Full Code Here


   public void destroyQueue(final SimpleString queueName, final ServerSession session) throws Exception
   {
      addressSettingsRepository.clearCache();


      Binding binding = postOffice.getBinding(queueName);


      if (binding == null)
      {
         throw new HornetQException(HornetQException.QUEUE_DOES_NOT_EXIST, "No such queue " + queueName);
      }


      Queue queue = (Queue)binding.getBindable();


      if (queue.getPageSubscription() != null)
      {
         queue.getPageSubscription().close();
      }


      if (queue.getConsumerCount() != 0)
      {
         throw new HornetQException(HornetQException.ILLEGAL_STATE, "Cannot delete queue " + queue.getName() +
                                                                    " on binding " +
                                                                    queueName +
                                                                    " - it has consumers = " +
                                                                    binding.getClass().getName());
      }


      if (session != null)
      {
         if (queue.isDurable())
         {
            // make sure the user has privileges to delete this queue
            securityStore.check(binding.getAddress(), CheckType.DELETE_DURABLE_QUEUE, session);
         }
         else
         {
            securityStore.check(binding.getAddress(), CheckType.DELETE_NON_DURABLE_QUEUE, session);
         }
      }


      queue.deleteAllReferences();

View Full Code Here

                                     filter,
                                     transformer,
                                     postOffice,
                                     storageManager);


      Binding binding = new DivertBinding(storageManager.generateUniqueID(), sAddress, divert);


      postOffice.addBinding(binding);


      managementService.registerDivert(divert, config);
   }

View Full Code Here

      managementService.registerDivert(divert, config);
   }


   public void destroyDivert(SimpleString name) throws Exception
   {
      Binding binding = postOffice.getBinding(name);
      if (binding == null)
      {
         throw new HornetQException(HornetQException.INTERNAL_ERROR, "No binding for divert " + name);
      }
      if (!(binding instanceof DivertBinding))

View Full Code Here

                                                   filter,
                                                   subscription,
                                                   true,
                                                   false);


            Binding binding = new LocalQueueBinding(queueBindingInfo.getAddress(), queue, nodeManager.getNodeId());


            queues.put(queueBindingInfo.getId(), queue);


            postOffice.addBinding(binding);

View Full Code Here

                  if (queueName == null)
                  {
                     throw new IllegalStateException("No queue name");
                  }


                  Binding binding = getBinding(queueName);


                  if (binding != null)
                  {
                     // We have a local queue
                     Queue queue = (Queue)binding.getBindable();


                     AddressSettings addressSettings = addressSettingsRepository.getMatch(binding.getAddress()
                                                                                                 .toString());


                     long redistributionDelay = addressSettings.getRedistributionDelay();


                     if (redistributionDelay != -1)
                     {
                        queue.addRedistributor(redistributionDelay);
                     }
                  }
               }


               break;
            }
            case CONSUMER_CLOSED:
            {
               TypedProperties props = notification.getProperties();


               SimpleString clusterName = props.getSimpleStringProperty(ManagementHelper.HDR_CLUSTER_NAME);


               if (clusterName == null)
               {
                  throw new IllegalStateException("No cluster name");
               }


               SimpleString filterString = props.getSimpleStringProperty(ManagementHelper.HDR_FILTERSTRING);


               QueueInfo info = queueInfos.get(clusterName);


               if (info == null)
               {
                  return;
               }


               info.decrementConsumers();


               if (filterString != null)
               {
                  List<SimpleString> filterStrings = info.getFilterStrings();


                  filterStrings.remove(filterString);
               }


               if (info.getNumberOfConsumers() == 0)
               {
                  if (!props.containsProperty(ManagementHelper.HDR_DISTANCE))
                  {
                     throw new IllegalStateException("No cluster name");
                  }


                  int distance = props.getIntProperty(ManagementHelper.HDR_DISTANCE);


                  if (distance == 0)
                  {
                     SimpleString queueName = props.getSimpleStringProperty(ManagementHelper.HDR_ROUTING_NAME);


                     if (queueName == null)
                     {
                        throw new IllegalStateException("No queue name");
                     }


                     Binding binding = getBinding(queueName);


                     if (binding == null)
                     {
                        throw new IllegalStateException("No queue " + queueName);
                     }


                     Queue queue = (Queue)binding.getBindable();


                     AddressSettings addressSettings = addressSettingsRepository.getMatch(binding.getAddress()
                                                                                                 .toString());


                     long redistributionDelay = addressSettings.getRedistributionDelay();


                     if (redistributionDelay != -1)

View Full Code Here

   public synchronized Binding removeBinding(final SimpleString uniqueName) throws Exception
   {


      addressSettingsRepository.clearCache();


      Binding binding = addressManager.removeBinding(uniqueName);


      if (binding == null)
      {
         throw new HornetQException(HornetQException.QUEUE_DOES_NOT_EXIST);
      }


      if (addressManager.getBindingsForRoutingAddress(binding.getAddress()) == null)
      {
         pagingManager.deletePageStore(binding.getAddress());


         managementService.unregisterAddress(binding.getAddress());
      }


      if (binding.getType() == BindingType.LOCAL_QUEUE)
      {
         managementService.unregisterQueue(uniqueName, binding.getAddress());
      }
      else if (binding.getType() == BindingType.DIVERT)
      {
         managementService.unregisterDivert(uniqueName);
      }


      if (binding.getType() != BindingType.DIVERT)
      {
         TypedProperties props = new TypedProperties();


         props.putSimpleStringProperty(ManagementHelper.HDR_ADDRESS, binding.getAddress());


         props.putSimpleStringProperty(ManagementHelper.HDR_CLUSTER_NAME, binding.getClusterName());


         props.putSimpleStringProperty(ManagementHelper.HDR_ROUTING_NAME, binding.getRoutingName());


         props.putIntProperty(ManagementHelper.HDR_DISTANCE, binding.getDistance());


         managementService.sendNotification(new Notification(null, NotificationType.BINDING_REMOVED, props));
      }


      binding.close();


      return binding;
   }

View Full Code Here

   public void sendQueueInfoToQueue(final SimpleString queueName, final SimpleString address) throws Exception
   {
      // We send direct to the queue so we can send it to the same queue that is bound to the notifications adress -
      // this is crucial for ensuring
      // that queue infos and notifications are received in a contiguous consistent stream
      Binding binding = addressManager.getBinding(queueName);


      if (binding == null)
      {
         throw new IllegalStateException("Cannot find queue " + queueName);
      }
      
      if (log.isDebugEnabled())
      {
         log.debug("PostOffice.sendQueueInfoToQueue on server=" + this.server + ", queueName=" + queueName + " and address=" + address);
      }


      Queue queue = (Queue)binding.getBindable();


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

View Full Code Here


               // New node - create a new flow record


               final SimpleString queueName = new SimpleString("sf." + name + "." + nodeID);


               Binding queueBinding = postOffice.getBinding(queueName);


               Queue queue;


               if (queueBinding != null)
               {
                  queue = (Queue)queueBinding.getBindable();
               }
               else
               {
                  // Add binding in storage so the queue will get reloaded on startup and we can find it - it's never
                  // actually routed to at that address though

View Full Code Here

0 1 2 3 4 5 6 7 8 9

TOP

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

org.hornetq.core.management.impl.QueueControlImpl

org.hornetq.core.postoffice.impl.BindingsImpl

org.hornetq.core.postoffice.impl.PostOfficeImpl

org.hornetq.core.postoffice.impl.SimpleAddressManager

org.hornetq.core.postoffice.impl.WildcardAddressManager

org.hornetq.core.server.cluster.ClusterManager

org.hornetq.core.server.cluster.impl.ClusterConnectionImpl

org.hornetq.core.server.cluster.impl.ClusterManagerImpl

org.hornetq.core.server.impl.HornetQServerImpl

org.hornetq.core.server.impl.PostOfficeJournalLoader

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.