/*
 * Licensed to the Apache Software Foundation (ASF) under one
 * or more contributor license agreements.  See the NOTICE file
 * distributed with this work for additional information
 * regarding copyright ownership.  The ASF 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
 * 
 *   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.
 */

package org.apache.uima.aae.controller;

import org.apache.uima.aae.error.AsynchAEException;
import org.apache.uima.aae.jmx.ServiceInfo;

public interface Endpoint {
  public static final int OK = 1;

  public static final int FAILED = 2;

  public static final int DISABLED = 3;

  public int getMetadataRequestTimeout();

  public void setController(AnalysisEngineController aController);

  public void startCheckpointTimer();

  public long getCheckpointTimer();

  public boolean isRetryEnabled();

  public void setMetadataRequestTimeout(int metadataRequestTimeout);

  public int getProcessRequestTimeout();

  public void setReplyEndpoint(boolean tORf);

  public boolean isReplyEndpoint();

  public void setProcessRequestTimeout(int processRequestTimeout);

  public boolean completedProcessingCollection();

  public void setCompletedProcessingCollection(boolean completed);

  public void setNoConsumers(boolean trueOrFalse);

  public boolean hasNoConsumers();

  public boolean isInitialized();

  public void setInitialized(boolean initialized);

  public String getEndpoint();

  public boolean isFinal();

  public void setFinal(boolean isFinal);

  public long getEntryTime();

  public void setEndpoint(String endpoint);

  public String getServerURI();

  public void setServerURI(String serverURI);

  public void startMetadataRequestTimer();

  public void startCollectionProcessCompleteTimer();

  public void startProcessRequestTimer(String aCasReferenceId);

  public void cancelTimer();

  public boolean isWaitingForResponse();

  public void setWaitingForResponse(boolean isWaiting);

  public void initialize() throws AsynchAEException;

  public void setDescriptor(String aDescriptor);

  public String getDescriptor();

  public void setRemote(boolean aRemote);

  public String getReplyToEndpoint();

  public boolean isRemote();

  public String getSerializer();

  public void close();

  public boolean isOpen();

  public void setHighWaterMark(String aHighWaterMark);

  public String getHighWaterMark();

  public boolean remove();

  public void setRemove(boolean removeIt);

  public boolean isCasMultiplier();

  public void setIsCasMultiplier(boolean trueORfalse);

  public void setShadowCasPoolSize(int aPoolSize);

  public int getShadowPoolSize();

  public ServiceInfo getServiceInfo();

  public Object getDestination();

  public void setDestination(Object aDestination);

  public void setCommand(int aCommand);

  public int getCommand();

  public void setRegisteredWithParent();

  public boolean isRegisteredWithParent();

  public void setInitialFsHeapSize(int aHeapSize);

  public void setTempReplyDestination(boolean isTempReplyDestination);

  public boolean isTempReplyDestination();

  public void setReplyDestinationFailed();

  public boolean replyDestinationFailed();

  public void setIdleTime(long anIdleTime);

  public long getIdleTime();

  public void setEndpointServer(String anEndpointServer);

  public String getEndpointServer();

  public void setConcurrentRequestConsumers(int aConsumerCount);

  public int getConcurrentRequestConsumers();

  public void setConcurrentReplyConsumers(int aConsumerCount);

  public int getConcurrentReplyConsumers();

  public void setSerializer(String aSerializer);

  public void setStatus(int aStatus);

  public int getStatus();

  public void setDelegateKey(String aDelegateKey);

  public String getDelegateKey();

  public void setProcessParentLast(boolean parentLast);

  public boolean processParentLast();
  
  public void setFreeCasEndpoint(boolean trueOrFalse);
  
  public boolean isFreeCasEndpoint();
}