使用 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);
有没有人可以帮助我?