|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectcom.waveset.adapter.ResourceAdapterBase
com.waveset.adapter.JmsListenerResourceAdapter
JMS Listener adapter processes messages delivered via JMS point-to-point (queues) or publish/subscribe (topics).
The 1.02b JMS API is used for maximum compatibility.
For 6.0 SP1, this adapter was re-written to read Messages synchronously in poll. The previous version processed Messages asynchronously, but it was found that J2EE spec does not require the asynchronous APIs be supported.
Nested Class Summary | |
static class |
JmsListenerResourceAdapter.SafetyInvocationHandler
An invocation handler for a dynamic proxy which ignores all unhandled errors in the invokes. |
Nested classes inherited from class com.waveset.adapter.ResourceAdapterBase |
ResourceAdapterBase.SimpleAccountIterator |
Nested classes inherited from class com.waveset.adapter.ResourceAdapter |
ResourceAdapter.ActionResult, ResourceAdapter.Features, ResourceAdapter.ObjectType |
Field Summary | |
protected ActiveSyncUtil |
_util
Handy utilities for logging |
static java.lang.String |
code_id
|
static java.lang.String |
RA_DESTINATION_NAME
|
static java.lang.String |
RA_DESTINATION_TYPE
|
static java.lang.String |
RA_DURABLE_SUBSCRIPTION_NAME
|
static java.lang.String |
RA_DURABLE_TOPIC_CLIENT_ID
|
static java.lang.String |
RA_FACTORY_NAME
|
static java.lang.String |
RA_IS_NATIVE_DELETE_RULE
|
static java.lang.String |
RA_JNDI_PROPERTIES
Resource property names |
static java.lang.String |
RA_LIFECYCLE_LISTENER
|
static java.lang.String |
RA_MESSAGE_MAPPER
|
static java.lang.String |
RA_MESSAGE_SELECTOR
|
static java.lang.String |
RA_PASSWORD
|
static java.lang.String |
RA_REINIT_UPON_EXCEPTION
|
static java.lang.String |
RA_RELIABLE_MESSAGING
|
static java.lang.String |
RA_RETRY_CONNECTION_FREQ
|
static java.lang.String |
RA_USER
|
static java.lang.String |
RESOURCE_NAME
Default resource name |
static java.lang.String |
RESOURCE_USER_FORM
|
protected static java.lang.String |
RM_AUTO_ACK_NAME
|
protected static java.lang.String |
RM_CLIENT_ACK_NAME
|
protected static java.lang.String |
RM_DUPS_OK_ACK_NAME
|
protected static java.lang.String |
RM_LOCAL_TRANSACTION_NAME
Valid values for the RA_RELIABLE_MESSAGING resource attribute |
Fields inherited from class com.waveset.adapter.ResourceAdapterBase |
_cache, _context, _excludedAccountsRule, _excludedAccountsRuleInited, _listAllObjectsAttrParse, _listAllObjectsAttrParseName, _listUserAttrParse, _listUserAttrParseName, _listUserGroupsAttrParse, _listUserGroupsAttrParseName, _resource, _thread, _trace, displayInfoCode, RA_BLOCKCOUNT, RA_LOGIN_ACTION, RA_LOGOFF_ACTION, RA_MULTI_VALUED_ATTRS, RA_TEST_MODE |
Constructor Summary | |
JmsListenerResourceAdapter()
|
Method Summary | |
WavesetResult |
authenticate(java.util.HashMap loginInfo)
Authenticates the user against the resource. |
WavesetResult |
checkCreateAccount(WSUser user)
|
WavesetResult |
checkDeleteAccount(WSUser user)
|
WavesetResult |
checkUpdateAccount(WSUser user)
|
void |
commitSession()
|
protected void |
connect()
|
Resource |
createPrototypeResource()
|
protected void |
disconnect()
|
protected java.lang.Object |
evaluateRule(Rule rule,
java.util.Map valueMap)
|
AccountIterator |
getAccountIterator()
account iteration not supported |
java.lang.Object |
getAttributeValue(java.lang.String name)
These are methods implemented in sources to get and set attributes. |
GenericObject |
getFeatures()
Expose features supported by the Resource Adapter. |
protected Rule |
getRule(java.lang.String name)
|
void |
init()
initialize yourself. |
protected java.util.Map |
mapMessageToRhs(javax.jms.Message message)
Convert the incoming JMS Message into a Map. |
protected java.util.Map |
mapRhsToLhs(java.util.Map rhsValueMap)
Map the values from the rhs to the lhs (based on schema map). |
protected GenericObject |
mungeValueMap(java.util.Map valueMap)
|
int |
poll()
The poll method. |
void |
setAttributeValue(java.lang.String name,
java.lang.Object value)
These are methods implemented in sources to get and set attributes. |
void |
shutdown()
Called once when the active sync is terminated. |
static Resource |
staticCreatePrototypeResource()
|
WavesetResult |
testConfiguration()
Test method. |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
public static final java.lang.String code_id
public static final java.lang.String RA_JNDI_PROPERTIES
public static final java.lang.String RA_DESTINATION_TYPE
public static final java.lang.String RA_FACTORY_NAME
public static final java.lang.String RA_DESTINATION_NAME
public static final java.lang.String RA_DURABLE_TOPIC_CLIENT_ID
public static final java.lang.String RA_DURABLE_SUBSCRIPTION_NAME
public static final java.lang.String RA_USER
public static final java.lang.String RA_PASSWORD
public static final java.lang.String RA_MESSAGE_SELECTOR
public static final java.lang.String RA_RELIABLE_MESSAGING
public static final java.lang.String RA_MESSAGE_MAPPER
public static final java.lang.String RA_RETRY_CONNECTION_FREQ
public static final java.lang.String RA_REINIT_UPON_EXCEPTION
public static final java.lang.String RA_LIFECYCLE_LISTENER
public static final java.lang.String RA_IS_NATIVE_DELETE_RULE
protected static final java.lang.String RM_LOCAL_TRANSACTION_NAME
protected static final java.lang.String RM_AUTO_ACK_NAME
protected static final java.lang.String RM_DUPS_OK_ACK_NAME
protected static final java.lang.String RM_CLIENT_ACK_NAME
public static final java.lang.String RESOURCE_NAME
public static final java.lang.String RESOURCE_USER_FORM
protected ActiveSyncUtil _util
Constructor Detail |
public JmsListenerResourceAdapter()
Method Detail |
public static Resource staticCreatePrototypeResource() throws WavesetException
WavesetException
public Resource createPrototypeResource() throws WavesetException
createPrototypeResource
in interface ResourceAdapter
createPrototypeResource
in class ResourceAdapterBase
WavesetException
public WavesetResult checkCreateAccount(WSUser user) throws WavesetException
checkCreateAccount
in interface ResourceAdapter
checkCreateAccount
in class ResourceAdapterBase
WavesetException
public WavesetResult checkUpdateAccount(WSUser user) throws WavesetException
checkUpdateAccount
in interface ResourceAdapter
checkUpdateAccount
in class ResourceAdapterBase
WavesetException
public WavesetResult checkDeleteAccount(WSUser user) throws WavesetException
checkDeleteAccount
in interface ResourceAdapter
checkDeleteAccount
in class ResourceAdapterBase
WavesetException
public WavesetResult authenticate(java.util.HashMap loginInfo) throws WavesetException
ResourceAdapter
authenticate
in interface ResourceAdapter
authenticate
in class ResourceAdapterBase
WavesetException
public GenericObject getFeatures()
getFeatures
in interface ResourceAdapter
getFeatures
in class ResourceAdapterBase
ResourceAdapter.Features
protected final Rule getRule(java.lang.String name) throws WavesetException
WavesetException
public final java.lang.Object getAttributeValue(java.lang.String name) throws WavesetException
getAttributeValue
in interface ActiveSync
WavesetException
public final void setAttributeValue(java.lang.String name, java.lang.Object value) throws WavesetException
setAttributeValue
in interface ActiveSync
WavesetException
public final void init() throws java.lang.Exception
ActiveSync
init
in interface ActiveSync
java.lang.Exception
public final void shutdown()
shutdown
in interface ActiveSync
public final int poll() throws java.lang.InterruptedException
poll
in interface ActiveSync
java.lang.InterruptedException
protected void connect() throws WavesetException
WavesetException
protected void disconnect()
public AccountIterator getAccountIterator() throws WavesetException
getAccountIterator
in interface ResourceAdapter
getAccountIterator
in class ResourceAdapterBase
WavesetException
protected GenericObject mungeValueMap(java.util.Map valueMap)
protected java.util.Map mapRhsToLhs(java.util.Map rhsValueMap) throws java.lang.Exception
rhsValueMap
- the incoming rhs value map
java.lang.Exception
protected final java.lang.Object evaluateRule(Rule rule, java.util.Map valueMap) throws WavesetException
WavesetException
protected java.util.Map mapMessageToRhs(javax.jms.Message message) throws java.lang.Exception
java.lang.Exception
public WavesetResult testConfiguration() throws WavesetException
testConfiguration
in interface ResourceAdapter
testConfiguration
in class ResourceAdapterBase
WavesetException
public void commitSession() throws java.lang.Exception
java.lang.Exception
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |