title: Spring-MVC, Cometd : Broadcasting without @Listener
body: <p>I am working on a Spring-MVC application and thanks to users on SO, we already have a working Cometd chat functionality. Another functionality we have in the application is notifications, but we would like to integrate Real-time notifications as soon as they happen, kinda like what Facebook has.  </p>
  
  <p>Basically the idea is, whenever a new notification is created, it will be saved in the database, and its information from the backend has to be passed to the notifications for logged in users on unique channel for each user.</p>
  
  <p>I would like to know if this approach will work, as it will take me some doing to route notifications to the chat class. Please note, I don't have an interface for the ChatServiceImpl class too. Is that okay? Enough talking, here's code :</p>
  
  <p>ChatServiceImpl :</p>
  
  <pre><code>@Named
  @Singleton
  @Service
  public class ChatServiceImpl {
      @Inject
      private BayeuxServer bayeux;
  
      @Session
      private ServerSession serverSession;
  
  
      public void sendNotification(Notification notification,int id
  // And then I send notification here like below, by extracting information from the notification object.
  
   ServerChannel serverChannel = bayeux.createChannelIfAbsent("/person/notification/" + id).getReference();
          serverChannel.setPersistent(true);
          serverChannel.publish(serverSession, output);
          }
      }
  </code></pre>
  
  <p>The above class has no interface, so I was planning to use the method as follows :</p>
  
  <pre><code>@Service
  @Transactional
  public class GroupCanvasServiceImpl implements GroupCanvasService{
      private ChatServiceImpl chatService;
  
     public void someMethod(){
     chatService.sendNotification(notification, id);
  }
  }
  </code></pre>
  
  <p>BayeuxInitializer :</p>
  
  <pre><code>@Component
  public class BayeuxInitializer implements DestructionAwareBeanPostProcessor, ServletContextAware
  {
      private BayeuxServer bayeuxServer;
      private ServerAnnotationProcessor processor;
  
      @Inject
      private void setBayeuxServer(BayeuxServer bayeuxServer)
      {
          this.bayeuxServer = bayeuxServer;
      }
  
      @PostConstruct
      private void init()
      {
  
          this.processor = new ServerAnnotationProcessor(bayeuxServer);
      }
  
      @PreDestroy
      private void destroy()
      {
          System.out.println("Bayeux in PreDestroy");
      }
  
      public Object postProcessBeforeInitialization(Object bean, String name) throws BeansException
      {
          processor.processDependencies(bean);
          processor.processConfigurations(bean);
          processor.processCallbacks(bean);
          return bean;
      }
  
      public Object postProcessAfterInitialization(Object bean, String name) throws BeansException
      {
          return bean;
      }
  
      public void postProcessBeforeDestruction(Object bean, String name) throws BeansException
      {
          processor.deprocessCallbacks(bean);
      }
  
      @Bean(initMethod = "start", destroyMethod = "stop")
      public BayeuxServer bayeuxServer()
      {
          return new BayeuxServerImpl();
      }
  
      public void setServletContext(ServletContext servletContext)
      {
          servletContext.setAttribute(BayeuxServer.ATTRIBUTE, bayeuxServer);
      }
  }
  </code></pre>
  
  <p>Kindly let me know if this approach is okay. Thanks a lot. </p>