Skip to main content

[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index] [List Home]
[ecf-dev] New topic in forum Eclipse Communications Framework (ECF), called ApacheMQ Provider, by Robert Onslow

Title: Eclipse Community Forums
Subject: ApacheMQ Provider Author: Robert Onslow Date: Thu, 07 March 2013 13:11
Phew. Can't get ApacheMQ to work.

I start ApacheMQ 5.3.2 on localhost at 61616

Then I start ActiveMQ JMS Server from org.eclipse.ecf.provider.jms.activemq pointing at tcp://localhost:61616/uk-co-xlegal-liveshow-annotation?wireFormat.maxInactivityDuration=0&wireFormat.maxInactivityDurationInitalDelay=10000

No logging of any connection

Next I get a container and connect it - but no connection is logged at ApacheMQ, nor is any containerconnectedevent generated

I suspect that neither the server nor the client is connecting. I suspect that I am missing a step here.

Any ideas?

IContainer container = manager.getContainerFactory().createContainer("ecf.jms.activemq.tcp.client", new Object[]{"tcp://localhost:61616/uk-co-xlegal-liveshow-annotation?wireFormat.maxInactivityDuration=0", "1000000"});
final ISharedObjectContainer soc = (ISharedObjectContainer) ((IAdaptable) container).getAdapter(ISharedObjectContainer.
soc.addListener(new IContainerListener() {

  public void handleEvent(
   IContainerEvent event) {
 if (event instanceof IContainerConnectedEvent)
  try {
									ISharedObjectManager manager = soc.getSharedObjectManager();
admin = new DistributedEventAdmin(context);
ID id1 = IDFactory.getDefault().createStringID("");
Properties props = new Properties();
									props.put(EventConstants.EVENT_TOPIC, "uk_co_xlegal_xbundle3_remote");

									manager.addSharedObject(id1, (ISharedObject) admin, props);
									((DistributedEventAdmin) admin).start();
} catch (Exception e) {
									Log.log(Log.ERROR, e.getMessage());
ID targetId = IDFactory.getDefault().createID(container.getConnectNamespace(), container.getID().getName());
container.connect(targetId, null);
[ Reply ][ Quote ][ View Topic/Message ][ Unsubscribe from this forum ]

Back to the top