1

使用 java 创建与 Oracle AQ 的连接时出现问题。这里的代码:

TopicConnectionFactory tc_fact = null;
TopicConnection t_conn = null;
TopicSession t_sess = null;

String[] args = new String[6];
args[0] = "orcl"; // sid
args[1] = "192.168.1.253"; // hostname
args[2] = "1521"; // portno
args[3] = "thin"; // driver
args[4] = "arizona"; // user
args[5] = "arizona"; // pass

tc_fact = AQjmsFactory.getTopicConnectionFactory(args[1], args[0], Integer.parseInt(args[2]), args[3]);
t_conn = tc_fact.createTopicConnection(args[4], args[5]);
t_sess = t_conn.createTopicSession(true, Session.CLIENT_ACKNOWLEDGE);
t_conn.start();

我收到这样的错误:

Exception in thread "main" java.lang.NoSuchMethodError: oracle.jdbc.internal.OracleConnection.getDbCsId()S
 at oracle.jms.AQjmsSession.setDBRatio(AQjmsSession.java:571)
 at oracle.jms.AQjmsSession.<init>(AQjmsSession.java:429)
 at oracle.jms.AQjmsConnection.createTopicSession(AQjmsConnection.java:741)
 at com.dwidasa.StreamsEnq.main(StreamsEnq.java:40)

通过此行时:

t_sess = t_conn.createTopicSession(true, Session.CLIENT_ACKNOWLEDGE);

有没有人可以帮助我?

4

0 回答 0