jmsnell 2002/10/28 22:39:57
Modified: java/src/org/apache/axis/ime MessageExchange.java
MessageExchangeFactory.java
java/src/org/apache/axis/ime/internal
MessageExchangeImpl.java
MessageExchangeProvider.java
Removed: java/src/org/apache/axis/ime
ConfigurableMessageExchange.java
ConfigurableMessageExchangeFactory.java
Log:
Last changes for the evening...
Folded ConfigurableMessageExchange into MessageExchange
Revision Changes Path
1.6 +62 -0 xml-axis/java/src/org/apache/axis/ime/MessageExchange.java
Index: MessageExchange.java
===================================================================
RCS file: /home/cvs/xml-axis/java/src/org/apache/axis/ime/MessageExchange.java,v
retrieving revision 1.5
retrieving revision 1.6
diff -u -r1.5 -r1.6
--- MessageExchange.java 29 Oct 2002 05:15:29 -0000 1.5
+++ MessageExchange.java 29 Oct 2002 06:39:57 -0000 1.6
@@ -57,6 +57,8 @@
import org.apache.axis.AxisFault;
import org.apache.axis.MessageContext;
+import java.util.Map;
+
/**
* Represents the boundary interface through which messages
* are exchanged. This interface supports both push and pull
@@ -195,4 +197,64 @@
public MessageExchangeStatusListener getMessageExchangeStatusListener();
+
+
+ /**
+ * @param String The id of the feature to enable
+ * @throws AxisFault
+ */
+ public void enableFeature(String featureId)
+ throws AxisFault;
+
+ /**
+ * @param String The id of the feature to disable
+ * @throws AxisFault
+ */
+ public void disableFeature(String featureId)
+ throws AxisFault;
+
+ /**
+ * @param String The id of the feature to check
+ * @return boolean
+ * @throws AxisFault
+ */
+ public boolean isFeatureEnabled(String featureId)
+ throws AxisFault;
+
+ /**
+ * @param String The id of the property
+ * @param Object The value of the property
+ */
+ public void setProperty(
+ String propertyId,
+ Object propertyValue);
+
+ /**
+ * @param String The id of the property
+ * @return Object The value of the property
+ */
+ public Object getProperty(
+ String propertyId);
+
+ /**
+ * @param String The id of the property
+ * @param Object The default value of the property
+ * @return Object The value of the property
+ */
+ public Object getProperty(
+ String propertyId,
+ Object defaultValue);
+
+ /**
+ * @return java.lang.Map The collection of properties
+ */
+ public Map getProperties();
+
+ /**
+ * @param java.lang.Map The collection of properties
+ */
+ public void setProperties(Map properties);
+
+ public void clearProperties();
+
}
1.5 +11 -0
xml-axis/java/src/org/apache/axis/ime/MessageExchangeFactory.java
Index: MessageExchangeFactory.java
===================================================================
RCS file:
/home/cvs/xml-axis/java/src/org/apache/axis/ime/MessageExchangeFactory.java,v
retrieving revision 1.4
retrieving revision 1.5
diff -u -r1.4 -r1.5
--- MessageExchangeFactory.java 28 Oct 2002 21:59:45 -0000 1.4
+++ MessageExchangeFactory.java 29 Oct 2002 06:39:57 -0000 1.5
@@ -56,6 +56,8 @@
import org.apache.axis.AxisFault;
+import java.util.Map;
+
/**
* @author James M Snell ([EMAIL PROTECTED])
*/
@@ -68,4 +70,13 @@
public MessageExchange createMessageExchange()
throws AxisFault;
+ /**
+ * @param java.lang.Map Collection of properties
+ * @param String Array of feature id's to enable
+ * @return ConfigurableMessageExchange
+ */
+ public MessageExchange createMessageExchange(
+ Map properties,
+ String[] enabledFeatures)
+ throws AxisFault;
}
1.5 +83 -0
xml-axis/java/src/org/apache/axis/ime/internal/MessageExchangeImpl.java
Index: MessageExchangeImpl.java
===================================================================
RCS file:
/home/cvs/xml-axis/java/src/org/apache/axis/ime/internal/MessageExchangeImpl.java,v
retrieving revision 1.4
retrieving revision 1.5
diff -u -r1.4 -r1.5
--- MessageExchangeImpl.java 29 Oct 2002 06:15:08 -0000 1.4
+++ MessageExchangeImpl.java 29 Oct 2002 06:39:57 -0000 1.5
@@ -67,6 +67,8 @@
import org.apache.axis.ime.MessageExchangeLifecycle;
import org.apache.axis.ime.internal.util.uuid.UUIDGenFactory;
+import java.util.Map;
+
/**
* @author James M Snell ([EMAIL PROTECTED])
*/
@@ -272,6 +274,87 @@
public synchronized MessageExchangeStatusListener
getMessageExchangeStatusListener() {
return this.statusListener;
}
+
+ /**
+ * Unsupported for now
+ * @see org.apache.axis.ime.MessageExchange@enableFeature(featureId)
+ */
+ public void enableFeature(String featureId)
+ throws AxisFault {
+ throw new
UnsupportedOperationException(Messages.getMessage("unsupportedOperationException00"));
+ }
+
+ /**
+ * Unsupported for now
+ * @see org.apache.axis.ime.MessageExchange@disableFeature(featureId)
+ */
+ public void disableFeature(String featureId)
+ throws AxisFault {
+ throw new
UnsupportedOperationException(Messages.getMessage("unsupportedOperationException00"));
+ }
+
+ /**
+ * Unsupported for now
+ * @see org.apache.axis.ime.MessageExchange@isFeatureEnabled(featureId)
+ */
+ public boolean isFeatureEnabled(String featureId)
+ throws AxisFault {
+ throw new
UnsupportedOperationException(Messages.getMessage("unsupportedOperationException00"));
+ }
+
+ /**
+ * Unsupported for now
+ * @see org.apache.axis.ime.MessageExchange@setProperty(String,Object)
+ */
+ public void setProperty(
+ String propertyId,
+ Object propertyValue) {
+ throw new
UnsupportedOperationException(Messages.getMessage("unsupportedOperationException00"));
+ }
+
+ /**
+ * Unsupported for now
+ * @see org.apache.axis.ime.MessageExchange@getProperty(String)
+ */
+ public Object getProperty(
+ String propertyId) {
+ throw new
UnsupportedOperationException(Messages.getMessage("unsupportedOperationException00"));
+ }
+
+ /**
+ * Unsupported for now
+ * @see org.apache.axis.ime.MessageExchange@getProperty(String,Object)
+ */
+ public Object getProperty(
+ String propertyId,
+ Object defaultValue) {
+ throw new
UnsupportedOperationException(Messages.getMessage("unsupportedOperationException00"));
+ }
+
+ /**
+ * Unsupported for now
+ * @see org.apache.axis.ime.MessageExchange@getProperties()
+ */
+ public Map getProperties() {
+ throw new
UnsupportedOperationException(Messages.getMessage("unsupportedOperationException00"));
+ }
+
+ /**
+ * Unsupported for now
+ * @see org.apache.axis.ime.MessageExchange@setProperties(java.lang.Map)
+ */
+ public void setProperties(Map properties) {
+ throw new
UnsupportedOperationException(Messages.getMessage("unsupportedOperationException00"));
+ }
+
+ /**
+ * Unsupported for now
+ * @see org.apache.axis.ime.MessageExchange@clearProperties()
+ */
+ public void clearProperties() {
+ throw new
UnsupportedOperationException(Messages.getMessage("unsupportedOperationException00"));
+ }
+
// -- Utility Classes --- //
1.4 +18 -1
xml-axis/java/src/org/apache/axis/ime/internal/MessageExchangeProvider.java
Index: MessageExchangeProvider.java
===================================================================
RCS file:
/home/cvs/xml-axis/java/src/org/apache/axis/ime/internal/MessageExchangeProvider.java,v
retrieving revision 1.3
retrieving revision 1.4
diff -u -r1.3 -r1.4
--- MessageExchangeProvider.java 29 Oct 2002 05:15:29 -0000 1.3
+++ MessageExchangeProvider.java 29 Oct 2002 06:39:57 -0000 1.4
@@ -56,6 +56,7 @@
package org.apache.axis.ime.internal;
import org.apache.axis.i18n.Messages;
+import org.apache.axis.AxisFault;
import org.apache.axis.MessageContext;
import org.apache.axis.ime.MessageExchange;
import org.apache.axis.ime.MessageContextListener;
@@ -66,6 +67,8 @@
import org.apache.axis.ime.internal.util.KeyedBuffer;
import org.apache.axis.ime.internal.util.NonPersistentKeyedBuffer;
+import java.util.Map;
+
/**
* @author James M Snell ([EMAIL PROTECTED])
*/
@@ -86,9 +89,23 @@
protected abstract ReceivedMessageDispatchPolicy
getReceivedMessageDispatchPolicy();
- public MessageExchange createMessageExchange() {
+ public MessageExchange createMessageExchange()
+ throws AxisFault {
return new MessageExchangeImpl(this);
}
+
+ /**
+ * Unsupported for now
+ */
+ public MessageExchange createMessageExchange(
+ Map properties,
+ String[] enabledFeatures)
+ throws AxisFault {
+ throw AxisFault.makeFault(
+ new UnsupportedOperationException(
+ Messages.getMessage("unsupportedOperationException00")));
+ }
+
public void init() {
init(DEFAULT_THREAD_COUNT);
