Examples of NotificationManager


Examples of org.apache.webbeans.event.NotificationManager

     */
    public BeanManagerImpl(WebBeansContext webBeansContext)
    {
        this.webBeansContext = webBeansContext;
        injectionResolver = new InjectionResolver(webBeansContext);
        notificationManager = new NotificationManager(webBeansContext);
        annotatedElementFactory = webBeansContext.getAnnotatedElementFactory();
    }
View Full Code Here

Examples of org.apache.webbeans.event.NotificationManager

     */
    public BeanManagerImpl(WebBeansContext webBeansContext)
    {
        this.webBeansContext = webBeansContext;
        injectionResolver = new InjectionResolver(webBeansContext);
        notificationManager = new NotificationManager(webBeansContext);
        annotatedElementFactory = webBeansContext.getAnnotatedElementFactory();
    }
View Full Code Here

Examples of org.apache.webbeans.event.NotificationManager

    public static <T> void defineObserverMethods(InjectionTargetBean<T> component, Class<T> clazz)
    {
        Asserts.assertNotNull(component, "component parameter can not be null");
        Asserts.nullCheckForClass(clazz);

        NotificationManager manager = NotificationManager.getInstance();

        Method[] candidateMethods = AnnotationUtil.getMethodsWithParameterAnnotation(clazz, Observes.class);

        // From normal
        createObserverMethods(component, clazz, candidateMethods);

        manager.addObservableComponentMethods(component);

    }
View Full Code Here

Examples of org.apache.webbeans.event.NotificationManager

     * system.
     */
    public BeanManagerImpl()
    {
        injectionResolver = new InjectionResolver(this);
        notificationManager = new NotificationManager();
    }   
View Full Code Here

Examples of org.apache.ws.notification.NotificationManager

    */
   public SOAPElement[] getCurrentMessage( TopicDocument topicExpressionType )
   throws BaseFaultException,
          Exception
   { //todo update generated code to use TopicDocument
      NotificationManager notificationManager = getNotificationManager(  );

      if ( notificationManager != null )
      {
         return notificationManager.getCurrentMessage( topicExpressionType );
      }

      return null;
   }
View Full Code Here

Examples of org.apache.ws.notification.NotificationManager

    */
   public EndpointReferenceType subscribe( SubscriptionRequest subscribeRequest )
   throws BaseFaultException,
          Exception
   {
      NotificationManager notificationManager = getNotificationManager(  );

      if ( notificationManager != null )
      {
         return notificationManager.subscribe( subscribeRequest );
      }

      return null;
   }
View Full Code Here

Examples of org.apache.ws.notification.NotificationManager

   /**
    * @see AbstractWSResource#emitTerminationNotification()
    */
   protected void emitTerminationNotification(  )
   {
      NotificationManager notifMgr = getNotificationManager(  );

      if ( notifMgr != null )
      {
         TopicDocument topicDoc = TopicDocument.Factory.newInstance(  );
         XmlBeansUtils.setupTopicExpressionType( ResourceLifetime11Constants.NSURI_WSRL,
                                                 ResourceLifetime11Constants.TOPIC_QNAME_RESOURCE_TERMINATION
                                                 .getLocalPart(  ),
                                                 topicDoc.addNewTopic(  ) );

         TerminationNotificationDocument termNotifDoc = TerminationNotificationDocument.Factory.newInstance(  );
         TerminationNotification         termNotif = termNotifDoc.addNewTerminationNotification(  );
         termNotif.setTerminationTime( Calendar.getInstance(  ) );

         try
         {
            notifMgr.emit( topicDoc,
                           XmlBeansUtils.toSOAPElement( termNotifDoc ) );
         }
         catch ( Exception e )
         {
            // TODO: what to do if we fail to emit this notification?
View Full Code Here

Examples of org.wso2.event.NotificationManager

   
    @SuppressWarnings("unchecked")
    private EventBrokerService buildEventSource(OMElement configElement)
            throws Exception {
        SubscriptionManager subscriptionManager;
        NotificationManager notificationManager;
        EventDispatcher eventDispatcher;
       
        if(configElement != null){

            String eventSourceName = null;
View Full Code Here

Examples of org.wso2.eventing.NotificationManager

        assertNotSame("The instance is not unique", broker1,  broker4);
    }

    public void testRegisterNotificationDispatcher() throws Exception {
        EventBrokerService broker = CarbonEventBroker.getInstance("instance3");
        NotificationManager notificationManager = new TestNotificationManager();
        ((CarbonEventBroker)broker).registerNotificationManager(notificationManager);

        assertNotNull("Notification Manager is not set", broker.getNotificationManager());
        assertSame("Invalid notification manager", notificationManager,
                broker.getNotificationManager());
View Full Code Here

Examples of org.wso2.eventing.NotificationManager

                ((TestNotificationManager)notificationManager).isEventDispatcherRegistered());
    }

    public void testEventPublish() throws Exception {
        EventBrokerService broker = CarbonEventBroker.getInstance("instance4");
        NotificationManager notificationManager = new TestNotificationManager();
        ((CarbonEventBroker)broker).registerNotificationManager(notificationManager);

        assertNotNull("Notification Manager is not set", broker.getNotificationManager());
        assertSame("Invalid notification manager", notificationManager,
                broker.getNotificationManager());
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.