Docjar: A Java Source and Docuemnt Enginecom.*    java.*    javax.*    org.*    all    new    plug-in

Quick Search    Search Deep

org.activemq.ra
Class MessageEndpointProxy  view MessageEndpointProxy download MessageEndpointProxy.java

java.lang.Object
  extended byorg.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


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:
beforeDelivery in interface javax.resource.spi.endpoint.MessageEndpoint

onMessage

public void onMessage(javax.jms.Message message)
Specified by:
onMessage in interface javax.jms.MessageListener

afterDelivery

public void afterDelivery()
                   throws javax.resource.ResourceException
Specified by:
afterDelivery in interface javax.resource.spi.endpoint.MessageEndpoint

release

public void release()
Specified by:
release in interface javax.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()).