List of route() Examples

Examples of route()

com.alibaba.dubbo.rpc.cluster.Router.route()
route. @param invokers @param url refer url @param invocation @return routed invokers @throws RpcException
diva.canvas.connector.Connector.route()
Tell the connector to route itself completely, using all available information. Repaint the figure.
org.apache.qpid.server.exchange.Exchange.route()
Returns a list of queues to which to route this message. If there are no queues the empty list must be returned. @return list of queues to which to route the message.
org.apache.qpid.server.protocol.v0_8.IncomingMessage.route()
org.apache.qpid.server.queue.IncomingMessage.route()
org.apache.servicemix.drools.model.JbiHelper.route()
Forwards the inbound message to the given @param uri @param localPart
org.hornetq.core.postoffice.Binding.route()
org.hornetq.core.postoffice.Bindings.route()
org.hornetq.core.postoffice.impl.BindingsImpl.route()
org.jboss.messaging.core.contract.PostOffice.route()
Route a reference. @param condition - the message will be routed to queue(s) if the specified condition matches thecondition of the bindings. @param tx - the transaction or null if not in the context of a transaction. @return true if reference was accepted by at least one queue.
org.jboss.messaging.core.plugin.contract.ClusteredPostOffice.route()
org.jboss.messaging.core.plugin.contract.PostOffice.route()
Route a reference. @param condition - the message will be routed to a queue if specified condition matches thecondition of the binding. @param tx - the transaction or null if not in the context of a transaction. @return true if reference was accepted by at least one queue.
org.jboss.soa.esb.actions.cbr.RegexRouter.route()
org.jboss.soa.esb.actions.cbr.SxcXPathRouter.route()
org.jboss.soa.esb.actions.cbr.XPathRouter.route()
org.jivesoftware.openfire.IQRouter.route()

Performs the actual packet routing.

You routing is considered 'quick' and implementations may not take excessive amounts of time to complete the routing. If routing will take a long amount of time, the actual routing should be done in another thread so this method returns quickly.

Warning

Be careful to enforce concurrency DbC of concurrent by synchronizing any accesses to class resources.
@param packet The packet to route @throws NullPointerException If the packet is null
org.jivesoftware.openfire.PacketRouter.route()
Routes the given packet based on its type. @param packet The packet to route.
org.jivesoftware.openfire.SessionPacketRouter.route()
org.mule.module.xml.routing.XmlMessageSplitter.route()
org.mule.routing.outbound.MulticastingRouter.route()
org.opentripplanner.profile.ProfileRouter.route()
org.slim3.controller.router.Router.route()
Routes the path. @param request the request @param path the path @return a routed path @throws NullPointerException if the request parameter is null or if the path parameter is null

Examples of org.hornetq.core.postoffice.Binding.route()


               Binding theBinding = getNextBinding(message, routingName, bindings);


               if (theBinding != null)
               {
                  theBinding.route(message, context);
               }
            }
         }
      }
   }

View Full Code Here

Examples of org.hornetq.core.postoffice.Binding.route()

            }


            // and let's route it
            if (theBinding != null)
            {
               theBinding.route(message, context);
            }
            else
            {
               throw HornetQMessageBundle.BUNDLE.groupingQueueRemoved(resp.getChosenClusterName());
            }

View Full Code Here

Examples of org.hornetq.core.postoffice.Binding.route()

                  break;
               }
            }
            if (chosen != null)
            {
               chosen.route(message, context);
            }
            else
            {
               throw HornetQMessageBundle.BUNDLE.groupingQueueRemoved(resp.getChosenClusterName());
            }

View Full Code Here

Examples of org.hornetq.core.postoffice.Binding.route()


         Binding binding = bindingsMap.get(bindingID);


         if (binding != null)
         {
            binding.route(message, context);
         }
         else
         {
            HornetQServerLogger.LOGGER.warn("Couldn't find binding with id=" + bindingID + " on routeFromCluster for message=" + message + " binding = " + this);
         }

View Full Code Here

Examples of org.hornetq.core.postoffice.Bindings.route()


      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 (log.isDebugEnabled())

View Full Code Here

Examples of org.hornetq.core.postoffice.Bindings.route()


      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 (log.isDebugEnabled())

View Full Code Here

Examples of org.hornetq.core.postoffice.Bindings.route()


      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

Examples of org.hornetq.core.postoffice.Bindings.route()


      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

Examples of org.hornetq.core.postoffice.Bindings.route()


      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

Examples of org.hornetq.core.postoffice.impl.BindingsImpl.route()


      for (int i = 0; i < 100; i++)
      {
         if (route)
         {
            bind.route(new ServerMessageImpl(i, 100), new RoutingContextImpl(new FakeTransaction()));
         }
         else
         {
            bind.redistribute(new ServerMessageImpl(i, 100), queue, new RoutingContextImpl(new FakeTransaction()));
         }

View Full Code Here

0 1 2 3 4 5 6

TOP

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.

Examples of route()

Warning

Examples of org.hornetq.core.postoffice.Binding.route()

Examples of org.hornetq.core.postoffice.Binding.route()

Examples of org.hornetq.core.postoffice.Binding.route()

Examples of org.hornetq.core.postoffice.Binding.route()

Examples of org.hornetq.core.postoffice.Bindings.route()

Examples of org.hornetq.core.postoffice.Bindings.route()

Examples of org.hornetq.core.postoffice.Bindings.route()

Examples of org.hornetq.core.postoffice.Bindings.route()

Examples of org.hornetq.core.postoffice.Bindings.route()

Examples of org.hornetq.core.postoffice.impl.BindingsImpl.route()