public class KeyedPoolMessageRequesterFactoryAdapter extends Object implements MessageRequesterFactory, org.apache.commons.pool.KeyedPoolableObjectFactory
KeyedPoolMessageRequesterFactoryAdapter
adapts a
MessageRequesterFactory
with methods from commons-pool
KeyedPoolableObjectFactory
. It is only required for requester
factories that do not inherit from AbstractMessageRequesterFactory
.AbstractMessageRequesterFactory
Constructor and Description |
---|
KeyedPoolMessageRequesterFactoryAdapter(MessageRequesterFactory factory) |
Modifier and Type | Method and Description |
---|---|
void |
activate(InboundEndpoint endpoint,
MessageRequester requester)
Invoked before the given requester is handed out to a
client, but not after
MessageRequesterFactory.create(org.mule.api.endpoint.InboundEndpoint) . |
void |
activateObject(Object key,
Object obj) |
protected void |
applyLifecycle(MessageRequester requester,
boolean created) |
MessageRequester |
create(InboundEndpoint endpoint)
Creates a new message requester instance, initialised with the passed
endpoint.
|
void |
destroy(InboundEndpoint endpoint,
MessageRequester requester)
Invoked when a requester returned
false for
MessageRequesterFactory.validate(org.mule.api.endpoint.InboundEndpoint, org.mule.api.transport.MessageRequester) . |
void |
destroyObject(Object key,
Object obj) |
boolean |
isCreateRequesterPerRequest()
Controls whether dispatchers are cached or created per request.
|
Object |
makeObject(Object key) |
void |
passivate(InboundEndpoint endpoint,
MessageRequester requester)
Invoked immediately before the given requester is returned
to its pool.
|
void |
passivateObject(Object key,
Object obj) |
boolean |
validate(InboundEndpoint endpoint,
MessageRequester requester)
Invoked after the requester is returned from a client but
before it is prepared for return to its pool via
MessageRequesterFactory.passivate(org.mule.api.endpoint.InboundEndpoint, org.mule.api.transport.MessageRequester) . |
boolean |
validateObject(Object key,
Object obj) |
public KeyedPoolMessageRequesterFactoryAdapter(MessageRequesterFactory factory)
public void activateObject(Object key, Object obj) throws Exception
activateObject
in interface org.apache.commons.pool.KeyedPoolableObjectFactory
Exception
public void destroyObject(Object key, Object obj) throws Exception
destroyObject
in interface org.apache.commons.pool.KeyedPoolableObjectFactory
Exception
public Object makeObject(Object key) throws Exception
makeObject
in interface org.apache.commons.pool.KeyedPoolableObjectFactory
Exception
public void passivateObject(Object key, Object obj) throws Exception
passivateObject
in interface org.apache.commons.pool.KeyedPoolableObjectFactory
Exception
public boolean validateObject(Object key, Object obj)
validateObject
in interface org.apache.commons.pool.KeyedPoolableObjectFactory
public boolean isCreateRequesterPerRequest()
MessageRequesterFactory
MessageRequesterFactory.validate(org.mule.api.endpoint.InboundEndpoint, org.mule.api.transport.MessageRequester)
it takes
precedence over the dispatcher's own return value of
MessageDispatcher.validate()
.isCreateRequesterPerRequest
in interface MessageRequesterFactory
public MessageRequester create(InboundEndpoint endpoint) throws MuleException
MessageRequesterFactory
create
in interface MessageRequesterFactory
endpoint
- the endoint for which this requester should be createdMessageRequester
for this
transportMuleException
- if the requester cannot be createdpublic void activate(InboundEndpoint endpoint, MessageRequester requester) throws MuleException
MessageRequesterFactory
MessageRequesterFactory.create(org.mule.api.endpoint.InboundEndpoint)
.activate
in interface MessageRequesterFactory
endpoint
- the endpoint of the requesterrequester
- the requester to be activatedMuleException
- if the requester cannot be activatedpublic void destroy(InboundEndpoint endpoint, MessageRequester requester)
MessageRequesterFactory
false
for
MessageRequesterFactory.validate(org.mule.api.endpoint.InboundEndpoint, org.mule.api.transport.MessageRequester)
.destroy
in interface MessageRequesterFactory
endpoint
- the endpoint of the requesterrequester
- the requester to be validatedpublic void passivate(InboundEndpoint endpoint, MessageRequester requester)
MessageRequesterFactory
passivate
in interface MessageRequesterFactory
endpoint
- the endpoint of the requesterrequester
- the requester to be passivatedpublic boolean validate(InboundEndpoint endpoint, MessageRequester requester)
MessageRequesterFactory
MessageRequesterFactory.passivate(org.mule.api.endpoint.InboundEndpoint, org.mule.api.transport.MessageRequester)
.validate
in interface MessageRequesterFactory
endpoint
- the endpoint of the requesterrequester
- the requester to be validatedtrue
if the requester is valid for reuse,
false
otherwise.protected void applyLifecycle(MessageRequester requester, boolean created) throws MuleException
MuleException
Copyright © 2003–2016 MuleSoft, Inc.. All rights reserved.