You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@openjpa.apache.org by pc...@apache.org on 2007/01/18 23:52:32 UTC
svn commit: r497614 -
/incubator/openjpa/trunk/openjpa-kernel/src/main/java/org/apache/openjpa/event/JMSRemoteCommitProvider.java
Author: pcl
Date: Thu Jan 18 14:52:32 2007
New Revision: 497614
URL: http://svn.apache.org/viewvc?view=rev&rev=497614
Log:
reformatted ugly code
Modified:
incubator/openjpa/trunk/openjpa-kernel/src/main/java/org/apache/openjpa/event/JMSRemoteCommitProvider.java
Modified: incubator/openjpa/trunk/openjpa-kernel/src/main/java/org/apache/openjpa/event/JMSRemoteCommitProvider.java
URL: http://svn.apache.org/viewvc/incubator/openjpa/trunk/openjpa-kernel/src/main/java/org/apache/openjpa/event/JMSRemoteCommitProvider.java?view=diff&rev=497614&r1=497613&r2=497614
==============================================================================
--- incubator/openjpa/trunk/openjpa-kernel/src/main/java/org/apache/openjpa/event/JMSRemoteCommitProvider.java (original)
+++ incubator/openjpa/trunk/openjpa-kernel/src/main/java/org/apache/openjpa/event/JMSRemoteCommitProvider.java Thu Jan 18 14:52:32 2007
@@ -171,19 +171,20 @@
// create a subscriber.
TopicSubscriber s = _session.createSubscriber(topic, null,
/* noLocal: */ true);
- MessageListener l = getMessageListener();
- s.setMessageListener(l);
- _connection.start();
- _connection.setExceptionListener(this);
- if (log.isInfoEnabled())
- log.info(s_loc.get("jms-start-listener", _topicName));
- } catch (OpenJPAException ke) {
- throw ke;
- } catch (Exception e) {
- throw new UserException(s_loc.get("jms-provider-config",
- _topicName, _tcfName), e).setFatal(true);
- }
- }
+
+ MessageListener l = getMessageListener();
+ s.setMessageListener(l);
+ _connection.start();
+ _connection.setExceptionListener(this);
+ if (log.isInfoEnabled())
+ log.info(s_loc.get("jms-start-listener", _topicName));
+ } catch (OpenJPAException ke) {
+ throw ke;
+ } catch (Exception e) {
+ throw new UserException(s_loc.get("jms-provider-config",
+ _topicName, _tcfName), e).setFatal(true);
+ }
+ }
/* *
* Returns a {@link javax.jms.MessageListener} capable of