X-Git-Url: https://git.pterodactylus.net/?a=blobdiff_plain;ds=inline;f=src%2Fmain%2Fjava%2Fnet%2Fpterodactylus%2Fsonitus%2Fdata%2Fsink%2FIcecast2Sink.java;fp=src%2Fmain%2Fjava%2Fnet%2Fpterodactylus%2Fsonitus%2Fdata%2Fsink%2FIcecast2Sink.java;h=4d492fd8bd20890b21b68ea0af95f6a26d190ed2;hb=c548332c486d812bfce23a9121219bf86ecc5588;hp=5487cc48fb5b34784f706dbd50ef4939122f2b76;hpb=f554e51504f7e39e658a84d79c041e0b0d8a6393;p=sonitus.git diff --git a/src/main/java/net/pterodactylus/sonitus/data/sink/Icecast2Sink.java b/src/main/java/net/pterodactylus/sonitus/data/sink/Icecast2Sink.java index 5487cc4..4d492fd 100644 --- a/src/main/java/net/pterodactylus/sonitus/data/sink/Icecast2Sink.java +++ b/src/main/java/net/pterodactylus/sonitus/data/sink/Icecast2Sink.java @@ -38,6 +38,7 @@ import com.google.common.base.Function; import com.google.common.base.Joiner; import com.google.common.base.Optional; import com.google.common.collect.FluentIterable; +import com.google.common.eventbus.EventBus; import com.google.common.io.BaseEncoding; import com.google.common.io.Closeables; @@ -52,6 +53,9 @@ public class Icecast2Sink implements Sink { /** The logger. */ private static final Logger logger = Logger.getLogger(Icecast2Sink.class.getName()); + /** The event bus. */ + private final EventBus eventBus; + /** The server name. */ private final String server; @@ -84,6 +88,8 @@ public class Icecast2Sink implements Sink { /** * Creates a new Icecast2 sink. * + * @param eventBus + * The event bus * @param server * The hostname of the server * @param port @@ -102,7 +108,8 @@ public class Icecast2Sink implements Sink { * {@code true} to publish the server in a public directory, {@code false} to * not publish it */ - public Icecast2Sink(String server, int port, String password, String mountPoint, String serverName, String serverDescription, String genre, boolean publishServer) { + public Icecast2Sink(EventBus eventBus, String server, int port, String password, String mountPoint, String serverName, String serverDescription, String genre, boolean publishServer) { + this.eventBus = eventBus; this.server = server; this.port = port; this.password = password;