Code cleanup.

git-svn-id: http://svn.us.apache.org/repos/asf/tuscany@1129611 13f79535-47bb-0310-9956-ffa450edef68

1 files changed, 58 insertions, 58 deletions

diff --git a/sca-java-2.x/contrib/samples/learning-more/binding-comet/pubsub-webapp/src/main/java/org/apache/tuscany/sca/sample/comet/EventProcessor.java b/sca-java-2.x/contrib/samples/learning-more/binding-comet/pubsub-webapp/src/main/java/org/apache/tuscany/sca/sample/comet/EventProcessor.java
index 3b19398ca1..838d2f317c 100644
--- a/sca-java-2.x/contrib/samples/learning-more/binding-comet/pubsub-webapp/src/main/java/org/apache/tuscany/sca/sample/comet/EventProcessor.java
+++ b/sca-java-2.x/contrib/samples/learning-more/binding-comet/pubsub-webapp/src/main/java/org/apache/tuscany/sca/sample/comet/EventProcessor.java
@@ -22,9 +22,9 @@ package org.apache.tuscany.sca.sample.comet;
 import java.util.ArrayList;
 import java.util.Date;
 import java.util.List;
-import java.util.Map;
 import java.util.UUID;
 import java.util.concurrent.ConcurrentHashMap;
+import java.util.concurrent.ConcurrentMap;
 
 import org.apache.tuscany.sca.binding.comet.runtime.callback.CometCallback;
 import org.apache.tuscany.sca.binding.comet.runtime.callback.Status;
@@ -42,66 +42,66 @@ import com.google.common.collect.Multimaps;
 @Scope("COMPOSITE")
 public class EventProcessor implements EventProcessorConsumerService, EventProcessorProducerService {
 
-	@Context
-	protected ComponentContext componentContext;
+    @Context
+    protected ComponentContext componentContext;
 
-	private Map<String, CometCallback> clients = new ConcurrentHashMap<String, CometCallback>();
-	private Multimap<String, String> eventListeners = Multimaps.synchronizedMultimap(HashMultimap
-			.<String, String> create());
+    private ConcurrentMap<String, CometCallback> clients = new ConcurrentHashMap<String, CometCallback>();
+    private Multimap<String, String> eventListeners = Multimaps.synchronizedMultimap(HashMultimap
+            .<String, String> create());
 
-	@Override
-	public void onEvent(String eventName, String eventData) {
-		// System.out.println("EventProcessor: Received event " + eventName +
-		// "...");
-		List<String> destinations = new ArrayList<String>();
-		synchronized (eventListeners) {
-			destinations.addAll(eventListeners.get(eventName));
-		}
-		Event event = new Event();
-		event.setName(eventName);
-		event.setData(eventData);
-		for (String registrationId : destinations) {
-			CometCallback client = clients.get(registrationId);
-			if (client == null) {
-				// client has unregistered from this event
-				synchronized (eventListeners) {
-					eventListeners.remove(eventName, registrationId);
-				}
-			} else {
-				Status status = client.sendMessage(event);
-				if (status == Status.CLIENT_DISCONNECTED) {
-					unregister(registrationId);
-				}
-			}
-		}
-	}
+    @Override
+    public void onEvent(String eventName, String eventData) {
+        // System.out.println("EventProcessor: Received event " + eventName +
+        // "...");
+        List<String> destinations = new ArrayList<String>();
+        synchronized (eventListeners) {
+            destinations.addAll(eventListeners.get(eventName));
+        }
+        Event event = new Event();
+        event.setName(eventName);
+        event.setData(eventData);
+        for (String registrationId : destinations) {
+            CometCallback client = clients.get(registrationId);
+            if (client == null) {
+                // client has unregistered from this event
+                synchronized (eventListeners) {
+                    eventListeners.remove(eventName, registrationId);
+                }
+            } else {
+                Status status = client.sendMessage(event);
+                if (status == Status.CLIENT_DISCONNECTED) {
+                    unregister(registrationId);
+                }
+            }
+        }
+    }
 
-	@Override
-	public void register(String eventName) {
-		String registrationId = UUID.randomUUID().toString();
-		CometCallback callback = componentContext.getRequestContext().getCallback();
-		clients.put(registrationId, callback);
-		synchronized (eventListeners) {
-			eventListeners.put(eventName, registrationId);
-		}
-		Event event = new Event();
-		event.setId(registrationId);
-		event.setName(eventName);
-		event.setData(new Date().toString());
-		callback.sendMessage(event);
-	}
+    @Override
+    public void register(String eventName) {
+        String registrationId = UUID.randomUUID().toString();
+        CometCallback callback = componentContext.getRequestContext().getCallback();
+        clients.put(registrationId, callback);
+        synchronized (eventListeners) {
+            eventListeners.put(eventName, registrationId);
+        }
+        Event event = new Event();
+        event.setId(registrationId);
+        event.setName(eventName);
+        event.setData(new Date().toString());
+        callback.sendMessage(event);
+    }
 
-	@Override
-	public void unregister(String registrationId) {
-		clients.remove(registrationId);
-		// unregistration from eventListeners done during onEvent
-	}
+    @Override
+    public void unregister(String registrationId) {
+        clients.remove(registrationId);
+        // unregistration from eventListeners done during onEvent
+    }
 
-	@Destroy
-	public void shutdown() {
-		clients.clear();
-		eventListeners.clear();
-		clients = null;
-		eventListeners = null;
-	}
+    @Destroy
+    public void shutdown() {
+        clients.clear();
+        eventListeners.clear();
+        clients = null;
+        eventListeners = null;
+    }
 }