|
|
|
|
|
|
{code :title=Bar.java|borderStyle=solid }
QueueSender sender;
QueueSession session = null;
QueueConnection connection = null;
try {
connection = processor.getJMSConnection();
session = connection.createQueueSession( processor.isTransactional(), Session.DUPS_OK_ACKNOWLEDG);
ObjectMessage message = session.createObjectMessage();
message.setObject( data );
message.setStringProperty( Environment.INDEX_NAME_JMS_PROPERTY, indexName );
if ( log.isDebugEnabled() ) {
attachDebugDetails( message, indexName );
sender = session.createSender( processor.getJmsQueue() );
sender.send( message );
sender.close();
session.close();
}
catch (JMSException e) {
throw log.unableToSendJMSWork( indexName, processor.getJmsQueueName(), e );
}
finally {
processor.releaseJMSConnection( connection );
}
{code}
|
|
|
|
|
|
