Использование CometD в пользовательском приемнике Ant

Question

Я пытаюсь подключить пользовательский прослушиватель Ant к CometD, но я получаю NPE, где я ожидаю ручку канала. Вот фрагмент кода:

@Service 
public class CometListener implements BuildListener { 
    @Inject 
    private BayeuxServer bayeuxServer; 
    @Session 
    private LocalSession sender; 

    private String _channelName; 

    private ServerChannel _channel = null; 

    public CometListener() { 
     _channelName = "/my/test"; 
    } 

    @PostConstruct 
    private void initChannel() { 
     _channel = bayeuxServer.createChannelIfAbsent(_channelName).getReference(); 
    } 

    public final void buildFinished(final BuildEvent finish) { 

     // Convert the Update business object to a CometD-friendly format 
     Map<String, Object> data = new HashMap<String, Object>(4); 
     data.put("status", 1); 
     _channel.publish(sender, data); 
     finish.getProject().log("buildFinished() called.", Project.MSG_ERR); 
    } 
} 

Я взял Using cometd in dropwizard в качестве примера, но предложенный ответ не решить проблему там.

Заранее благодарим за любые отзывы.

Answer 1

Nevermind, мне нужен клиент Bayeux, а не сервер.