Start line:  
End line:  

Snippet Preview

Snippet HTML Code

Stack Overflow Questions
Copyright 2005-2014 Red Hat, Inc. Red Hat licenses this file to you 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 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.
package io.fabric8.camel;
The MASTER camel component ensures that only a single endpoint in a cluster is active at any point in time with all other JVMs being hot standbys which wait until the master JVM dies before taking over to provide high availability of a single consumer.
public class MasterComponent extends ZKComponentSupport {
    private String zkRoot = "/fabric/registry/camel/master";
    public String getZkRoot() {
        return ;
    public void setZkRoot(String zkRoot) {
        this. = zkRoot;
    //  Implementation methods
    protected Endpoint createEndpoint(String uriString remainingMap<StringObjectparamsthrows Exception {
        int idx = remaining.indexOf(':');
        if (idx <= 0) {
            throw new IllegalArgumentException("Missing : in URI so can't split the group name from the actual URI for '" + remaining + "'");
        // we are registering a regular endpoint
        String name = remaining.substring(0, idx);
        String childUri = remaining.substring(idx + 1);
        // we need to apply the params here
        if (params != null && params.size() > 0) {
            childUri = childUri + "?" + URISupport.createQueryString(params);
        return new MasterEndpoint(urithisnamechildUri);
    protected String getFabricPath(String name) {
        String path = name;
        if (ObjectHelper.isNotEmpty()) {
            path =  + "/" + name;
        return path;
New to GrepCode? Check out our FAQ X