activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Niko Zaft <niko.z...@sinnerschrader.com>
Subject Multicast within CamelContext
Date Tue, 10 Jan 2012 10:18:59 GMT
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