[seam-commits] Seam SVN: r12665 - branches/enterprise/JBPAPP_5_0/src/remoting/org/jboss/seam/remoting/messaging.
Author: manaRH
Date: 2010-04-30 11:55:15 -0400 (Fri, 30 Apr 2010)
New Revision: 12665
Modified:
branches/enterprise/JBPAPP_5_0/src/remoting/org/jboss/seam/remoting/messaging/SubscriptionRegistry.java
Log:
fixed formatting
Modified:
branches/enterprise/JBPAPP_5_0/src/remoting/org/jboss/seam/remoting/messaging/SubscriptionRegistry.java
===================================================================
---
branches/enterprise/JBPAPP_5_0/src/remoting/org/jboss/seam/remoting/messaging/SubscriptionRegistry.java 2010-04-29
20:57:43 UTC (rev 12664)
+++
branches/enterprise/JBPAPP_5_0/src/remoting/org/jboss/seam/remoting/messaging/SubscriptionRegistry.java 2010-04-30
15:55:15 UTC (rev 12665)
@@ -102,31 +102,31 @@
return topicConnection;
}
- public RemoteSubscriber subscribe(String topicName)
- {
- if (!allowedTopics.contains(topicName))
- {
- throw new IllegalArgumentException(String.format(
- "Cannot subscribe to a topic that is not allowed. Topic [%s] is not an
" +
- "allowed topic.", topicName));
- }
-
- RemoteSubscriber sub = new RemoteSubscriber(UUID.randomUUID().toString(),
topicName);
-
- try {
- subscribe(sub);
- subscriptions.put(sub.getToken(), sub);
-
- // Save the client's token in their session context
- getUserTokens().add(sub.getToken());
-
- return sub;
- }
- catch (Exception ex) {
- log.error(ex);
- return null;
- }
- }
+ public RemoteSubscriber subscribe(String topicName)
+ {
+ if (!allowedTopics.contains(topicName))
+ {
+ throw new IllegalArgumentException(String.format("Cannot subscribe to a
topic that is not allowed. Topic [%s] is not an " + "allowed topic.",
topicName));
+ }
+
+ RemoteSubscriber sub = new RemoteSubscriber(UUID.randomUUID().toString(),
topicName);
+
+ try
+ {
+ subscribe(sub);
+ subscriptions.put(sub.getToken(), sub);
+
+ // Save the client's token in their session context
+ getUserTokens().add(sub.getToken());
+
+ return sub;
+ }
+ catch (Exception ex)
+ {
+ log.error(ex);
+ return null;
+ }
+ }
private void subscribe(RemoteSubscriber sub) throws JMSException, Exception
{