package org.jboss.proxy.ejb;
import java.lang.reflect.Method;
import org.jboss.invocation.Invocation;
import org.jboss.invocation.InvocationContext;
import org.jboss.invocation.InvocationKey;
import org.jboss.invocation.InvocationType;
import org.jboss.proxy.ejb.handle.EntityHandleImpl;
public class EntityInterceptor
extends GenericEJBInterceptor
{
private static final long serialVersionUID = 4399705304832568350L;
public EntityInterceptor()
{}
public Object invoke(Invocation invocation)
throws Throwable
{
InvocationContext ctx = invocation.getInvocationContext();
Method m = invocation.getMethod();
if (m.equals(TO_STRING))
{
return toString(ctx);
}
else if (m.equals(EQUALS))
{
Object[] args = invocation.getArguments();
String argsString = args[0] != null ? args[0].toString() : "";
String thisString = toString(ctx);
return new Boolean(thisString.equals(argsString));
}
else if (m.equals(HASH_CODE))
{
return new Integer(ctx.getCacheId().hashCode());
}
else if (m.equals(GET_HANDLE))
{
String jndiName = (String) ctx.getValue(InvocationKey.JNDI_NAME);
Object id = ctx.getCacheId();
return new EntityHandleImpl(jndiName, id);
}
else if (m.equals(GET_PRIMARY_KEY))
{
return ctx.getCacheId();
}
else if (m.equals(GET_EJB_HOME))
{
return getEJBHome(invocation);
}
else if (m.equals(IS_IDENTICAL))
{
Object[] args = invocation.getArguments();
String argsString = args[0].toString();
String thisString = toString(ctx);
return new Boolean(thisString.equals(argsString));
}
else
{
invocation.setType(InvocationType.REMOTE);
invocation.setId(ctx.getCacheId());
return getNext().invoke(invocation);
}
}
private String toString(InvocationContext ctx)
{
return ctx.getValue(InvocationKey.JNDI_NAME) + ":" +
ctx.getCacheId().toString();
}
}