|
|
|
|
|
|
{code:title= Bar.java | borderStyle JmsBackendQueueTask#runborderStyle =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}
{{QueueSender}} and {{QueueSession}} should also be closed in finally block, or try-with-resource should be used.
|
|
|
|
|
|
