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() {

 @Override
  public void handleEvent(
   IContainerEvent event) {
							         System.out.println(event.getClass().getName());
 if (event instanceof IContainerConnectedEvent)
  try {
									
									ISharedObjectManager manager = soc.getSharedObjectManager();
admin = new DistributedEventAdmin(context);
ID id1 = IDFactory.getDefault().createStringID("uk.co.xlegal.xbundle3.remote");
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);