Start line:  
End line:  

Snippet Preview

Snippet HTML Code

Stack Overflow Questions
  /*
   * #%L
   * Abstract base class for Service Locator Selection Strategy
   * %%
   * 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.servicelocator.cxf.internal;
 
 import java.util.List;
 
 
 
 public abstract class LocatorSelectionStrategy implements FailoverStrategy {
 
 	protected static final Logger LOG = Logger.getLogger(LocatorSelectionStrategy.class
 			.getName());
 	
 	
 	
 	protected Random random = new Random();
 
 	public String selectAlternateAddress(List<Stringalternates) {
 		String alternateAddress = null;
 		if (alternates != null && ! alternates.isEmpty()) {
 			int index = .nextInt(alternates.size());
 			alternateAddress = alternates.remove(index);
 		}
 		return alternateAddress;
 	}

 
 	public List<EndpointgetAlternateEndpoints(Exchange exchange) {
 		return null;
 	}

 
 	public Endpoint selectAlternateEndpoint(List<Endpointalternates) {
 		return null;
 	}

Parameters:
exchange
Returns:
 
 	abstract public String getPrimaryAddress(Exchange exchange);
 	
 	public void setMatcher(SLPropertiesMatcher propertiesMatcher) {
 	    if(propertiesMatcher != null) {
 	         = propertiesMatcher;
 	    }
 	}
 	
 	public void setServiceLocator(ServiceLocator serviceLocator) {
 		this. = serviceLocator;
 	}
 
 		return ;
 	}
 
 	protected QName getServiceName(Exchange exchange) {
 		return exchange.getEndpoint().getService().getName();
 	}
 	
 	protected List<StringgetEndpoints(QName serviceName) {
		List<Stringendpoints = Collections.emptyList();
		try {
			endpoints = .lookup(serviceName);
catch (ServiceLocatorException e) {
						"Can not refresh list of endpoints due to ServiceLocatorException"e);
			}
catch (InterruptedException e) {
						"Can not refresh list of endpoints due to InterruptedException"e);
			}
		}
		return endpoints;
	}
New to GrepCode? Check out our FAQ X