}
@Override
public MessageEndpoint createEndpoint(XAResource xaResource, long timeout)
throws UnavailableException {
EndpointProxy handler = new EndpointProxy(_metadata, this, xaResource);
return (MessageEndpoint) Proxy.newProxyInstance(Thread.currentThread().getContextClassLoader(),
new Class<?>[] {_metadata.getListenerInterface(),MessageEndpoint.class},
handler);
}