Constructor Detail

• InputQueueImpl

  public InputQueueImpl(org.apache.uima.resourceSpecifier.InputQueueType iqt,
                String endpoint,
                String brokerURL,
                int prefetch)

  Instantiates a new input queue impl.

  Parameters:

  iqt - the iqt

  endpoint - the endpoint

  brokerURL - the broker url

  prefetch - the prefetch

• InputQueueImpl

  public InputQueueImpl(org.apache.uima.resourceSpecifier.InputQueueType iqt,
                ServiceContext context)

  Instantiates a new input queue impl.

  Parameters:

  iqt - the iqt

  context - the context

Method Detail

• getEndpoint

  public String getEndpoint()

  Description copied from interface: InputQueue
  Gets the endpoint.

  Specified by:

  getEndpoint in interface InputQueue

  Returns:

  the endpoint

• setEndpoint

  public void setEndpoint(String endpoint)

  Description copied from interface: InputQueue
  Sets the endpoint.

  Specified by:

  setEndpoint in interface InputQueue

  Parameters:

  endpoint - the new endpoint

• getBroker

  public String getBroker()

  Description copied from interface: InputQueue
  Gets the broker.

  Specified by:

  getBroker in interface InputQueue

  Returns:

  the broker

• setBroker

  public void setBroker(String broker)

  Description copied from interface: InputQueue
  Sets the broker.

  Specified by:

  setBroker in interface InputQueue

  Parameters:

  broker - the new broker

• setPrefetch

  public void setPrefetch(int prefetch)

  Description copied from interface: InputQueue
  Sets the prefetch.

  Specified by:

  setPrefetch in interface InputQueue

  Parameters:

  prefetch - the new prefetch

• getPrefetch

  public int getPrefetch()

  Description copied from interface: InputQueue
  Gets the prefetch.

  Specified by:

  getPrefetch in interface InputQueue

  Returns:

  the prefetch