Skip to content

Commit cb4fff3

Browse files
authored
OAK-11419: oak-store-document - persistent cache: remove unused UDP/TCP broadcasters (#2012)
* OAK-11419: oak-store-document - persistent cache: remove unused UDP broadcaster * OAK-11419: oak-store-document - persistent cache: remove unused TCP broadcaster
1 parent 8550089 commit cb4fff3

File tree

4 files changed

+5
-878
lines changed

4 files changed

+5
-878
lines changed

oak-store-document/src/main/java/org/apache/jackrabbit/oak/plugins/document/persistentCache/PersistentCache.java

Lines changed: 0 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -35,8 +35,6 @@
3535
import org.apache.jackrabbit.oak.plugins.document.persistentCache.async.CacheActionDispatcher;
3636
import org.apache.jackrabbit.oak.plugins.document.persistentCache.broadcast.Broadcaster;
3737
import org.apache.jackrabbit.oak.plugins.document.persistentCache.broadcast.InMemoryBroadcaster;
38-
import org.apache.jackrabbit.oak.plugins.document.persistentCache.broadcast.TCPBroadcaster;
39-
import org.apache.jackrabbit.oak.plugins.document.persistentCache.broadcast.UDPBroadcaster;
4038
import org.apache.jackrabbit.oak.stats.StatisticsProvider;
4139
import org.h2.mvstore.FileStore;
4240
import org.h2.mvstore.MVMap;
@@ -228,12 +226,6 @@ private void initBroadcast(String broadcast) {
228226
return;
229227
} else if (broadcast.equals("inMemory")) {
230228
broadcaster = InMemoryBroadcaster.INSTANCE;
231-
} else if (broadcast.startsWith("udp:")) {
232-
String config = broadcast.substring("udp:".length(), broadcast.length());
233-
broadcaster = new UDPBroadcaster(config);
234-
} else if (broadcast.startsWith("tcp:")) {
235-
String config = broadcast.substring("tcp:".length(), broadcast.length());
236-
broadcaster = new TCPBroadcaster(config);
237229
} else {
238230
throw new IllegalArgumentException("Unknown broadcaster type " + broadcast);
239231
}

0 commit comments

Comments
 (0)