org.apache.camel.component.jt400
Class Jt400DataQueueEndpoint

java.lang.Object
  extended by org.apache.camel.impl.ServiceSupport
      extended by org.apache.camel.impl.DefaultEndpoint
          extended by org.apache.camel.impl.ScheduledPollEndpoint
              extended by org.apache.camel.impl.DefaultPollingEndpoint
                  extended by org.apache.camel.component.jt400.Jt400DataQueueEndpoint
All Implemented Interfaces:
CamelContextAware, Endpoint, IsSingleton, Service, ShutdownableService, HasId

public class Jt400DataQueueEndpoint
extends DefaultPollingEndpoint

AS/400 Data queue endpoint


Nested Class Summary
static class Jt400DataQueueEndpoint.Format
          Enumeration of supported data formats
 
Constructor Summary
protected Jt400DataQueueEndpoint(String endpointUri, Jt400Component component)
          Creates a new AS/400 data queue endpoint
 
Method Summary
 PollingConsumer createPollingConsumer()
          Creates a new Polling Consumer so that the caller can poll message exchanges from the consumer using PollingConsumer.receive(), PollingConsumer.receiveNoWait() or PollingConsumer.receive(long) whenever it is ready to do so rather than using the Event Based Consumer returned by Endpoint.createConsumer(Processor)
 Producer createProducer()
          Creates a new producer which is used send messages into the endpoint
protected  com.ibm.as400.access.DataQueue getDataQueue()
           
 Jt400DataQueueEndpoint.Format getFormat()
           
protected  com.ibm.as400.access.AS400 getSystem()
           
 boolean isSingleton()
          Whether this class supports being singleton or not.
 void setCcsid(int ccsid)
           
 void setFormat(Jt400DataQueueEndpoint.Format format)
           
 void setGuiAvailable(boolean guiAvailable)
           
 
Methods inherited from class org.apache.camel.impl.DefaultPollingEndpoint
createConsumer
 
Methods inherited from class org.apache.camel.impl.ScheduledPollEndpoint
configureConsumer, configureProperties, getConsumerProperties, setConsumerProperties
 
Methods inherited from class org.apache.camel.impl.DefaultEndpoint
createEndpointUri, createExchange, createExchange, createExchange, doStart, doStop, equals, getCamelContext, getComponent, getEndpointKey, getEndpointUri, getExchangePattern, getExchangeType, getId, hashCode, isLenientProperties, isSynchronous, setCamelContext, setEndpointUri, setEndpointUriIfNotSpecified, setExchangePattern, setSynchronous, toString
 
Methods inherited from class org.apache.camel.impl.ServiceSupport
addChildService, doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isSuspended, isSuspending, removeChildService, resume, shutdown, start, 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

Jt400DataQueueEndpoint

protected Jt400DataQueueEndpoint(String endpointUri,
                                 Jt400Component component)
                          throws CamelException
Creates a new AS/400 data queue endpoint

Throws:
CamelException
Method Detail

setCcsid

public void setCcsid(int ccsid)
              throws PropertyVetoException
Throws:
PropertyVetoException

setFormat

public void setFormat(Jt400DataQueueEndpoint.Format format)

getFormat

public Jt400DataQueueEndpoint.Format getFormat()

setGuiAvailable

public void setGuiAvailable(boolean guiAvailable)
                     throws PropertyVetoException
Throws:
PropertyVetoException

createPollingConsumer

public PollingConsumer createPollingConsumer()
                                      throws Exception
Description copied from interface: Endpoint
Creates a new Polling Consumer so that the caller can poll message exchanges from the consumer using PollingConsumer.receive(), PollingConsumer.receiveNoWait() or PollingConsumer.receive(long) whenever it is ready to do so rather than using the Event Based Consumer returned by Endpoint.createConsumer(Processor)

Specified by:
createPollingConsumer in interface Endpoint
Overrides:
createPollingConsumer in class DefaultEndpoint
Returns:
a newly created pull consumer
Throws:
Exception - if the pull consumer could not be created

createProducer

public Producer createProducer()
                        throws Exception
Description copied from interface: Endpoint
Creates a new producer which is used send messages into the endpoint

Returns:
a newly created producer
Throws:
Exception - can be thrown

getSystem

protected com.ibm.as400.access.AS400 getSystem()

getDataQueue

protected com.ibm.as400.access.DataQueue getDataQueue()

isSingleton

public boolean isSingleton()
Description copied from interface: IsSingleton
Whether this class supports being singleton or not.

Returns:
true to be a single shared instance, false to create new instances.


Apache CAMEL