Can you create a test case and raise a Jira. That's the easiest way to test things out.
Regards -- Dejan Bosanac - http://twitter.com/dejanb ----------------- The experts in open source integration and messaging - http://fusesource.com ActiveMQ in Action - http://www.manning.com/snyder/ Blog - http://www.nighttale.net On Tue, Jan 10, 2012 at 11:18 AM, Niko Zaft <[email protected]>wrote: > Hi there, > > i am currently trying to setup an ActiveMQ (5.5.0) within a Camel-Context. > I'd like to run it with multicast within a network of Brokers. > > In the CamelContext there are two types of JmsComponents, "wmq" which > doesnt use multicast and the "amq" which is the component with multicast. > > I am facing some Problems when running this on too different machines > within the same subnet. When starting the two servers it seems that both > brokers communicate on both machines. But there is no message-exchange on > the topic both applications are registered to. Only 1 Server gets the > message. Additionally, after some hours both servers run into an instable > state. > > Please find the broker-setup, i am currently trying to get working: > > brokerName=adapter > brokerUrl=vm://adapter?create=false > brokerNetworkConnectorUrl=multicast://default?group=Development > connectorUri=tcp://localhost:61616 > connectorDiscoveryUri=multicast://default?group=Development > > @Bean(initMethod = "start", destroyMethod = "stop") > public CamelContext camelContext() throws JMSException { > CamelContext camelContext = new > SpringCamelContext(this.applicationContext); > camelContext.disableJMX(); > camelContext.addComponent("amq", > ActiveMQComponent.activeMQComponent(this.brokerUrl)); > camelContext.addComponent("wmq", > JmsComponent.jmsComponent(wmqConnectionFactory())); > ... > return camelContext; > } > > @Bean(initMethod = "start", destroyMethod = "stop") > public BrokerService broker() throws Exception { > BrokerService broker = new BrokerService(); > broker.setBrokerName(this.brokerName); > broker.setPersistent(false); > broker.setUseJmx(false); > TransportConnector connector = new TransportConnector(); > connector.setUri(new URI(this.connectorUri)); > connector.setDiscoveryUri(new URI(this.connectorDiscoveryUri)); > broker.addConnector(connector); > broker.addNetworkConnector(this.brokerNetworkConnectorUrl); > > broker.start(); return broker; > } > > > Thank you in advance for any help > > -- > Niko Zaft > > SinnerSchrader Deutschland GmbH > Völckersstraße 38, 22765 Hamburg > Amtsgericht Hamburg HRB-Nr. 63663 > Geschäftsführer: Matthias Schrader (Sprecher), Holger Blank, > Thomas Dyckhoff, Chris Wallon > Büros: Hamburg, Frankfurt am Main > > http://www.sinnerschrader.de | Creating Radical Relationships. >
