org.apache.camel.component.jt400
Class Jt400PgmEndpoint

java.lang.Object
  org.apache.camel.support.ServiceSupport
      org.apache.camel.impl.DefaultEndpoint
          org.apache.camel.component.jt400.Jt400PgmEndpoint

All Implemented Interfaces:

org.apache.camel.CamelContextAware, org.apache.camel.Endpoint, org.apache.camel.IsSingleton, org.apache.camel.Service, org.apache.camel.ShutdownableService, org.apache.camel.spi.HasId, org.apache.camel.StatefulService, org.apache.camel.SuspendableService

public class Jt400PgmEndpoint
extends org.apache.camel.impl.DefaultEndpoint

Field Summary

Fields inherited from class org.apache.camel.support.ServiceSupport

shutdown, shuttingdown, started, starting, stopped, stopping, suspended, suspending

Constructor Summary

protected	Jt400PgmEndpoint(String endpointUri, Jt400Component component) Creates a new AS/400 PGM CALL endpoint using a default connection pool provided by the component.
protected	Jt400PgmEndpoint(String endpointUri, Jt400Component component, com.ibm.as400.access.AS400ConnectionPool connectionPool) Creates a new AS/400 PGM CALL endpoint using the specified connection pool.
	Jt400PgmEndpoint(String endpointUri, String programToExecute, Map<String,Object> parameters, org.apache.camel.CamelContext camelContext)

Method Summary

org.apache.camel.Consumer	createConsumer(org.apache.camel.Processor processor)
org.apache.camel.Producer	createProducer()
Jt400DataQueueEndpoint.Format	getFormat()
com.ibm.as400.access.AS400	getiSeries() Obtains an AS400 object that connects to this endpoint.
int	getOutputFieldLength(int idx)
String	getProgramToExecute()
boolean	isFieldIdxForOuput(int idx)
boolean	isGuiAvailable()
boolean	isSingleton()
void	releaseiSeries(com.ibm.as400.access.AS400 iSeries) Releases a previously obtained AS400 object from use.
void	setFieldsLength(String fieldsLength)
void	setFormat(Jt400DataQueueEndpoint.Format format)
void	setGuiAvailable(boolean guiAvailable)
void	setOutputFieldsIdx(String outputFieldsIdx)

Methods inherited from class org.apache.camel.impl.DefaultEndpoint

configureConsumer, configurePollingConsumer, configureProperties, createEndpointConfiguration, createEndpointUri, createExchange, createExchange, createExchange, createPollingConsumer, doStart, doStop, equals, getCamelContext, getComponent, getConsumerProperties, getEndpointConfiguration, getEndpointKey, getEndpointUri, getExchangePattern, getId, hashCode, isLenientProperties, isSynchronous, setCamelContext, setConsumerProperties, setEndpointConfiguration, setEndpointUri, setEndpointUriIfNotSpecified, setExchangePattern, setProperties, setSynchronous, toString

Methods inherited from class org.apache.camel.support.ServiceSupport

doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, resume, shutdown, start, stop, suspend

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.apache.camel.Service

start, stop

Constructor Detail

Jt400PgmEndpoint

protected Jt400PgmEndpoint(String endpointUri,
                           Jt400Component component)
                    throws org.apache.camel.CamelException

Creates a new AS/400 PGM CALL endpoint using a default connection pool provided by the component.

Throws:

NullPointerException - if component is null

org.apache.camel.CamelException

Jt400PgmEndpoint

protected Jt400PgmEndpoint(String endpointUri,
                           Jt400Component component,
                           com.ibm.as400.access.AS400ConnectionPool connectionPool)
                    throws org.apache.camel.CamelException

Creates a new AS/400 PGM CALL endpoint using the specified connection pool.

Throws:

org.apache.camel.CamelException

Jt400PgmEndpoint

public Jt400PgmEndpoint(String endpointUri,
                        String programToExecute,
                        Map<String,Object> parameters,
                        org.apache.camel.CamelContext camelContext)

Method Detail

createProducer

public org.apache.camel.Producer createProducer()
                                         throws Exception

Throws:

Exception

createConsumer

public org.apache.camel.Consumer createConsumer(org.apache.camel.Processor processor)
                                         throws Exception

Throws:

Exception

isSingleton

public boolean isSingleton()

isFieldIdxForOuput

public boolean isFieldIdxForOuput(int idx)

getOutputFieldLength

public int getOutputFieldLength(int idx)

getProgramToExecute

public String getProgramToExecute()

getiSeries

public com.ibm.as400.access.AS400 getiSeries()

Obtains an AS400 object that connects to this endpoint. Since these objects represent limited resources, clients have the responsibility of releasing them when done.

Returns:

an AS400 object that connects to this endpoint

releaseiSeries

public void releaseiSeries(com.ibm.as400.access.AS400 iSeries)

Releases a previously obtained AS400 object from use.

Parameters:

iSeries - a previously obtained AS400 object

setOutputFieldsIdx

public void setOutputFieldsIdx(String outputFieldsIdx)

setFieldsLength

public void setFieldsLength(String fieldsLength)

setFormat

public void setFormat(Jt400DataQueueEndpoint.Format format)

getFormat

public Jt400DataQueueEndpoint.Format getFormat()

setGuiAvailable

public void setGuiAvailable(boolean guiAvailable)
                     throws PropertyVetoException

Throws:

PropertyVetoException

isGuiAvailable

public boolean isGuiAvailable()