commit cd189125cc0fec9fc89089b7761fea0d29e78e81
author Nanayakkara Kuruppuge Thilina Gunarathne <thilina@apache.org> Fri Nov 04 00:33:14 2005 +0000
committer Nanayakkara Kuruppuge Thilina Gunarathne <thilina@apache.org> Fri Nov 04 00:33:14 2005 +0000
tree 1757ee3cac858f8c42dde0fb84cce7dd9a37544c
parent 86b153e0dfeb9f1088c20bb93adf88114a2e51f7

Configuration file and the Pariticipant Repository Configuration...

src/endpoints.conf

diff --git a/src/endpoints.conf b/src/endpoints.conf
new file mode 100644
index 0000000..ef5b073
--- /dev/null
+++ b/src/endpoints.conf
@@ -0,0 +1,4 @@
+host=127.0.0.1

+port=8082

+tcpmon_enable=false

+PARTICIPANT_REPOSITORY =.
\ No newline at end of file

src/org/apache/kandula/participant/TransactionInHandler.java

diff --git a/src/org/apache/kandula/participant/TransactionInHandler.java b/src/org/apache/kandula/participant/TransactionInHandler.java
index 385968e..60a55a9 100644
--- a/src/org/apache/kandula/participant/TransactionInHandler.java
+++ b/src/org/apache/kandula/participant/TransactionInHandler.java
@@ -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(),