anthonyraymond/joal
1
1
Fork 0
mirror of https://github.com/anthonyraymond/joal.git synced 2024-11-10 09:02:31 +08:00
Code Issues Projects Releases Packages Wiki Activity

Dispatch torrent file alteration to client

Browse source
This commit is contained in:
anthonyraymond 2017-07-12 00:02:02 +02:00
parent 89e0bca1d2
commit 65ecc5ba20
1 changed files with 57 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

57
src/main/java/org/araymond/joal/web/services/corelistener/WebTorrentFileEventListener.java Normal file
View file

@ -0,0 +1,57 @@
package org.araymond.joal.web.services.corelistener;
import org.araymond.joal.core.events.filechange.FailedToAddTorrentFileEvent;
import org.araymond.joal.core.events.filechange.TorrentFileAddedEvent;
import org.araymond.joal.core.events.filechange.TorrentFileDeletedEvent;
import org.araymond.joal.web.messages.outgoing.impl.files.FailedToAddTorrentFilePayload;
import org.araymond.joal.web.messages.outgoing.impl.files.TorrentFileAddedPayload;
import org.araymond.joal.web.messages.outgoing.impl.files.TorrentFileDeletedPayload;
import org.araymond.joal.web.services.JoalMessageSendingTemplate;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.context.event.EventListener;
import org.springframework.core.Ordered;
import org.springframework.core.annotation.Order;
import org.springframework.stereotype.Service;
import javax.inject.Inject;
import java.util.Map;
/**
* Created by raymo on 11/07/2017.
*/
@Service
public class WebTorrentFileEventListener extends WebEventListener {
private static final Logger logger = LoggerFactory.getLogger(WebTorrentFileEventListener.class);
@Inject
public WebTorrentFileEventListener(final JoalMessageSendingTemplate messagingTemplate) {
super(messagingTemplate);
}
@Order(Ordered.LOWEST_PRECEDENCE)
@EventListener
void handleTorrentFileAdded(final TorrentFileAddedEvent event) {
logger.debug("Send TorrentFileAddedPayload to clients.");
this.messagingTemplate.convertAndSend("/torrents", new TorrentFileAddedPayload(event));
}
@Order(Ordered.LOWEST_PRECEDENCE)
@EventListener
void handleTorrentFileDeleted(final TorrentFileDeletedEvent event) {
logger.debug("Send TorrentFileDeletedPayload to clients.");
this.messagingTemplate.convertAndSend("/torrents", new TorrentFileDeletedPayload(event));
}
@Order(Ordered.LOWEST_PRECEDENCE)
@EventListener
void handleFailedToAddTorrentFile(final FailedToAddTorrentFileEvent event) {
logger.debug("Send FailedToAddTorrentFilePayload to clients.");
this.messagingTemplate.convertAndSend("/torrents", new FailedToAddTorrentFilePayload(event));
}
}