// Path: src/main/java/org/bygle/endpoint/managing/EndPointManagerInterface.java
// public interface EndPointManagerInterface {
// 
// 	public void publishRecord(byte[] rdf, String rdfAbout, String host) throws Exception;
// 
// 	public void dePublishRecord(byte[] rdf, String rdfAbout, String host) throws Exception;
// 
// 	public void rePublishRecord(byte[] rdf, String rdfAbout, String host) throws Exception;
// 
// 	public ResponseEntity<?> query(String defaultGraphUri, String sparqlQuery, int outputFormat) throws Exception;
// 
// 	public void executeImport() throws Exception;
// 
// 	public void executePublishing() throws Exception;
// 
// 	public void resetEndpoint() throws Exception;
// 
// 	public void dropEndpoint() throws Exception;
// 
// }
// 
// Path: src/main/java/org/bygle/endpoint/managing/EndPointManagerProvider.java
// @Service("endPointManagerProvider")
// public class EndPointManagerProvider {
// 	@Autowired
// 	@Qualifier("endPointManager")
// 	private  EndPointManager endPointManager ;
// 
// 	public EndPointManager getEndPointManager() {
// 		return endPointManager;
// 	}
// 	public void setEndPointManager(EndPointManager endPointManager) {
// 		this.endPointManager = endPointManager;
// 	}
// }


import org.bygle.endpoint.managing.EndPointManagerInterface;
import org.bygle.endpoint.managing.EndPointManagerProvider;
import org.springframework.stereotype.Component;
package org.bygle.scheduler;


@Component("endpointPublisher")
public class EndpointPublisher {
	EndPointManagerProvider endPointManagerProvider;
	private boolean isRunnig = false;
	public EndpointPublisher() {
	}
	public void executePublishing() {
        try {
        	System.out.println("executePublishing");
        	if(isRunnig==false){
	    		isRunnig = true;
				EndPointManagerInterface endPointManager = endPointManagerProvider.getEndPointManager();
				endPointManager.executePublishing();
				isRunnig = false;
        	}
		} catch (Exception e) {
			e.printStackTrace();
			isRunnig = false;
		}
    }
// Path: src/main/java/org/bygle/endpoint/managing/EndPointManagerInterface.java
// public interface EndPointManagerInterface {
// 
// 	public void publishRecord(byte[] rdf, String rdfAbout, String host) throws Exception;
// 
// 	public void dePublishRecord(byte[] rdf, String rdfAbout, String host) throws Exception;
// 
// 	public void rePublishRecord(byte[] rdf, String rdfAbout, String host) throws Exception;
// 
// 	public ResponseEntity<?> query(String defaultGraphUri, String sparqlQuery, int outputFormat) throws Exception;
// 
// 	public void executeImport() throws Exception;
// 
// 	public void executePublishing() throws Exception;
// 
// 	public void resetEndpoint() throws Exception;
// 
// 	public void dropEndpoint() throws Exception;
// 
// }
// 
// Path: src/main/java/org/bygle/endpoint/managing/EndPointManagerProvider.java
// @Service("endPointManagerProvider")
// public class EndPointManagerProvider {
// 	@Autowired
// 	@Qualifier("endPointManager")
// 	private  EndPointManager endPointManager ;
// 
// 	public EndPointManager getEndPointManager() {
// 		return endPointManager;
// 	}
// 	public void setEndPointManager(EndPointManager endPointManager) {
// 		this.endPointManager = endPointManager;
// 	}
// }


// Path: src/main/java/org/bygle/scheduler/EndpointPublisher.java
import org.bygle.endpoint.managing.EndPointManagerInterface;
import org.bygle.endpoint.managing.EndPointManagerProvider;
import org.springframework.stereotype.Component;

package org.bygle.scheduler;


@Component("endpointPublisher")
public class EndpointPublisher {
	EndPointManagerProvider endPointManagerProvider;
	private boolean isRunnig = false;
	public EndpointPublisher() {
	}
	public void executePublishing() {
        try {
        	System.out.println("executePublishing");
        	if(isRunnig==false){
	    		isRunnig = true;
				EndPointManagerInterface endPointManager = endPointManagerProvider.getEndPointManager();
				endPointManager.executePublishing();
				isRunnig = false;
        	}
		} catch (Exception e) {
			e.printStackTrace();
			isRunnig = false;
		}
    }
	public void setEndPointManagerProvider(EndPointManagerProvider endPointManagerProvider) {