Start line:  
End line:  

Snippet Preview

Snippet HTML Code

Stack Overflow Questions
  /*
   * #%L
   * Service Locator Client for CXF
   * %%
   * Copyright (C) 2011 Talend Inc.
   * %%
   * Licensed under the Apache License, Version 2.0 (the "License");
   * you may not use this file except in compliance with the License.
   * You may obtain a copy of the License at
  * 
  *      http://www.apache.org/licenses/LICENSE-2.0
  * 
  * Unless required by applicable law or agreed to in writing, software
  * distributed under the License is distributed on an "AS IS" BASIS,
  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  * See the License for the specific language governing permissions and
  * limitations under the License.
  * #L%
  */
 package org.talend.esb.locator;
 
 import java.util.List;
 
 
 
 public class LocatorRegistrar implements ServerLifeCycleListener,
 
 	private static final Logger LOG = Logger.getLogger(LocatorRegistrar.class
 
 	private Bus bus = BusFactory.getDefaultBus();
 
 
 	private String endpointPrefix = "";
 
 	public void startServer(Server server) {
 		if (.isLoggable(.)) {
 			.log(."Server started...");
 		}
 		try {
 			registerEndpoint(server);
 		} catch (ServiceLocatorException e) {
 						"ServiceLocator Exception thrown while registering endpoint."e);
 			}
 		} catch (InterruptedException e) {
 						"Interrupted Exception thrown while registering endpoint. "e);
 			}
 		}
 	}
 
 	public void stopServer(Server server) {
 		if (.isLoggable(.)) {
 			.log(."Server stopped...");
 		}
 		try {
 		} catch (ServiceLocatorException e) {
 						"ServiceLocator Exception thrown during unregister endpoint. "e);
 			}
 		} catch (InterruptedException e) {
 						"Interrupted Exception thrown during unregister endpoint."e);
 			}
 		}
 	}
 
 	public void process(ServiceLocator lc) {
 	}
 
 	public void init() throws InterruptedExceptionServiceLocatorException {
 		if (.isLoggable(.)) {
 			.log(."Registering listener...");
 		}
			.log(."Registering available services...");
		}
	}
	public void setBus(Bus bus) {
		this. = bus;
	}
	public void setEndpointPrefix(String endpointPrefix) {
		this. = endpointPrefix!=null?endpointPrefix:"";
	}
	public void setLocatorClient(ServiceLocator locatorClient) {
		this. = locatorClient;
		locatorClient.setPostConnectAction(this);
			.log(."Locator client was set.");
		}
	}
	private void registerAvailableServers() {
		ServerRegistry serverRegistry = .getExtension(ServerRegistry.class);
		List<Serverservers = serverRegistry.getServers();
		for (Server server : servers) {
			try {
					.log(."Server available with endpoint "
				}
catch (ServiceLocatorException e) {
							"ServiceLocator Exception thrown while registering endpoint."e);
				}
catch (InterruptedException e) {
							"InterruptedException thrown while registering endpoint."e);
				}
			}
		}
	}
	private void registerListener() {
		if (manager != null) {
			manager.registerListener(this);
				.log(."Server life cycle listener registered.");
			}
		}
	}
	private void registerEndpoint(Server server)
		ServiceInfo serviceInfo = eInfo.getService();
		QName serviceName = serviceInfo.getName();
		String endpointAddress =  + eInfo.getAddress();
		.register(serviceNameendpointAddress);
	}
	private void unregisterEndpoint(Server server)
		ServiceInfo serviceInfo = eInfo.getService();
		QName serviceName = serviceInfo.getName();
		String endpointAddress =  + eInfo.getAddress();
		.unregister(serviceNameendpointAddress);
	}
New to GrepCode? Check out our FAQ X