Apache
/
openjpa
mirror of https://github.com/apache/openjpa.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

reformatted ugly code 

git-svn-id: https://svn.apache.org/repos/asf/incubator/openjpa/trunk@497614 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Patrick Linskey 2007-01-18 22:52:32 +00:00
parent 396efa6ae6
commit a40baca273
1 changed files with 14 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

27
openjpa-kernel/src/main/java/org/apache/openjpa/event/JMSRemoteCommitProvider.java
View File

@ -171,19 +171,20 @@ public class JMSRemoteCommitProvider
// create a subscriber. // create a subscriber.
TopicSubscriber s = _session.createSubscriber(topic, null, TopicSubscriber s = _session.createSubscriber(topic, null,
/* noLocal: */ true); /* noLocal: */ true);
MessageListener l = getMessageListener();
s.setMessageListener(l); MessageListener l = getMessageListener();
_connection.start(); s.setMessageListener(l);
_connection.setExceptionListener(this); _connection.start();
if (log.isInfoEnabled()) _connection.setExceptionListener(this);
log.info(s_loc.get("jms-start-listener", _topicName)); if (log.isInfoEnabled())
} catch (OpenJPAException ke) { log.info(s_loc.get("jms-start-listener", _topicName));
throw ke; } catch (OpenJPAException ke) {
} catch (Exception e) { throw ke;
throw new UserException(s_loc.get("jms-provider-config", } catch (Exception e) {
_topicName, _tcfName), e).setFatal(true); throw new UserException(s_loc.get("jms-provider-config",
} _topicName, _tcfName), e).setFatal(true);
} }
}
/* * /* *
* Returns a {@link javax.jms.MessageListener} capable of * Returns a {@link javax.jms.MessageListener} capable of