svn commit: r330671 - in /webservices/kandula/trunk/java/src: endpoints.conf org/apache/kandula/participant/TransactionInHandler.java

[thilina]

Author: thilina
Date: Thu Nov  3 16:33:14 2005
New Revision: 330671

URL: http://svn.apache.org/viewcvs?rev=330671&view=rev
Log:
Configuration file and the Pariticipant Repository Configuration...

Added:
    webservices/kandula/trunk/java/src/endpoints.conf
Modified:
    
webservices/kandula/trunk/java/src/org/apache/kandula/participant/TransactionInHandler.java

Added: webservices/kandula/trunk/java/src/endpoints.conf
URL: 
http://svn.apache.org/viewcvs/webservices/kandula/trunk/java/src/endpoints.conf?rev=330671&view=auto
==============================================================================
--- webservices/kandula/trunk/java/src/endpoints.conf (added)
+++ webservices/kandula/trunk/java/src/endpoints.conf Thu Nov  3 16:33:14 2005
@@ -0,0 +1,4 @@
+host=127.0.0.1

+port=8082

+tcpmon_enable=false

+PARTICIPANT_REPOSITORY =.
\ No newline at end of file

Modified: 
webservices/kandula/trunk/java/src/org/apache/kandula/participant/TransactionInHandler.java
URL: 
http://svn.apache.org/viewcvs/webservices/kandula/trunk/java/src/org/apache/kandula/participant/TransactionInHandler.java?rev=330671&r1=330670&r2=330671&view=diff
==============================================================================
--- 
webservices/kandula/trunk/java/src/org/apache/kandula/participant/TransactionInHandler.java
 (original)
+++ 
webservices/kandula/trunk/java/src/org/apache/kandula/participant/TransactionInHandler.java
 Thu Nov  3 16:33:14 2005
@@ -59,6 +59,8 @@
         // business logic receives the message

         String resourceFile = (String) msgContext.getParameter(

                 Constants.KANDULA_RESOURCE).getValue();

+        String participantRepository = 
EndpointReferenceFactory.getInstance().getPariticipantRepository();

+        System.out.println(participantRepository);

         try {

             resource = (KandulaResource) Class.forName(resourceFile)

                     .newInstance();

@@ -74,8 +76,7 @@
         ParticipantTransactionManager txManager = new 
ParticipantTransactionManager();

         try {

             RegistrationCoordinatorPortTypeRawXMLStub stub = new 
RegistrationCoordinatorPortTypeRawXMLStub(

-                    ".", coorContext.getRegistrationService());

-            // TODO: try to get the protocol through configuration parameter

+                    participantRepository, 
coorContext.getRegistrationService());

             EndpointReference participantProtocolService = 
EndpointReferenceFactory

                     .getInstance().get2PCParticipantEndpoint(id);

             stub.registerOperation(resource.getProtocol(),




---------------------------------------------------------------------
To unsubscribe, e-mail: [EMAIL PROTECTED]
For additional commands, e-mail: [EMAIL PROTECTED]