org.mule.providers.dq
Class DQConnector

java.lang.Object
  extended byorg.mule.providers.AbstractConnector
      extended byorg.mule.providers.AbstractServiceEnabledConnector
          extended byorg.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.


Field Summary
static String LIB_PROPERTY
           
static String PROPERTY_POLLING_FREQUENCY
          Polling frequency property name
static String RECORD_DESCRIPTOR_PROPERTY
           
 
Fields inherited from class org.mule.providers.AbstractServiceEnabledConnector
serviceDescriptor, serviceOverrides
 
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
 
Fields inherited from interface org.mule.umo.provider.UMOConnector
INT_VALUE_NOT_SET
 
Constructor Summary
DQConnector()
           
 
Method Summary
 UMOMessageReceiver createReceiver(UMOComponent component, UMOEndpoint endpoint)
           
 void doInitialise()
           
protected  void doStop()
          Template method to perform any work when stopping the connectoe
 RecordFormat getFormat()
           
 String getHostname()
           
 String getPassword()
           
 Long getPollingFrequency()
           
 String getProtocol()
           
 String getRecordFormat()
           
 AS400 getSystem()
           
 String getUsername()
           
 void setFormat(RecordFormat format)
           
 void setHostname(String pSystemName)
           
 void setPassword(String pPassword)
           
 void setPollingFrequency(Long pPollingFrequency)
           
 void setRecordFormat(String recordFormat)
           
 void setSystem(AS400 pSystem)
           
 void setUsername(String username)
           
 
Methods inherited from class org.mule.providers.AbstractServiceEnabledConnector
getMessageAdapter, getServiceDescriptor, getServiceOverrides, getStreamMessageAdapter, initFromServiceDescriptor, initialiseFromUrl, setServiceOverrides
 
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
 

Field Detail

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
Constructor Detail

DQConnector

public DQConnector()
Method Detail

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.