Код: Выделить всё
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.scheduling.annotation.EnableScheduling;
@SpringBootApplication
@EnableScheduling
public class GodCreatorApplication {
public static void main(String[] args) {
SpringApplication.run(GodCreatorApplication.class, args);
}
}
< /code>
botconfiguration: < /p>
import discord4j.core.DiscordClientBuilder;
import discord4j.core.GatewayDiscordClient;
import discord4j.core.event.domain.Event;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import java.util.List;
@Configuration
public class BotConfiguration {
@Value("${discord.token}")
private String token;
@Bean
public GatewayDiscordClient gatewayDiscordClient(List eventListeners) {
GatewayDiscordClient client = DiscordClientBuilder.create(token)
.build()
.login()
.block();
for(EventListener listener : eventListeners) {
assert client != null;
client.on(listener.getEventType())
.flatMap(listener::execute)
.onErrorResume(listener::handleError)
.subscribe();
}
return client;
}
}
< /code>
MessageListener: < /p>
import discord4j.core.object.entity.Message;
import reactor.core.publisher.Mono;
public abstract class MessageListener {
public Mono processCommand(Message eventMessage) {
return Mono.just(eventMessage)
.filter(message -> message.getAuthor().map(user -> !user.isBot()).orElse(false))
.filter(message -> message.getContent().equalsIgnoreCase("!todo"))
.flatMap(Message::getChannel)
.flatMap(channel -> channel.createMessage("Things to do today:\n - write a bot\n - eat lunch\n - play a game"))
.then();
}
}
< /code>
MassageCreateListener: < /p>
import discord4j.core.event.domain.message.MessageCreateEvent;
import org.springframework.stereotype.Service;
import reactor.core.publisher.Mono;
@Service
public class MessageCreateListener extends MessageListener implements EventListener {
@Override
public Class getEventType() {
return MessageCreateEvent.class;
}
@Override
public Mono execute(MessageCreateEvent event) {
return processCommand(event.getMessage());
}
}
Подробнее здесь: https://stackoverflow.com/questions/775 ... er-stopped