Package org.apache.servicemix.jbi.nmr.flow

Examples of org.apache.servicemix.jbi.nmr.flow.Flow

274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
        boolean foundRoute = false;
        // If we found a destination, or this is a reply
        if (exchange.getEndpoint() != null || exchange.getRole() == Role.CONSUMER) {
            foundRoute = true;
            Flow flow = defaultFlowChooser.chooseFlow(flows, exchange);
            if (flow == null) {
                throw new MessagingException("Unable to choose a flow for exchange: " + exchange);
            }
            flow.send(exchange);
        }

        if (exchange.getRole() == Role.PROVIDER) {
            getSubscriptionManager().dispatchToSubscribers(exchange);
        }
View Full Code Here
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
        boolean foundRoute = false;
        // If we found a destination, or this is a reply
        if (exchange.getEndpoint() != null || exchange.getRole() == Role.CONSUMER) {
            foundRoute = true;
            Flow flow = defaultFlowChooser.chooseFlow(flows, exchange);
            if (flow == null) {
                throw new MessagingException("Unable to choose a flow for exchange: " + exchange);
            }
            flow.send(exchange);
        }

        if (exchange.getRole() == Role.PROVIDER) {
          getSubscriptionManager().dispatchToSubscribers(exchange);
        }
View Full Code Here
200
201
202
203
204
205
206
207
208
209
210
        Set<AbstractName> listGBeans = kernel.listGBeans(flows);
        for (AbstractName name: listGBeans) {
            if (!kernel.isRunning(name)) {
                kernel.startGBean(name);
            }
            Flow flow = (Flow) kernel.getGBean(name);
            flowSet.add(flow);
        }
       
        return flowSet.toArray(new Flow[0]);
    }
View Full Code Here
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
        boolean foundRoute = false;
        // If we found a destination, or this is a reply
        if (exchange.getEndpoint() != null || exchange.getRole() == Role.CONSUMER) {
            foundRoute = true;
            Flow flow = defaultFlowChooser.chooseFlow(flows, exchange);
            if (flow == null) {
                throw new MessagingException("Unable to choose a flow for exchange: " + exchange);
            }
            flow.send(exchange);
        }

        if (exchange.getRole() == Role.PROVIDER) {
            getSubscriptionManager().dispatchToSubscribers(exchange);
        }
View Full Code Here
208
209
210
211
212
213
214
215
216
217
218
        Set<AbstractName> listGBeans = kernel.listGBeans(flows);
        for (AbstractName name: listGBeans) {
            if (!kernel.isRunning(name)) {
                kernel.startGBean(name);
            }
            Flow flow = (Flow) kernel.getGBean(name);
            flowSet.add(flow);
        }
       
        return flowSet.toArray(new Flow[0]);
    }
View Full Code Here
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
        boolean foundRoute = false;
        // If we found a destination, or this is a reply
        if (exchange.getEndpoint() != null || exchange.getRole() == Role.CONSUMER) {
            foundRoute = true;
            Flow flow = defaultFlowChooser.chooseFlow(flows, exchange);
            if (flow == null) {
                throw new MessagingException("Unable to choose a flow for exchange: " + exchange);
            }
            flow.send(exchange);
        }

        if (exchange.getRole() == Role.PROVIDER) {
            getSubscriptionManager().dispatchToSubscribers(exchange);
        }
View Full Code Here
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
        boolean foundRoute = false;
        // If we found a destination, or this is a reply
        if (exchange.getEndpoint() != null || exchange.getRole() == Role.CONSUMER) {
            foundRoute = true;
            Flow flow = defaultFlowChooser.chooseFlow(flows, exchange);
            if (flow == null) {
                throw new MessagingException("Unable to choose a flow for exchange: " + exchange);
            }
            flow.send(exchange);
        }

        if (exchange.getRole() == Role.PROVIDER) {
          getSubscriptionManager().dispatchToSubscribers(exchange);
        }
View Full Code Here
35
36
37
38
39
40
41
42
43
44
45
        assertTrue(FlowProvider.getQuery(nameAndQuery).equals(query));
      
    }
   
    public void testGetFlows() throws Exception{
        Flow flow = FlowProvider.getFlow("st");
        assertTrue(flow instanceof STFlow);
        flow = FlowProvider.getFlow("seda");
        assertTrue(flow instanceof SedaFlow);
        flow = FlowProvider.getFlow("jms");
        assertTrue(flow instanceof JMSFlow);
View Full Code Here
47
48
49
50
51
52
53
54
55
56
        assertTrue(flow instanceof JMSFlow);
    }
   
    public void testSetProperties() throws Exception {
        String jmsURL = "reliable://tcp://fred:666";
        Flow flow = FlowProvider.getFlow("jms?jmsURL="+jmsURL);
        assertTrue(flow instanceof JMSFlow);
        JMSFlow jmsFlow = (JMSFlow)flow;
        assertTrue(jmsFlow.getJmsURL().equals(jmsURL));
    }
View Full Code Here
TOP

Related Classes of org.apache.servicemix.jbi.nmr.flow.Flow

  • org.apache.servicemix.geronimo.ServiceMixGBean
  • org.apache.servicemix.jbi.nmr.DefaultBroker
  • org.apache.servicemix.jbi.nmr.flow.FlowProviderTest
    • 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.