public static void sendMessage (DataSource conn, String queueName, String message, String user) выдает здесь SQLException {
try {
QueueConnection QCon = getConnection(conn);
Session session = QCon.createQueueSession(false, Session.CLIENT_ACKNOWLEDGE);
QCon.start();
Queue queue = ((AQjmsSession) session).getQueue(user, queueName);
MessageProducer producer = session.createProducer(queue);
// msg.setText
Message msg = session.createTextMessage(message);
//set properties to msg since axis2 needs this parameters to find the operation
producer.send(msg);
// TextMessage tMsg = session.createTextMessage(message);
// producer.send(tMsg);
System.out.println("Sent message = " + msg.toString());
session.close();
producer.close();
QCon.close();
} catch (JMSException e) {
e.printStackTrace();
return;
}
}
}, помещая в очередь сообщение or.bindVariables.put ("DESTINATION", destination) println ("queueName ==>" + queueName) println ("or.bindVariables.get (PROVIDER_ABM)" + or.bindVariables.get ("PROVIDER_ABM")) println ("conn" + conn)
AQJMSEnqueue.sendMessage(ds, queueName,or.bindVariables.get("PROVIDER_ABM"), user);
Здесь я пытаюсь вставить сообщение через очередь в базе данных.Но оно отображается как недействительное сообщение после ввода в базу данных.Как будто это происходит, но должно быть так, как конвертировать xml в clob, прежде чем ставить сообщение в очередь через oracleenqueue