package com.walker.push.mail; import com.walker.push.AbstractPushObject; import com.walker.push.Notification; import com.walker.push.NotificationChannel; import com.walker.push.PushException; import com.walker.push.PushResult; import com.walker.push.util.PushUtils; import java.util.List; public class WebsocketPush extends AbstractPushObject { public WebsocketPush(){ this.setId(NotificationChannel.WebSocket.getIndex()); this.setName(NotificationChannel.WebSocket.getName()); } @Override public void startup() { } @Override protected PushResult doPushContent(Notification notification, List data) throws PushException { logger.debug("推送web消息 = {}", notification); return PushUtils.acquireSuccessPushResult(); } @Override public NotificationChannel getNotificationChannel() { return NotificationChannel.WebSocket; } @Override public List translateToTarget(Notification notification) { return null; } }