hammant 02/01/10 03:18:24
Modified:
src/java/org/apache/avalon/cornerstone/blocks/transport/publishing
AbstractPublisher.java
src/java/org/apache/avalon/cornerstone/blocks/transport/subscription
SocketObjectStreamSubscriber.java
Log:
imprevements to publishing and subscription
Revision Changes Path
1.2 +5 -2
jakarta-avalon-cornerstone/src/java/org/apache/avalon/cornerstone/blocks/transport/publishing/AbstractPublisher.java
Index: AbstractPublisher.java
===================================================================
RCS file:
/home/cvs/jakarta-avalon-cornerstone/src/java/org/apache/avalon/cornerstone/blocks/transport/publishing/AbstractPublisher.java,v
retrieving revision 1.1
retrieving revision 1.2
diff -u -r1.1 -r1.2
--- AbstractPublisher.java 9 Jan 2002 21:40:04 -0000 1.1
+++ AbstractPublisher.java 10 Jan 2002 11:18:24 -0000 1.2
@@ -16,6 +16,7 @@
import org.apache.commons.altrmi.server.ClassRetriever;
import org.apache.commons.altrmi.server.impl.JarFileClassRetriever;
import org.apache.commons.altrmi.server.impl.BaseMobileClassRetriever;
+import org.apache.commons.altrmi.server.impl.NoClassRetriever;
import org.apache.avalon.framework.logger.AbstractLogEnabled;
import org.apache.avalon.framework.activity.Startable;
import org.apache.avalon.framework.activity.Initializable;
@@ -35,7 +36,7 @@
*
*
* @author Paul Hammant <a href="mailto:[EMAIL PROTECTED]">[EMAIL
PROTECTED]</a>
- * @version $Revision: 1.1 $
+ * @version $Revision: 1.2 $
*/
public abstract class AbstractPublisher extends AbstractLogEnabled
implements AltrmiPublisher, Startable, Configurable, Initializable,
Block {
@@ -75,8 +76,10 @@
}
} else if (classRetrieverType.equals("baseMobileClass")) {
mClassRetriever = new BaseMobileClassRetriever();
+ } else if (classRetrieverType.equals("none")) {
+ mClassRetriever = new NoClassRetriever();
} else {
- throw new ConfigurationException("classRetrieverType must be
'baseMobileClass' or 'jarFile'");
+ throw new ConfigurationException("classRetrieverType must be
'baseMobileClass', 'jarFile' or 'none'");
}
}
1.2 +3 -3
jakarta-avalon-cornerstone/src/java/org/apache/avalon/cornerstone/blocks/transport/subscription/SocketObjectStreamSubscriber.java
Index: SocketObjectStreamSubscriber.java
===================================================================
RCS file:
/home/cvs/jakarta-avalon-cornerstone/src/java/org/apache/avalon/cornerstone/blocks/transport/subscription/SocketObjectStreamSubscriber.java,v
retrieving revision 1.1
retrieving revision 1.2
diff -u -r1.1 -r1.2
--- SocketObjectStreamSubscriber.java 9 Jan 2002 21:40:04 -0000 1.1
+++ SocketObjectStreamSubscriber.java 10 Jan 2002 11:18:24 -0000 1.2
@@ -11,7 +11,7 @@
import org.apache.avalon.framework.configuration.Configuration;
import org.apache.avalon.framework.configuration.ConfigurationException;
import org.apache.commons.altrmi.client.impl.rmi.RmiAltrmiHostContext;
-import
org.apache.commons.altrmi.client.impl.socket.PlainSocketAltrmiHostContext;
+import
org.apache.commons.altrmi.client.impl.socket.SocketObjectStreamHostContext;
/**
@@ -19,7 +19,7 @@
*
*
* @author Paul Hammant <a href="mailto:[EMAIL PROTECTED]">[EMAIL
PROTECTED]</a>
- * @version $Revision: 1.1 $
+ * @version $Revision: 1.2 $
*/
public class SocketObjectStreamSubscriber extends AbstractSubscriber {
@@ -50,7 +50,7 @@
*/
public void initialize() throws Exception {
- mHostContext = new PlainSocketAltrmiHostContext(mHost, mPort);
+ mHostContext = new SocketObjectStreamHostContext(mHost, mPort);
super.initialize();
}
}
--
To unsubscribe, e-mail: <mailto:[EMAIL PROTECTED]>
For additional commands, e-mail: <mailto:[EMAIL PROTECTED]>
