|
|||||||||
| Home >> All >> org >> activemq >> [ ra overview ] | PREV CLASS NEXT CLASS | ||||||||
SUMMARY: JAVADOC | SOURCE | DOWNLOAD | NESTED | FIELD | CONSTR | METHOD |
DETAIL: FIELD | CONSTR | METHOD | ||||||||
org.activemq.ra
Class MessageEndpointProxy

java.lang.Objectorg.activemq.ra.MessageEndpointProxy
- All Implemented Interfaces:
- javax.resource.spi.endpoint.MessageEndpoint, javax.jms.MessageListener
- public class MessageEndpointProxy
- extends java.lang.Object
- implements javax.jms.MessageListener, javax.resource.spi.endpoint.MessageEndpoint
- extends java.lang.Object
| Nested Class Summary | |
private static class |
MessageEndpointProxy.MessageEndpointAlive
|
private static class |
MessageEndpointProxy.MessageEndpointDead
|
private static class |
MessageEndpointProxy.MessageEndpointInTheElectricChair
|
private static class |
MessageEndpointProxy.MessageEndpointState
|
| Field Summary | |
private boolean |
alive
|
private static MessageEndpointProxy.MessageEndpointState |
ALIVE
|
private static MessageEndpointProxy.MessageEndpointState |
DEAD
|
private static int |
deliveryCount
|
private javax.resource.spi.endpoint.MessageEndpoint |
endpoint
|
private static MessageEndpointProxy.MessageEndpointState |
GOING_TO_DIE
|
private static org.apache.commons.logging.Log |
log
|
private static int |
proxyCount
|
private int |
proxyID
|
private MessageEndpointProxy.MessageEndpointState |
state
|
| Constructor Summary | |
MessageEndpointProxy(javax.resource.spi.endpoint.MessageEndpoint endpoint)
|
|
| Method Summary | |
void |
afterDelivery()
|
void |
beforeDelivery(java.lang.reflect.Method method)
|
private static int |
getID()
|
private static int |
getNextDeliveryCount()
|
void |
onMessage(javax.jms.Message message)
|
void |
release()
|
java.lang.String |
toString()
Convert this Object to a human-readable String. |
| Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
| Field Detail |
ALIVE
private static final MessageEndpointProxy.MessageEndpointState ALIVE
GOING_TO_DIE
private static final MessageEndpointProxy.MessageEndpointState GOING_TO_DIE
DEAD
private static final MessageEndpointProxy.MessageEndpointState DEAD
log
private static final org.apache.commons.logging.Log log
proxyCount
private static int proxyCount
deliveryCount
private static int deliveryCount
proxyID
private final int proxyID
endpoint
private javax.resource.spi.endpoint.MessageEndpoint endpoint
alive
private boolean alive
state
private MessageEndpointProxy.MessageEndpointState state
| Constructor Detail |
MessageEndpointProxy
public MessageEndpointProxy(javax.resource.spi.endpoint.MessageEndpoint endpoint)
| Method Detail |
getID
private static int getID()
getNextDeliveryCount
private static int getNextDeliveryCount()
beforeDelivery
public void beforeDelivery(java.lang.reflect.Method method) throws java.lang.NoSuchMethodException, javax.resource.ResourceException
- Specified by:
beforeDeliveryin interfacejavax.resource.spi.endpoint.MessageEndpoint
onMessage
public void onMessage(javax.jms.Message message)
- Specified by:
onMessagein interfacejavax.jms.MessageListener
afterDelivery
public void afterDelivery()
throws javax.resource.ResourceException
- Specified by:
afterDeliveryin interfacejavax.resource.spi.endpoint.MessageEndpoint
release
public void release()
- Specified by:
releasein interfacejavax.resource.spi.endpoint.MessageEndpoint
toString
public java.lang.String toString()
- Description copied from class:
java.lang.Object - Convert this Object to a human-readable String.
There are no limits placed on how long this String
should be or what it should contain. We suggest you
make it as intuitive as possible to be able to place
it into System.out.println() 55
and such.
It is typical, but not required, to ensure that this method never completes abruptly with a java.lang.RuntimeException.
This method will be called when performing string concatenation with this object. If the result is
null, string concatenation will instead use"null".The default implementation returns
getClass().getName() + "@" + Integer.toHexString(hashCode()).
|
|||||||||
| Home >> All >> org >> activemq >> [ ra overview ] | PREV CLASS NEXT CLASS | ||||||||
SUMMARY: JAVADOC | SOURCE | DOWNLOAD | NESTED | FIELD | CONSTR | METHOD |
DETAIL: FIELD | CONSTR | METHOD | ||||||||
JAVADOC
org.activemq.ra.MessageEndpointProxy