try
{
lLocalServer.invoke(
lFactoryInstance.getObjectName(),
"start",
new Object[] {},
new String[] {}
);
}
catch(Exception e)
{
log.error("HiveAgentConnection::unexpect exception==",e);
}

I got exception like the following. I still can not explain this.

[15:24:49,360,HiveAgentConnection] HiveAgentConnection::unexpect exception==
javax.management.RuntimeErrorException: Error thrown in operation start

I implemented createManagedConnection() method of ManagedConnectionFactoryImpl like:

public ManagedConnection createManagedConnection(javax.security.auth.Subject subject, ConnectionRequestInfo info)
throws ResourceException
{
System.out.println("ManagedConnectionFactoryImpl::createManagedConnection ");
HiveAgentConnection conn = null;
try
{
conn = new HiveAgentConnection();
}
catch(HiveConnectException e)
{
throw new ResourceException("Hive connecting failed: " + e);
}

return new ManagedConnectionImpl(subject, info, conn);
}

The construction calls createRemoteMBeanServer() which is like:

private RemoteMBeanServer createRemoteMBeanServer() throws HiveConnectException
{
RemoteMBeanServer lConnector = null;

System.out.println("HiveAgnetConnection==createRemoteMBeanServer");
try
{
// create a MBeanServer and let it start
final MBeanServer lLocalServer = MBeanServerFactory.createMBeanServer();
System.out.println("HiveAgnetConnection==createRemoteMBeanServer==createMBeanServer() successed");

// register the connector factory
final ObjectInstance lFactoryInstance = lLocalServer.createMBean(
"org.jboss.jmx.connector.ConnectorFactoryService",
new ObjectName( lLocalServer.getDefaultDomain(), "name", "ConnectorFactory" )
);

System.out.println("HiveAgnetConnection==createRemoteMBeanServer==setAttribute");

/** set up notification type to rmi */
int lType = RemoteMBeanServer.NOTIFICATION_TYPE_RMI;

lLocalServer.setAttribute(
lFactoryInstance.getObjectName(),
new Attribute( "NotificationType", new Integer( lType ) )
);

System.out.println("HiveAgnetConnection==createRemoteMBeanServer==invoke start");
System.out.println("HiveAgentConnection==createRemoteMBeanServer==getObjectName: "+ lFactoryInstance.getObjectName());
try
{
lLocalServer.invoke(
lFactoryInstance.getObjectName(),
"start",
new Object[] {},
new String[] {}
);
}
catch(Exception e)
{
log.error("HiveAgentConnection::unexpect exception==",e);
}
......
}