activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Dejan Bosanac <de...@nighttale.net>
Subject Re: Multicast within CamelContext
Date Thu, 19 Jan 2012 07:30:47 GMT
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 <niko.zaft@sinnerschrader.com>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.
>

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message