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