Historial de página

@Name("pushChangeNotifier")
public class PushChangeNotifierPushManager {

   @In
   private TopicPublisher pruebaPushPublisher;   

   @In
   private TopicSession topicSession;

   public void publishfireEvent(PushEvent event) {
        try {
           pruebaPushPublisher.publish(topicSession.createObjectMessage(event.getMessage()));
        } catch (Exception ex) {
           throw new RuntimeException(ex);
        } 
   }

}

@MessageDriven(activationConfig = {
    @ActivationConfigProperty(
        propertyName = "destinationType",
        propertyValue = "javax.jms.Topic"
    ),
    @ActivationConfigProperty(
        propertyName = "destination",
        propertyValue = "topic/pruebaPushTopic"
    )
})
@Name("pushReceiver")
public class pushReceiver implements MessageListener {

   @Logger
   private Log log;

   @Push
   private PushContext someChannel;
  
   @Override
   public void onMessage(Message messagejmsMessage) {
      try {
         someChannel.send((ObjectMessage) message).getObject( String message = jmsMessage.getStringProperty("message");
         Events.exist().raiseEvent(new PushEvent(message));
      } catch (JMSException ex) {
         log.error("Problem sending push event message.", ex);
      } 
   }

}