You are viewing a plain text version of this content. The canonical link for it is here.
Posted to fx-dev@ws.apache.org by ga...@apache.org on 2007/02/22 18:20:36 UTC
svn commit: r510594 - in
/webservices/sandesha/trunk/java/src/org/apache/sandesha2:
i18n/SandeshaMessageKeys.java i18n/resource.properties
util/SequenceManager.java
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: sandesha-dev-unsubscribe@ws.apache.org
For additional commands, e-mail: sandesha-dev-help@ws.apache.org