| java.lang.Object org.jboss.ejb3.mdb.inflow.MessageInflowLocalProxy
Method Summary | |
protected void | after(Object proxy) After delivery processing. | protected void | before(Object proxy, MessagingContainer container, Method method, Object[] args) Before delivery processing. | protected Object | delivery(Object proxy, MessagingContainer container, Method method, Object[] args) Delivery. | protected void | endTransaction(Object proxy, boolean commit) | protected void | finish(String context, Object proxy, boolean commit) | protected MessagingContainer | getContainer(Invocation mi) | protected JBossMessageEndpointFactory | getMessageEndpointFactory(Invocation invocation) | protected String | getProxyString(Object proxy) Get our proxy's string value. | public Object | invoke(Object proxy, Method method, Object[] args) | protected void | release(Object proxy) Release this message endpoint. | protected void | releaseThreadLock(Object proxy) | protected void | resetContextClassLoader(Object proxy) | public void | setMessageEndpointFactory(MessageEndpointFactory messageEndpointFactory) | public void | setXaResource(XAResource resource) | protected void | startTransaction(String context, Object proxy, MessagingContainer container, Method m, Object[] args, boolean isTransacted) | public String | toString() |
MESSAGE_ENDPOINT_FACTORY | final public static String MESSAGE_ENDPOINT_FACTORY(Code) | | The key for the factory
|
MESSAGE_ENDPOINT_XARESOURCE | final public static String MESSAGE_ENDPOINT_XARESOURCE(Code) | | The key for the xa resource
|
delivered | protected boolean delivered(Code) | | Whether we have delivered a message
|
inUseThread | protected Thread inUseThread(Code) | | The in use thread
|
oldClassLoader | protected ClassLoader oldClassLoader(Code) | | The old classloader of the thread
|
released | protected SynchronizedBoolean released(Code) | | Whether this proxy has been released
|
suspended | protected Transaction suspended(Code) | | Any suspended transaction
|
transaction | protected Transaction transaction(Code) | | Any transaction we started
|
after | protected void after(Object proxy) throws Throwable(Code) | | After delivery processing.
Parameters: mi - the invocation throws: Throwable - for any error |
endTransaction | protected void endTransaction(Object proxy, boolean commit) throws Throwable(Code) | | End the transaction
Parameters: mi - the invocation Parameters: commit - whether to try to commit throws: Throwable - for any error |
finish | protected void finish(String context, Object proxy, boolean commit) throws Throwable(Code) | | Finish the current delivery
Parameters: context - the lifecycle method Parameters: mi - the invocation Parameters: commit - whether to commit throws: Throwable - for any error |
getMessageEndpointFactory | protected JBossMessageEndpointFactory getMessageEndpointFactory(Invocation invocation)(Code) | | Get the message endpoint factory
the message endpoint factory |
getProxyString | protected String getProxyString(Object proxy)(Code) | | Get our proxy's string value.
Parameters: mi - the invocation the string |
release | protected void release(Object proxy) throws Throwable(Code) | | Release this message endpoint.
Parameters: mi - the invocation throws: Throwable - for any error |
releaseThreadLock | protected void releaseThreadLock(Object proxy)(Code) | | Release the thread lock
Parameters: mi - the invocation |
resetContextClassLoader | protected void resetContextClassLoader(Object proxy)(Code) | | Reset the context classloader
Parameters: mi - the invocation |
setMessageEndpointFactory | public void setMessageEndpointFactory(MessageEndpointFactory messageEndpointFactory)(Code) | | |
startTransaction | protected void startTransaction(String context, Object proxy, MessagingContainer container, Method m, Object[] args, boolean isTransacted) throws Throwable(Code) | | Start a transaction
Parameters: context - the lifecycle method Parameters: mi - the invocation Parameters: container - the container throws: Throwable - for any error |
|
|