@UriEndpoint(firstVersion="1.5.0", scheme="jt400", title="JT400", syntax="jt400:userID:password/systemName/objectPath.type", consumerClass=Jt400DataQueueConsumer.class, label="messaging") public class Jt400Endpoint extends org.apache.camel.impl.ScheduledPollEndpoint implements org.apache.camel.MultipleConsumersSupport
Modifier and Type | Field and Description |
---|---|
static String |
KEY |
static String |
SENDER_INFORMATION |
Modifier | Constructor and Description |
---|---|
protected |
Jt400Endpoint(String endpointUri,
Jt400Component component)
Creates a new AS/400 data queue endpoint using a default connection pool
provided by the component.
|
protected |
Jt400Endpoint(String endpointUri,
Jt400Component component,
com.ibm.as400.access.AS400ConnectionPool connectionPool)
Creates a new AS/400 data queue endpoint using the specified connection
pool.
|
Modifier and Type | Method and Description |
---|---|
org.apache.camel.Consumer |
createConsumer(org.apache.camel.Processor processor) |
org.apache.camel.Producer |
createProducer() |
int |
getCcsid() |
int |
getCssid() |
Jt400Configuration.Format |
getFormat() |
protected String |
getObjectPath()
Returns the fully qualified integrated file system path name of the data
queue of this endpoint.
|
int |
getOutputFieldLength(int idx) |
Integer[] |
getOutputFieldsIdxArray() |
Integer[] |
getOutputFieldsLengthArray() |
String |
getPassword() |
String |
getProcedureName() |
int |
getReadTimeout() |
String |
getSearchKey() |
Jt400Configuration.SearchType |
getSearchType() |
protected com.ibm.as400.access.AS400 |
getSystem()
Obtains an
AS400 object that connects to this endpoint. |
String |
getSystemName() |
Jt400Type |
getType() |
String |
getUserID() |
boolean |
isFieldIdxForOuput(int idx) |
boolean |
isGuiAvailable() |
boolean |
isKeyed() |
boolean |
isMultipleConsumersSupported() |
boolean |
isSecured() |
boolean |
isSingleton() |
protected void |
releaseSystem(com.ibm.as400.access.AS400 system)
Releases a previously obtained
AS400 object from use. |
void |
setCcsid(int ccsid) |
void |
setFieldsLength(String fieldsLength) |
void |
setFormat(Jt400Configuration.Format format) |
void |
setGuiAvailable(boolean guiAvailable) |
void |
setKeyed(boolean keyed) |
void |
setObjectPath(String objectPath) |
void |
setOutputFieldsIdx(String outputFieldsIdx) |
void |
setOutputFieldsIdxArray(Integer[] outputFieldsIdxArray) |
void |
setOutputFieldsLengthArray(Integer[] outputFieldsLengthArray) |
void |
setPassword(String password) |
void |
setProcedureName(String procedureName) |
void |
setReadTimeout(int readTimeout) |
void |
setSearchKey(String searchKey) |
void |
setSearchType(Jt400Configuration.SearchType searchType) |
void |
setSecured(boolean secured) |
void |
setSystemName(String systemName) |
void |
setType(Jt400Type type) |
void |
setUserID(String userID) |
configurePollingConsumer, configureProperties, configureScheduledPollConsumerProperties, doStart, doStop, getBackoffErrorThreshold, getBackoffIdleThreshold, getBackoffMultiplier, getDelay, getInitialDelay, getPollStrategy, getRunLoggingLevel, getScheduledExecutorService, getScheduler, getSchedulerProperties, getTimeUnit, initConsumerProperties, isGreedy, isSendEmptyMessageWhenIdle, isStartScheduler, isUseFixedDelay, setBackoffErrorThreshold, setBackoffIdleThreshold, setBackoffMultiplier, setDelay, setGreedy, setInitialDelay, setPollStrategy, setRunLoggingLevel, setScheduledExecutorService, setScheduler, setScheduler, setSchedulerProperties, setSendEmptyMessageWhenIdle, setStartScheduler, setTimeUnit, setUseFixedDelay
configureConsumer, createEndpointConfiguration, createEndpointUri, createExchange, createExchange, createExchange, createPollingConsumer, equals, getCamelContext, getComponent, getConsumerProperties, getEndpointConfiguration, getEndpointKey, getEndpointUri, getExceptionHandler, getExchangePattern, getId, getPollingConsumerBlockTimeout, getPollingConsumerQueueSize, hashCode, isBridgeErrorHandler, isLenientProperties, isPollingConsumerBlockWhenFull, isSynchronous, setBridgeErrorHandler, setCamelContext, setConsumerProperties, setEndpointConfiguration, setEndpointUri, setEndpointUriIfNotSpecified, setExceptionHandler, setExchangePattern, setPollingConsumerBlockTimeout, setPollingConsumerBlockWhenFull, setPollingConsumerQueueSize, setProperties, setSynchronous, toString
doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspend
public static final String KEY
public static final String SENDER_INFORMATION
protected Jt400Endpoint(String endpointUri, Jt400Component component) throws org.apache.camel.CamelException
NullPointerException
- if component
is nullorg.apache.camel.CamelException
protected Jt400Endpoint(String endpointUri, Jt400Component component, com.ibm.as400.access.AS400ConnectionPool connectionPool) throws org.apache.camel.CamelException
org.apache.camel.CamelException
public org.apache.camel.Producer createProducer() throws Exception
createProducer
in interface org.apache.camel.Endpoint
Exception
public org.apache.camel.Consumer createConsumer(org.apache.camel.Processor processor) throws Exception
createConsumer
in interface org.apache.camel.Endpoint
Exception
public boolean isSingleton()
isSingleton
in interface org.apache.camel.IsSingleton
protected com.ibm.as400.access.AS400 getSystem()
AS400
object that connects to this endpoint. Since
these objects represent limited resources, clients have the
responsibility of releasing them
when done.AS400
object that connects to this endpointprotected void releaseSystem(com.ibm.as400.access.AS400 system)
AS400
object from use.system
- a previously obtained AS400
objectprotected String getObjectPath()
public Jt400Type getType()
public void setType(Jt400Type type)
public String getSearchKey()
public boolean isKeyed()
public Integer[] getOutputFieldsIdxArray()
public int getCcsid()
public void setOutputFieldsIdxArray(Integer[] outputFieldsIdxArray)
public void setSearchKey(String searchKey)
public void setOutputFieldsIdx(String outputFieldsIdx)
public void setKeyed(boolean keyed)
public Integer[] getOutputFieldsLengthArray()
public void setSearchType(Jt400Configuration.SearchType searchType)
public boolean isGuiAvailable()
public void setFormat(Jt400Configuration.Format format)
public void setFieldsLength(String fieldsLength)
public Jt400Configuration.Format getFormat()
public void setOutputFieldsLengthArray(Integer[] outputFieldsLengthArray)
public int getCssid()
public String getUserID()
public Jt400Configuration.SearchType getSearchType()
public void setCcsid(int ccsid)
public void setGuiAvailable(boolean guiAvailable)
public String getPassword()
public String getSystemName()
public boolean isFieldIdxForOuput(int idx)
public int getOutputFieldLength(int idx)
public void setObjectPath(String objectPath)
public void setPassword(String password)
public void setUserID(String userID)
public void setSystemName(String systemName)
public void setSecured(boolean secured)
public boolean isSecured()
public int getReadTimeout()
public void setReadTimeout(int readTimeout)
public void setProcedureName(String procedureName)
public String getProcedureName()
public boolean isMultipleConsumersSupported()
isMultipleConsumersSupported
in interface org.apache.camel.MultipleConsumersSupport
Apache Camel