Если я правильно понимаю проблему, у вас проблема, потому что даже если источник данных DefaultDS сообщает, что он запущен, поскольку он не получил никаких подключений, вы не обязательно знаете, что могут быть установлены соединения.
К сожалению, даже при включенной опции prefill служба источника данных будет запускаться нормально, даже если она не может связь.
Лучше всего реализовать ServiceMBean, который проверяет фактическое соединение с источником данных до того, как он сообщит о запуске. . В этом примере мы назовем его org.bob.ConnChecker и развернем с использованием ObjectName org.bob: service = ConnChecker.
Ваш дескриптор развертывания должен выглядеть примерно так:
<mbean code="org.bob.ConnChecker" name="jboss.mq:service=DestinationManager">
<depends optional-attribute-name="DataSource">jboss.jca:name=DefaultDS,service=ManagedConnectionPool</depends>
</mbean>
Таким образом, ваша служба не будет запущена, пока не будет запущен источник данных. Ваша служба не запустится, пока не установит соединение. Теперь вам просто нужно добавить org.bob: service = ConnChecker как зависимость от DestinationManager:
jboss.mq:service=MessageCache jboss.mq:service=PersistenceManager jboss.mq:service=StateManager jboss.mq:service=ThreadPool jboss: service = Именование org.bob: service = ConnChecker
Код ConnChecker будет выглядеть примерно так:
....
import org.jboss.system.ServiceMBeanSupport;
....
public class ConnChecker extends ServiceMBeanSupport implements ConnCheckerMBean {
/** The ObjectName of the data source */
protected ObjectName dataSourceObjectName = null;
/** The Datasource reference */
protected DataSource dataSource = null;
/**
* Called by JBoss when the dataSource has started
* @throws Exception This will happen if the dataSource cannot provide a connection
* @see org.jboss.system.ServiceMBeanSupport#startService()
*/
public void startService() throws Exception {
Connection conn = null;
try {
// Get the JNDI name from the DataSource Pool MBean
String jndiName = (String)server.getAttribute(dataSourceObjectName, "PoolJndiName");
// Get a ref to the DataSource from JNDI
lookupDataSource(jndiName);
// Try getting a connection
conn = dataSource.getConnection();
// If we get here, we successfully got a connection and this service will report being Started
} finally {
if(conn!=null) try { conn.close(); } catch (Exception e) {}
}
}
/**
* Configures the service's DataSource ObjectName
* @param dataSourceObjectName The ObjectName of the connection pool
*/
public void setDataSource(ObjectName dataSourceObjectName) {
this.dataSourceObjectName = dataSourceObjectName;
}
/**
* Acquires a reference to the data source from JNDI
* @param jndiName The JNDI binding name of the data source
* @throws NamingException
*/
protected void lookupDataSource(String jndiName) throws NamingException {
dataSource = (DataSource)new InitialContext().lookup(jndiName);
}
}
Код ConnCheckerMBean выглядит так:
....
import org.jboss.system.ServiceMBeanSupport;
....
public interface ConnCheckerMBean extends ServiceMBean {
public void setDataSource(ObjectName dataSourceObjectName);
}
Таким образом, вы по-прежнему будете получать ошибки, если не удается установить соединение с базой данных, но DestinationManager не запускается, и, надеюсь, это будет лучше, чем головная боль, которую вы испытываете сейчас.
person
Nicholas
schedule
20.07.2011
