Examples of registerCallback()


Examples of com.arjuna.webservices11.wsarjtx.processors.TerminationParticipantProcessor.registerCallback()

    {
        final AddressingProperties addressingProperties = AddressingHelper.createNotificationContext(MessageId.getMessageId()) ;

        final RequestCallback callback = new RequestCallback() ;
        final TerminationParticipantProcessor terminationParticipantProcessor = TerminationParticipantProcessor.getProcessor() ;
        terminationParticipantProcessor.registerCallback(_id, callback) ;
        try
        {
            TerminationCoordinatorClient.getClient().sendClose(_terminationCoordinator, addressingProperties, new InstanceIdentifier(_id)) ;
            callback.waitUntilTriggered() ;
        }
View Full Code Here

Examples of com.arjuna.webservices11.wsat.processors.CompletionInitiatorProcessor.registerCallback()

    {
        final AddressingProperties addressingProperties = AddressingHelper.createNotificationContext(MessageId.getMessageId()) ;

        final CompletionStub.RequestCallback callback = new CompletionStub.RequestCallback() ;
        final CompletionInitiatorProcessor completionInitiator = CompletionInitiatorProcessor.getProcessor() ;
        completionInitiator.registerCallback(_id, callback) ;
        try
        {
            CompletionCoordinatorClient.getClient().sendCommit(_completionCoordinator, addressingProperties, new InstanceIdentifier(_id)) ;
            callback.waitUntilTriggered() ;
        }
View Full Code Here

Examples of com.jboss.transaction.txinterop.webservices.atinterop.processors.ATInitiatorProcessor.registerCallback()

        final String messageId = MessageId.getMessageId() ;
        final AddressingProperties addressingProperties = AddressingHelper.createRequestContext(serviceURI, messageId) ;
       
        final RequestCallback callback = new RequestCallback() ;
        final ATInitiatorProcessor initiator = ATInitiatorProcessor.getInitiator() ;
        initiator.registerCallback(messageId, callback) ;
        try
        {
            AsyncParticipantClient.getClient().sendCompletionCommit(addressingProperties, coordinatorURI) ;
            callback.waitUntilTriggered(15000) ;
        }
View Full Code Here

Examples of com.jboss.transaction.txinterop.webservices.bainterop.processors.BAInitiatorProcessor.registerCallback()

        final String messageId = MessageId.getMessageId() ;
        final AddressingProperties addressingProperties = AddressingHelper.createRequestContext(serviceURI, messageId) ;
       
        final RequestCallback callback = new RequestCallback() ;
        final BAInitiatorProcessor initiator = BAInitiatorProcessor.getInitiator() ;
        initiator.registerCallback(messageId, callback) ;
        try
        {
            AsyncParticipantClient.getClient().sendCancel(coordinationContext, addressingProperties) ;
            callback.waitUntilTriggered(15000) ;
        }
View Full Code Here

Examples of com.jboss.transaction.wstf.webservices.sc007.processors.InitiatorProcessor.registerCallback()

        final String messageId = MessageId.getMessageId() ;
        final AddressingProperties addressingProperties = AddressingHelper.createRequestContext(serviceURI, messageId) ;
       
        final RequestCallback callback = new RequestCallback() ;
        final InitiatorProcessor initiator = InitiatorProcessor.getInitiator() ;
        initiator.registerCallback(messageId, callback) ;
        try
        {
            AsyncParticipantClient.getClient().sendCompletionCommit(addressingProperties, coordinatorURI) ;
            callback.waitUntilTriggered(15000) ;
        }
View Full Code Here

Examples of com.jjesus.callback.Caller.registerCallback()

    public static void main( String[] args )
    {
        System.out.println("Main()");
        Caller caller = new Caller();
        Handler handler = new Handler();
        caller.registerCallback(handler);
        caller.doCallback();
    }
}
View Full Code Here

Examples of com.knowgate.scheduler.SingleThreadExecutor.registerCallback()

      oCon.close("SendMail");
      oCon = null;
     
      if (bAutoRunJob) {
        SingleThreadExecutor oSte = new SingleThreadExecutor(oDbb, sJobId);
        oSte.registerCallback(SendMail.DEBUGLN);
        oSte.registerCallback(SendMail.PRINTLN);
        oSte.run();     
      } // bAutoRunJob
     
    } catch (SQLException sqle) {
View Full Code Here

Examples of com.knowgate.scheduler.SingleThreadExecutor.registerCallback()

      oCon = null;
     
      if (bAutoRunJob) {
        SingleThreadExecutor oSte = new SingleThreadExecutor(oDbb, sJobId);
        oSte.registerCallback(SendMail.DEBUGLN);
        oSte.registerCallback(SendMail.PRINTLN);
        oSte.run();     
      } // bAutoRunJob
     
    } catch (SQLException sqle) {
      if (DebugFile.trace) DebugFile.writeln("SQLException "+sqle.getMessage());
View Full Code Here

Examples of com.metaparadigm.jsonrpc.JSONRPCBridge.registerCallback()

      throw new ServletException(
          "Cannot find CommandDispatcher, the org.geomajas.internal.global.GeomajasContextListener "
              + "was probably not registered.");
    }
    jsonBridge.registerObject("CommandDispatcher", commandDispatcher);
    jsonBridge.registerCallback(this, HttpServletRequest.class);

    // put in application context
    config.getServletContext().setAttribute(JSON_RPC_BRIDGE_ATTRIBUTE, jsonBridge);
  }
View Full Code Here

Examples of com.metaparadigm.jsonrpc.JSONRPCBridge.registerCallback()

            session.setAttribute( JSONRPCBRIDGE, bridge );
        }

        WikiJSONAccessor acc = new WikiJSONAccessor();
       
        bridge.registerCallback( acc, HttpServletRequest.class );
       
        for( Iterator i = c_globalObjects.values().iterator(); i.hasNext(); )
        {
            CallbackContainer cc = (CallbackContainer) i.next();
      
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.