Formatting fixes for datagrid - WHITESPACE ONLY
Change-Id: I39c99795fcfef974b5b8c95cb7493e12322f6f74
diff --git a/src/main/java/net/onrc/onos/datagrid/HazelcastDatagrid.java b/src/main/java/net/onrc/onos/datagrid/HazelcastDatagrid.java
index 563be33..31de685 100755
--- a/src/main/java/net/onrc/onos/datagrid/HazelcastDatagrid.java
+++ b/src/main/java/net/onrc/onos/datagrid/HazelcastDatagrid.java
@@ -178,10 +178,10 @@
Class<K> typeK, Class<V> typeV) {
synchronized (eventChannels) {
IEventChannel<K, V> eventChannel =
- createChannelImpl(channelName, typeK, typeV);
+ createChannelImpl(channelName, typeK, typeV);
eventChannel.startup();
return eventChannel;
- }
+ }
}
/**
@@ -208,8 +208,8 @@
// Add the channel if the first listener
if (genericEventChannel == null) {
IEventChannel<K, V> castedEventChannel =
- new HazelcastEventChannel<K, V>(hazelcastInstance,
- channelName, typeK, typeV);
+ new HazelcastEventChannel<K, V>(hazelcastInstance,
+ channelName, typeK, typeV);
eventChannels.put(channelName, castedEventChannel);
return castedEventChannel;
}
@@ -223,13 +223,13 @@
}
@SuppressWarnings("unchecked")
IEventChannel<K, V> castedEventChannel =
- (IEventChannel<K, V>) genericEventChannel;
+ (IEventChannel<K, V>) genericEventChannel;
return castedEventChannel;
}
/**
* Add event channel listener.
- *
+ * <p/>
* NOTE: The channel is started automatically right after the listener
* is added.
*
@@ -247,12 +247,12 @@
Class<K> typeK, Class<V> typeV) {
synchronized (eventChannels) {
IEventChannel<K, V> eventChannel =
- createChannelImpl(channelName, typeK, typeV);
+ createChannelImpl(channelName, typeK, typeV);
eventChannel.addListener(listener);
eventChannel.startup();
return eventChannel;
- }
+ }
}
/**
@@ -266,9 +266,9 @@
@Override
public <K, V> void removeListener(String channelName,
IEventChannelListener<K, V> listener) {
- synchronized (eventChannels) {
+ synchronized (eventChannels) {
IEventChannel<?, ?> genericEventChannel =
- eventChannels.get(channelName);
+ eventChannels.get(channelName);
if (genericEventChannel != null) {
//
@@ -279,7 +279,7 @@
//
@SuppressWarnings("unchecked")
IEventChannel<K, V> castedEventChannel =
- (IEventChannel<K, V>) genericEventChannel;
+ (IEventChannel<K, V>) genericEventChannel;
castedEventChannel.removeListener(listener);
}
}