MQQueueConnectionFactory cf = new MQQueueConnectionFactory(); JmsConfiguration jc = new JmsConfiguration(cf); cf.setHostName("172.16.16.136"); cf.setPort(1416); cf.setQueueManager("QM2"); cf.setChannel("BTOA"); cf.setTransportType(1); JmsComponent ibmmq = new JmsComponent(jc); ibmmq.setAcknowledgementModeName("AUTO_ACKNOWLEDGE"); CamelContext camel = new DefaultCamelContext(); camel.addComponent("ibmmq", ibmmq); camel.addRoutes(new RouteBuilder() { public void configure() { from("direct:test").to("ibmmq:QRB"); } }); Endpoint endpoint = camel.getEndpoint("direct:test"); Exchange exchange = endpoint.createExchange(); String data = "send something"; Producer producer = endpoint.createProducer(); exchange.getIn().setBody(data); producer.process(exchange); System.out.println(new String((byte[])exchange.getOut().getBody()));
Exception in thread "main" org.apache.camel.CamelExchangeException: No consumers available on endpoint: Endpoint[direct://test]. Exchange[Message: send something] at org.apache.camel.component.direct.DirectProducer.process(DirectProducer.java:46) at com.sunyard.camel.TestJmsComponent.main(TestJmsComponent.java:51) where is wrong in my program? -- View this message in context: http://camel.465427.n5.nabble.com/No-consumers-available-on-endpoint-exception-tp5076708p5076708.html Sent from the Camel - Users mailing list archive at Nabble.com.