在Java中使用pelops时,有没有办法捕获连接错误?我有以下代码,但由于某些原因,我无法访问catch块。
public static Boolean testDBConnection() throws PelopsException {
try{
Cluster cluster = new Cluster("127.0.0.1", 9160);
Pelops.addPool(pool, cluster, keyspace);
Pelops.shutdown();
return true;
}
catch(PelopsException e)
{
System.out.println("SOMETHING WENT WRONG!");
System.out.println(e.getMessage());
return false;
}
}这可能是非常容易的事情,但我似乎不能让它工作。我看到了异常的到来,但我就是没有办法捕捉到这个?有谁能带我到正确的方向吗?
谢谢!
编辑-在Eclipse控制台中返回异常...
15:47:33.545 [main] DEBUG o.s.c.pelops.pool.CommonsBackedPool - Made new connection 'Connection[Testing][127.0.0.1:9160][724408050]'
15:47:34.545 [main] ERROR o.scale7.cassandra.pelops.Connection - Failed to open transport. See cause for details...
org.apache.thrift.transport.TTransportException: java.net.ConnectException: Connection refused: connect
at org.apache.thrift.transport.TSocket.open(TSocket.java:185) ~[libthrift-0.5.0.jar:na]
at org.apache.thrift.transport.TFramedTransport.open(TFramedTransport.java:81) ~[libthrift-0.5.0.jar:na]
at org.scale7.cassandra.pelops.Connection.open(Connection.java:70) ~[scale7-pelops-0.913.jar:na]
at org.scale7.cassandra.pelops.pool.CommonsBackedPool$ConnectionFactory.makeObject(CommonsBackedPool.java:785) [scale7-pelops-0.913.jar:na]
at org.apache.commons.pool.impl.GenericKeyedObjectPool.addObject(GenericKeyedObjectPool.java:1685) [commons-pool-1.5.5.jar:1.5.5]
at org.apache.commons.pool.impl.GenericKeyedObjectPool.ensureMinIdle(GenericKeyedObjectPool.java:2058) [commons-pool-1.5.5.jar:1.5.5]
at org.apache.commons.pool.impl.GenericKeyedObjectPool.preparePool(GenericKeyedObjectPool.java:1722) [commons-pool-1.5.5.jar:1.5.5]
at org.scale7.cassandra.pelops.pool.CommonsBackedPool.addNode(CommonsBackedPool.java:373) [scale7-pelops-0.913.jar:na]
at org.scale7.cassandra.pelops.pool.CommonsBackedPool.<init>(CommonsBackedPool.java:104) [scale7-pelops-0.913.jar:na]
at org.scale7.cassandra.pelops.pool.CommonsBackedPool.<init>(CommonsBackedPool.java:64) [scale7-pelops-0.913.jar:na]
at org.scale7.cassandra.pelops.pool.CommonsBackedPool.<init>(CommonsBackedPool.java:52) [scale7-pelops-0.913.jar:na]
at org.scale7.cassandra.pelops.Pelops.addPool(Pelops.java:25) [scale7-pelops-0.913.jar:na]
at libraries.cassandra.testDBConnection(cassandra.java:192) [classes/:na]
at libraries.cassandra.main(cassandra.java:38) [classes/:na]
Caused by: java.net.ConnectException: Connection refused: connect
at java.net.PlainSocketImpl.socketConnect(Native Method) ~[na:1.6.0_25]
at java.net.PlainSocketImpl.doConnect(Unknown Source) ~[na:1.6.0_25]
at java.net.PlainSocketImpl.connectToAddress(Unknown Source) ~[na:1.6.0_25]
at java.net.PlainSocketImpl.connect(Unknown Source) ~[na:1.6.0_25]
at java.net.SocksSocketImpl.connect(Unknown Source) ~[na:1.6.0_25]
at java.net.Socket.connect(Unknown Source) ~[na:1.6.0_25]
at org.apache.thrift.transport.TSocket.open(TSocket.java:180) ~[libthrift-0.5.0.jar:na]
... 13 common frames omitted发布于 2011-06-14 07:15:30
抛出org.apache.thrift.TTransportException的异常是一个检查过的异常,它不会被扩展RuntimeException的PelopsException捕获和包装。
如果你想让你的方法总是返回一个PelopsException,你必须在你的catch(Exception e)块中抛出新的PelopsException(e.getMessage())。
catch(Exception e)
{
System.out.println("SOMETHING WENT WRONG!");
System.out.println(e.getMessage());
throw new PelopsException(e.getMessage());
}发布于 2011-06-14 07:10:38
它可能抛出一个unchecked exception或一个错误(这不是一个异常)。
尝试将您的代码更改为catch (Throwable e),看看会得到什么。
https://stackoverflow.com/questions/6337436
复制相似问题