Support Forums : How are NMR flows selected in FUSE ESB? ...

FuseSource is now a part of Red Hat!

For any other questions, please do not hesitate to contact Red Hat.

Forum Home » Fuse Distributions » Fuse ESB

Thread: How are NMR flows selected in FUSE ESB?

Welcome, Guest

Guest Settings

This question is not answered. Helpful answers available: 2. Correct answers available: 1.

Reply to this Thread

Search Forum

Back to Thread List

Replies: 11 - Last Post: May 25, 2008 5:22 PM Last Post By: bsnyder

tmielke

Posts: 178
Registered: 12/04/07

How are NMR flows selected in FUSE ESB?
Posted: Apr 18, 2008 2:56 PM

esb , flow , nmr , sedaflow , jcaflow , jmsflow

Looking at the default out-of-the-box FUSE ESB configuration it seems to enable SEDA, JMS and JCA flow all at the same time (inside <securedBroker> in servicemix.xml). Can someone please explain using what criteria one of these flows is selected at runtime? Is a flow selected per container or at a finer granularity, e.g. per deployment?
What happens when e.g. I run a clustered FUSE ESB environment? Is the JMS flow automatically selected? When would it switch to JCA? And finally does changing a flow require a restart?

bsnyder

Posts: 150
Registered: 08/07/07

Re: How are NMR flows selected in FUSE ESB?
Posted: Apr 18, 2008 3:50 PM

in response to: tmielke

Can someone please explain using what criteria one of these flows is selected at runtime?

Flow selection is the job of the DefaultFlowChooser.chooseFlow() method. This method delegates to each flow's canHandle() method to check various qualities of service on the exchange to determine if the flow can handle that exchange. Below are links to the canHandle() method for each flow:

Notice that each method checks the qualities of service that are applicable which is where determines of that flow can handle the exchange.

Is a flow selected per container or at a finer granularity, e.g. per deployment?

Flows are selected on a per message exchange basis and is determined by the qualities of service that required by a given exchange.

What happens when e.g. I run a clustered FUSE ESB environment? Is the JMS flow automatically selected? When would it switch to JCA?

When running multiple instances of ServiceMix, the same flow selection process described above is used. Flows are selected based on the qualities of service required by a given message exchange. E.g., if a SU deployed in one instance of ServiceMix needs to send a message to a SU deployed in a different instance of ServiceMix, that remoteness is a quality of service that can only be handled by the JMS flow or the JCA flow.

There is a mapping of qualities of service to flows available in the ServiceMix docs here:

http://servicemix.apache.org/transactions.html

There's also a whole bunch of new info about clustering available in the ServiceMix docs here:

http://servicemix.apache.org/clustering.html

And finally does changing a flow require a restart?

If you change the configuration of a flow in the servicemix.xml, the ServiceMix container needs to be restarted.

martinmurphy

Posts: 92
Registered: 12/05/07

Re: How are NMR flows selected in FUSE ESB?
Posted: Apr 18, 2008 3:58 PM

in response to: bsnyder

Oops, too quick for me Bruce. I was writing the response while you were posting this more detailed response

martinmurphy

Posts: 92
Registered: 12/05/07

Re: How are NMR flows selected in FUSE ESB?
Posted: Apr 18, 2008 3:57 PM

in response to: tmielke

Basically a chooseFlow method is called that checks if a flow is set on the message exchange, if a flow isn't set then it will go through its list of flows (SEDA, JMS and JCA by default) and check to see if it can handle the message exchange. For example the SEDA Flow can't handle clustered messages.

pdmackinnon

Posts: 13
Registered: 09/13/07

Re: How are NMR flows selected in FUSE ESB?
Posted: Apr 29, 2008 3:54 PM

in response to: martinmurphy

So is the order of selection determined by the order that these flows are specified in the servicemix.xml config? Or are you saying that the default order (SEDA, JMS and JCA) is hardcoded somewhere? I'm trying to understand how ServiceMix selects a flow when multiple configured flows all satisfy the QoS requirements.

bsnyder

Posts: 150
Registered: 08/07/07

Re: How are NMR flows selected in FUSE ESB?
Posted: Apr 29, 2008 11:03 PM

in response to: pdmackinnon

No, the ordering in the servicemix.xml has nothing to do with it. The order is determined simply by the nearest first, i.e., a local flow is selected before a remote flow.

Bruce

roger

Posts: 48
Registered: 04/23/08

Re: How are NMR flows selected in FUSE ESB?
Posted: May 21, 2008 1:12 PM

in response to: bsnyder

servicemix , activemq , flow , flow_type

OK, just to assure that I've understood you right:

Question 1: Even though I configure my container to use the JMS flow (by setting the flowType attribute to for example jms://tcp:61363 or similar), it might happen that ServiceMix decideds to use for example SEDA for transport between two components if they happen reside in the same VM?

Question 2: If I want to enable journaled JMS (perhaps to an external database), thus logging all message exchanges on the NMR, would this mean that I will miss the messages not transported by ActiveMQ/JMS?

Regards,
Roger

bsnyder

Posts: 150
Registered: 08/07/07

Re: How are NMR flows selected in FUSE ESB?
Posted: May 21, 2008 5:09 PM

in response to: roger

Question 1: Even though I configure my container to use the JMS flow (by setting the flowType attribute to for example jms://tcp:61363 or similar), it might happen that ServiceMix decideds to use for example SEDA for transport between two components if they happen reside in the same VM?

If the components have the same service name and endpoint, then yes.

Question 2: If I want to enable journaled JMS (perhaps to an external database), thus logging all message exchanges on the NMR, would this mean that I will miss the messages not transported by ActiveMQ/JMS?

I'm sorry I don't understand your question. To what are you referring when you say, '... messages not transported by ActiveMQ/JMS?'

Bruce

roger

Posts: 48
Registered: 04/23/08

Re: How are NMR flows selected in FUSE ESB?
Posted: May 21, 2008 6:18 PM

in response to: bsnyder

servicemix , activemq , flow

Hi again,

What I meant was those messages not transported by JMS, i.e. those transported locally one the NMR (using SEDA). I assume these messages won't be processed and journaled by the ActiveMQ instance?

Regards,
Roger

bsnyder

Posts: 150
Registered: 08/07/07

Re: How are NMR flows selected in FUSE ESB?
Posted: May 22, 2008 3:39 PM

in response to: roger

Yes, that's correct. The SEDA flow uses java.util.concurrent queues for management of the normalized messages. This has nothing to do with ActiveMQ or JMS.

Bruce

martinmurphy

Posts: 92
Registered: 12/05/07

Re: How are NMR flows selected in FUSE ESB?
Posted: May 22, 2008 4:15 PM

in response to: bsnyder

fuse , jms , esb , configuration , servicemix , nmr

I'm pretty sure that you can get local flows to use JMS queues as well though if you don't make the SEDA flow available to the broker (NMR). For example if I have config like this :

<sm:broker>
      <sm:securedBroker authorizationMap="#authorizationMap">
        <sm:flows>
          <sm:jmsFlow jmsURL="${activemq.url}" />
        </sm:flows>
      </sm:securedBroker>
    </sm:broker>

Then the JMS flow would be used for messages since it will be able to satisify all the properties that the SEDA flow could. I haven't tested this though, so correct me if I'm wrong Bruce. This might be useful to persist your messages between components.

bsnyder

Posts: 150
Registered: 08/07/07

Re: How are NMR flows selected in FUSE ESB?
Posted: May 25, 2008 5:22 PM

in response to: martinmurphy

Yes, that's true, but I'd recommend using the vm protocol instead of the tcp protocol (in the servicemix.properties file) in order to avoid the overhead of the TCP/IP stack on a single machine.

Bruce

Back to Thread List

FUSE Open Source Community is a community resource for open source service oriented architecture (SOA) and application integration products and technologies. FUSE offers products based on Apache ServiceMix, Apache ActiveMQ, Apache CXF and Apache Camel which are certified, productized and fully supported by the people who wrote the code. Learn about ActiveMQ with our training, support, and consulting on ActiveMQ performance. FUSE also offers integration software that allows developers to service-enable existing components or build new services with preconfigured enterprise integration patterns. FUSE ESB 4 for enterprise service bus is an open source integration platform for BPEL components that supports the latest emerging standards like OSGi and JBI 2.0. FUSE Services Framework allows Java developers to create reusable RESTful services using front-end programming APIs like JAX-WS. Our powerful message oriented middleware solution, FUSE Message Broker, offers a cost-effective and flexible open source messaging platform. FUSE also works to enhance your SOA using content based routing with FUSE Mediation Router.