org.mule.providers.dq
Class DQConnector
java.lang.Object
org.mule.providers.AbstractConnector
org.mule.providers.AbstractServiceEnabledConnector
org.mule.providers.dq.DQConnector
- All Implemented Interfaces:
- Disposable, ExceptionListener, Initialisable, UMOConnectable, UMOConnector
- public class DQConnector
- extends AbstractServiceEnabledConnector
DQConnector is a delegate provider that encapsulates an AS400
DataQueue provider. The properties hostname, userId and password must be set for
connection. The Message Queue location is the provider endpoint.
| Fields inherited from class org.mule.providers.AbstractConnector |
connected, connecting, createDispatcherPerRequest, createMultipleTransactedReceivers, defaultInboundTransformer, defaultOutboundTransformer, defaultResponseTransformer, dispatcherFactory, dispatchers, disposed, disposing, exceptionListener, initialised, logger, name, receivers, serverSide, sessionHandler, started, startOnConnect |
| Methods inherited from class org.mule.providers.AbstractConnector |
checkDisposed, connect, createDispatcher, destroyReceiver, disconnect, dispose, disposeDispatchers, disposeReceivers, doConnect, doDisconnect, doDispose, doStart, exceptionThrown, fireNotification, getConnectEventId, getConnectionDescription, getConnectionStrategy, getDefaultInboundTransformer, getDefaultOutboundTransformer, getDefaultResponseTransformer, getDispatcher, getDispatcher, getDispatcherFactory, getDispatchers, getDispatcherThreadingProfile, getExceptionListener, getName, getReceiver, getReceiver, getReceiverKey, getReceivers, getReceivers, getReceiverThreadingProfile, getReplyToHandler, getSessionHandler, getSupportedProtocols, handleException, handleWorkException, initialise, isConnected, isCreateDispatcherPerRequest, isCreateMultipleTransactedReceivers, isDisposed, isDisposing, isEnableMessageEvents, isRemoteSyncEnabled, isServerSide, isStarted, isUseSingleDispatcherThreadPool, isUseSingleReceiverThreadPool, lookupDispatcher, lookupReceiver, registerListener, registerSupportedProtocol, registerSupportedProtocolWithotPrefix, setConnectionStrategy, setCreateDispatcherPerRequest, setCreateMultipleTransactedReceivers, setDefaultInboundTransformer, setDefaultOutboundTransformer, setDefaultResponseTransformer, setDispatcherFactory, setDispatcherThreadingProfile, setEnableMessageEvents, setExceptionListener, setName, setReceiverThreadingProfile, setServerSide, setSessionHandler, setSupportedProtocols, setUseSingleDispatcherThreadPool, setUseSingleReceiverThreadPool, startConnector, stopConnector, supportsProtocol, unregisterListener, unregisterSupportedProtocol, workAccepted, workCompleted, workRejected, workStarted |
| Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
LIB_PROPERTY
public static final String LIB_PROPERTY
- See Also:
- Constant Field Values
RECORD_DESCRIPTOR_PROPERTY
public static final String RECORD_DESCRIPTOR_PROPERTY
- See Also:
- Constant Field Values
PROPERTY_POLLING_FREQUENCY
public static final String PROPERTY_POLLING_FREQUENCY
- Polling frequency property name
- See Also:
- Constant Field Values
DQConnector
public DQConnector()
createReceiver
public UMOMessageReceiver createReceiver(UMOComponent component,
UMOEndpoint endpoint)
throws Exception
- Overrides:
createReceiver in class AbstractServiceEnabledConnector
- Throws:
Exception- See Also:
AbstractConnector.createReceiver(org.mule.umo.UMOComponent,
org.mule.umo.endpoint.UMOEndpoint)
getPassword
public final String getPassword()
- Returns:
- Returns the password.
setPassword
public void setPassword(String pPassword)
- Parameters:
pPassword - The password to set.
getPollingFrequency
public Long getPollingFrequency()
- Returns:
- Returns the pollingFrequency.
setPollingFrequency
public void setPollingFrequency(Long pPollingFrequency)
- Parameters:
pPollingFrequency - The pollingFrequency to set.
getSystem
public AS400 getSystem()
- Returns:
- Returns the system.
setSystem
public void setSystem(AS400 pSystem)
- Parameters:
pSystem - The system to set.
getHostname
public String getHostname()
- Returns:
- Returns the hostname.
setHostname
public void setHostname(String pSystemName)
- Parameters:
pSystemName - The hostname to set.
getUsername
public String getUsername()
- Returns:
- Returns the userId.
setUsername
public void setUsername(String username)
- Parameters:
username - The userId to set.
doInitialise
public void doInitialise()
throws InitialisationException
- Overrides:
doInitialise in class AbstractServiceEnabledConnector
- Throws:
InitialisationException- See Also:
AbstractConnector.doInitialise()
getProtocol
public final String getProtocol()
- Specified by:
getProtocol in interface UMOConnector- Specified by:
getProtocol in class AbstractConnector
- See Also:
AbstractConnector.getProtocol()
doStop
protected void doStop()
throws UMOException
- Description copied from class:
AbstractConnector
- Template method to perform any work when stopping the connectoe
- Overrides:
doStop in class AbstractConnector
- Throws:
UMOException - if the method fails- See Also:
AbstractConnector.stopConnector()
getRecordFormat
public String getRecordFormat()
setRecordFormat
public void setRecordFormat(String recordFormat)
getFormat
public RecordFormat getFormat()
setFormat
public void setFormat(RecordFormat format)
Copyright © 2003-2006 MuleSource Inc.. All Rights Reserved.