Author: nbelaevski Date: 2010-11-01 20:02:04 -0400 (Mon, 01 Nov 2010) New Revision: 19875 Modified: branches/RF-7817/examples/push-demo/src/main/java/demo/HornetQInitializer.java branches/RF-7817/examples/push-demo/src/main/java/demo/TopicsInitializer.java Log: https://jira.jboss.org/browse/RF-9610 Modified: branches/RF-7817/examples/push-demo/src/main/java/demo/HornetQInitializer.java =================================================================== --- branches/RF-7817/examples/push-demo/src/main/java/demo/HornetQInitializer.java 2010-11-02 00:00:02 UTC (rev 19874) +++ branches/RF-7817/examples/push-demo/src/main/java/demo/HornetQInitializer.java 2010-11-02 00:02:04 UTC (rev 19875) @@ -50,7 +50,6 @@ private JMSServerManager serverManager; - @Override public void processEvent(SystemEvent event) throws AbortProcessingException { if (event instanceof PostConstructApplicationEvent) { try { @@ -112,7 +111,6 @@ serverManager.createTopic(false, "info", "/topic/info"); } - @Override public boolean isListenerForSource(Object source) { return true; } Modified: branches/RF-7817/examples/push-demo/src/main/java/demo/TopicsInitializer.java =================================================================== --- branches/RF-7817/examples/push-demo/src/main/java/demo/TopicsInitializer.java 2010-11-02 00:00:02 UTC (rev 19874) +++ branches/RF-7817/examples/push-demo/src/main/java/demo/TopicsInitializer.java 2010-11-02 00:02:04 UTC (rev 19875) @@ -47,7 +47,6 @@ */ public class TopicsInitializer implements SystemEventListener { - @Override public void processEvent(SystemEvent event) throws AbortProcessingException { TopicsContext topicsContext = TopicsContext.lookup(); @@ -57,14 +56,12 @@ topic.addTopicListener(new SessionTopicListener() { - @Override public void processUnsubscriptionEvent(SessionUnsubscriptionEvent event) throws EventAbortedException { TopicKey topicKey = event.getTopicKey(); Session session = event.getSession(); System.out.println(MessageFormat.format("Session {0} disconnected from {1}", session.getId(), topicKey.getTopicAddress())); } - @Override public void processSubscriptionEvent(SessionSubscriptionEvent event) throws EventAbortedException { TopicKey topicKey = event.getTopicKey(); Session session = event.getSession(); @@ -76,7 +73,6 @@ topicKey.getTopicAddress(), hsr.getRemoteAddr())); } - @Override public void processPreSubscriptionEvent(SessionPreSubscriptionEvent event) throws EventAbortedException { ExternalContext externalContext = FacesContext.getCurrentInstance().getExternalContext(); ChatBean chatBean = (ChatBean) externalContext.getSessionMap().get("chatBean"); @@ -87,7 +83,6 @@ }); } - @Override public boolean isListenerForSource(Object source) { return true; }