Author: gatfora
Date: Thu Feb 22 09:20:36 2007
New Revision: 510594
URL: http://svn.apache.org/viewvc?view=rev&rev=510594
Log:
Remove ListenerManager code as it isn't required
Modified:
webservices/sandesha/trunk/java/src/org/apache/sandesha2/i18n/SandeshaMessageKeys.java
webservices/sandesha/trunk/java/src/org/apache/sandesha2/i18n/resource.properties
webservices/sandesha/trunk/java/src/org/apache/sandesha2/util/SequenceManager.java
Modified:
webservices/sandesha/trunk/java/src/org/apache/sandesha2/i18n/SandeshaMessageKeys.java
URL:
http://svn.apache.org/viewvc/webservices/sandesha/trunk/java/src/org/apache/sandesha2/i18n/SandeshaMessageKeys.java?view=diff&rev=510594&r1=510593&r2=510594
==============================================================================
---
webservices/sandesha/trunk/java/src/org/apache/sandesha2/i18n/SandeshaMessageKeys.java
(original)
+++
webservices/sandesha/trunk/java/src/org/apache/sandesha2/i18n/SandeshaMessageKeys.java
Thu Feb 22 09:20:36 2007
@@ -62,7 +62,6 @@
public static final String
cannotChooseSpecLevel="cannotChooseSpecLevel";
public static final String setAValidMsgNumber="setAValidMsgNumber";
- public static final String
cannotStartTransportListenerDueToError="cannotStartTransportListener";
public static final String
cannotStartListenerForIncommingMsgs="cannotStartListenerForIncommingMsgs";
public static final String nonUniqueResult="nonUniqueResult";
public static final String invalidStringArray="invalidStringArray";
Modified:
webservices/sandesha/trunk/java/src/org/apache/sandesha2/i18n/resource.properties
URL:
http://svn.apache.org/viewvc/webservices/sandesha/trunk/java/src/org/apache/sandesha2/i18n/resource.properties?view=diff&rev=510594&r1=510593&r2=510594
==============================================================================
---
webservices/sandesha/trunk/java/src/org/apache/sandesha2/i18n/resource.properties
(original)
+++
webservices/sandesha/trunk/java/src/org/apache/sandesha2/i18n/resource.properties
Thu Feb 22 09:20:36 2007
@@ -63,8 +63,6 @@
cannotChooseSpecLevel=Could not find an appropriate specification level for
the reply sequence, given inbound sequence {0} and bean info {1}.
invalidMsgNumber=Sandesha2 Internal Error: invalid message number {0}.
-cannotStartTransportListenerDueToError=Sandesha2 Internal error: could not
start the transport listener due to error {0}.
-cannotStartListenerForIncommingMsgs=Sandesha2 Internal error: cannot start the
listner for incoming messages. You must set the ''transport in'' protocol in
order to get async acknowledgement messages.
nonUniqueResult=Sandesha2 Internal error: A search for a unique object
resulted in several matches. Match 1 {0}, Match 2 {1}.
invalidStringArray=Sandesha2 Internal error: invalid String array : {0}.
cannotCointinueSender=Sandesha2 Internal error: cannot continue the Sender due
to exception: {0}.
Modified:
webservices/sandesha/trunk/java/src/org/apache/sandesha2/util/SequenceManager.java
URL:
http://svn.apache.org/viewvc/webservices/sandesha/trunk/java/src/org/apache/sandesha2/util/SequenceManager.java?view=diff&rev=510594&r1=510593&r2=510594
==============================================================================
---
webservices/sandesha/trunk/java/src/org/apache/sandesha2/util/SequenceManager.java
(original)
+++
webservices/sandesha/trunk/java/src/org/apache/sandesha2/util/SequenceManager.java
Thu Feb 22 09:20:36 2007
@@ -16,16 +16,12 @@
*/
package org.apache.sandesha2.util;
-import javax.xml.namespace.QName;
-
import org.apache.axis2.AxisFault;
import org.apache.axis2.Constants;
import org.apache.axis2.addressing.AddressingConstants;
import org.apache.axis2.addressing.EndpointReference;
import org.apache.axis2.context.MessageContext;
import org.apache.axis2.description.Parameter;
-import org.apache.axis2.description.TransportInDescription;
-import org.apache.axis2.engine.ListenerManager;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.apache.sandesha2.RMMsgContext;
@@ -254,28 +250,6 @@
if (log.isDebugEnabled())
log.debug("Using replyTo EPR as AcksTo,
addr=" + replyToEPR.getAddress());
acksToEPR = replyToEPR;
- }
-
- // start the in listner for the client side, if acksTo
is not anonymous.
- if (acksToEPR != null &&
!acksToEPR.hasAnonymousAddress()) {
- String transportInProtocol =
firstAplicationMsgCtx.getOptions().getTransportInProtocol();
- if (transportInProtocol == null) {
- throw new
SandeshaException(SandeshaMessageHelper
-
.getMessage(SandeshaMessageKeys.cannotStartListenerForIncommingMsgs));
- }
-
- try {
- ListenerManager listenerManager =
firstAplicationMsgCtx.getConfigurationContext().getListenerManager();
- TransportInDescription transportIn =
firstAplicationMsgCtx.getConfigurationContext()
-
.getAxisConfiguration().getTransportIn(new QName(transportInProtocol));
- // if acksTo is not anonymous start the
in-transport
- if
(!listenerManager.isListenerRunning(transportIn.getName().getLocalPart())) {
-
listenerManager.addListener(transportIn, false);
- }
- } catch (AxisFault e) {
- throw new
SandeshaException(SandeshaMessageHelper.getMessage(
-
SandeshaMessageKeys.cannotStartTransportListenerDueToError, e.toString()), e);
- }
}
}
// In case either of the replyTo or AcksTo is anonymous,
rewrite them using the AnonURI template
---------------------------------------------------------------------
To unsubscribe, e-mail: [EMAIL PROTECTED]
For additional commands, e-mail: [EMAIL PROTECTED]
