Author: david.lloyd(a)jboss.com Date: 2008-02-22 16:13:40 -0500 (Fri, 22 Feb 2008) New Revision: 3486 Removed: remoting3/trunk/mc-deployers/src/main/java/org/jboss/cx/remoting/deployer/EndpointBean.java remoting3/trunk/mc-deployers/src/main/java/org/jboss/cx/remoting/deployer/EndpointDeployer.java remoting3/trunk/mc-deployers/src/main/java/org/jboss/cx/remoting/deployer/EndpointKernelDeployment.java remoting3/trunk/mc-deployers/src/main/java/org/jboss/cx/remoting/deployer/EndpointMetaData.java remoting3/trunk/mc-deployers/src/main/java/org/jboss/cx/remoting/deployer/ProtocolBean.java remoting3/trunk/mc-deployers/src/main/java/org/jboss/cx/remoting/deployer/ServiceBean.java Log: Let's try again... Deleted: remoting3/trunk/mc-deployers/src/main/java/org/jboss/cx/remoting/deployer/EndpointBean.java =================================================================== --- remoting3/trunk/mc-deployers/src/main/java/org/jboss/cx/remoting/deployer/EndpointBean.java 2008-02-22 17:23:32 UTC (rev 3485) +++ remoting3/trunk/mc-deployers/src/main/java/org/jboss/cx/remoting/deployer/EndpointBean.java 2008-02-22 21:13:40 UTC (rev 3486) @@ -1,45 +0,0 @@ -package org.jboss.cx.remoting.deployer; - -import org.jboss.cx.remoting.Endpoint; -import org.jboss.cx.remoting.spi.EndpointProvider; - -/** - * - */ -public final class EndpointBean { - private EndpointProvider provider; - private Endpoint endpoint; - private String endpointName; - - public Endpoint getEndpoint() { - return endpoint; - } - - public EndpointProvider getProvider() { - return provider; - } - - public void setProvider(final EndpointProvider provider) { - this.provider = provider; - } - - public String getEndpointName() { - return endpointName; - } - - public void setEndpointName(final String endpointName) { - this.endpointName = endpointName; - } - - public void start() { - endpoint = provider.createEndpoint(endpointName); - } - - public void stop() { - try { - endpoint.shutdown(); - } finally { - endpoint = null; - } - } -} Deleted: remoting3/trunk/mc-deployers/src/main/java/org/jboss/cx/remoting/deployer/EndpointDeployer.java =================================================================== --- remoting3/trunk/mc-deployers/src/main/java/org/jboss/cx/remoting/deployer/EndpointDeployer.java 2008-02-22 17:23:32 UTC (rev 3485) +++ remoting3/trunk/mc-deployers/src/main/java/org/jboss/cx/remoting/deployer/EndpointDeployer.java 2008-02-22 21:13:40 UTC (rev 3486) @@ -1,32 +0,0 @@ -package org.jboss.cx.remoting.deployer; - -import org.jboss.cx.remoting.spi.EndpointProvider; -import org.jboss.cx.remoting.log.Logger; -import org.jboss.deployers.spi.deployer.helpers.AbstractSimpleRealDeployer; -import org.jboss.deployers.spi.DeploymentException; -import org.jboss.deployers.structure.spi.DeploymentUnit; - -/** - * This is the real endpoint deployer. It takes an endpoint deployment and deployes it. - */ -public final class EndpointDeployer extends AbstractSimpleRealDeployer<EndpointKernelDeployment> { - private static final Logger log = Logger.getLogger(EndpointDeployer.class); - - private EndpointProvider provider; - - public EndpointDeployer() { - super(EndpointKernelDeployment.class); - } - - public EndpointProvider getProvider() { - return provider; - } - - public void setProvider(final EndpointProvider provider) { - log.debug("Setting endpoint provider to %s", provider); - this.provider = provider; - } - - public void deploy(final DeploymentUnit deploymentUnit, final EndpointKernelDeployment kernelDeployment) throws DeploymentException { - } -} Deleted: remoting3/trunk/mc-deployers/src/main/java/org/jboss/cx/remoting/deployer/EndpointKernelDeployment.java =================================================================== --- remoting3/trunk/mc-deployers/src/main/java/org/jboss/cx/remoting/deployer/EndpointKernelDeployment.java 2008-02-22 17:23:32 UTC (rev 3485) +++ remoting3/trunk/mc-deployers/src/main/java/org/jboss/cx/remoting/deployer/EndpointKernelDeployment.java 2008-02-22 21:13:40 UTC (rev 3486) @@ -1,10 +0,0 @@ -package org.jboss.cx.remoting.deployer; - -import org.jboss.kernel.plugins.deployment.AbstractKernelDeployment; -import org.jboss.cx.remoting.Endpoint; - -/** - * - */ -public final class EndpointKernelDeployment extends AbstractKernelDeployment { -} Deleted: remoting3/trunk/mc-deployers/src/main/java/org/jboss/cx/remoting/deployer/EndpointMetaData.java =================================================================== --- remoting3/trunk/mc-deployers/src/main/java/org/jboss/cx/remoting/deployer/EndpointMetaData.java 2008-02-22 17:23:32 UTC (rev 3485) +++ remoting3/trunk/mc-deployers/src/main/java/org/jboss/cx/remoting/deployer/EndpointMetaData.java 2008-02-22 21:13:40 UTC (rev 3486) @@ -1,16 +0,0 @@ -package org.jboss.cx.remoting.deployer; - -/** - * - */ -public final class EndpointMetaData { - private String endpointName; - - public String getEndpointName() { - return endpointName; - } - - public void setEndpointName(final String endpointName) { - this.endpointName = endpointName; - } -} Deleted: remoting3/trunk/mc-deployers/src/main/java/org/jboss/cx/remoting/deployer/ProtocolBean.java =================================================================== --- remoting3/trunk/mc-deployers/src/main/java/org/jboss/cx/remoting/deployer/ProtocolBean.java 2008-02-22 17:23:32 UTC (rev 3485) +++ remoting3/trunk/mc-deployers/src/main/java/org/jboss/cx/remoting/deployer/ProtocolBean.java 2008-02-22 21:13:40 UTC (rev 3486) @@ -1,43 +0,0 @@ -package org.jboss.cx.remoting.deployer; - -import org.jboss.cx.remoting.Endpoint; -import org.jboss.cx.remoting.RemotingException; -import org.jboss.cx.remoting.spi.protocol.ProtocolRegistrationSpec; -import org.jboss.cx.remoting.spi.protocol.ProtocolRegistration; - -/** - * - */ -public final class ProtocolBean { - private Endpoint endpoint; - private String scheme; - private ProtocolRegistrationSpec registrationSpec; - private ProtocolRegistration registration; - - public Endpoint getEndpoint() { - return endpoint; - } - - public void setEndpoint(final Endpoint endpoint) { - this.endpoint = endpoint; - } - - public void create() throws RemotingException { - registrationSpec = ProtocolRegistrationSpec.DEFAULT - .setScheme(scheme) - .setProtocolHandlerFactory(null); - registration = endpoint.registerProtocol(registrationSpec); - } - - public void start() { - registration.start(); - } - - public void stop() { - registration.stop(); - } - - public void destroy() { - registration.unregister(); - } -} Deleted: remoting3/trunk/mc-deployers/src/main/java/org/jboss/cx/remoting/deployer/ServiceBean.java =================================================================== --- remoting3/trunk/mc-deployers/src/main/java/org/jboss/cx/remoting/deployer/ServiceBean.java 2008-02-22 17:23:32 UTC (rev 3485) +++ remoting3/trunk/mc-deployers/src/main/java/org/jboss/cx/remoting/deployer/ServiceBean.java 2008-02-22 21:13:40 UTC (rev 3486) @@ -1,90 +0,0 @@ -package org.jboss.cx.remoting.deployer; - -import org.jboss.cx.remoting.ServiceDeploymentSpec; -import org.jboss.cx.remoting.RequestListener; -import org.jboss.cx.remoting.Endpoint; -import org.jboss.cx.remoting.RemotingException; -import org.jboss.cx.remoting.spi.Registration; - -/** - * - */ -public final class ServiceBean<I,O> { - private Class<I> requestType; - private Class<O> replyType; - private String serviceGroupName; - private String serviceType; - private RequestListener<I,O> requestListener; - private Endpoint endpoint; - private Registration registration; - - public Class<I> getRequestType() { - return requestType; - } - - public void setRequestType(final Class<I> requestType) { - this.requestType = requestType; - } - - public Class<O> getReplyType() { - return replyType; - } - - public void setReplyType(final Class<O> replyType) { - this.replyType = replyType; - } - - public String getServiceGroupName() { - return serviceGroupName; - } - - public void setServiceGroupName(final String serviceGroupName) { - this.serviceGroupName = serviceGroupName; - } - - public String getServiceType() { - return serviceType; - } - - public void setServiceType(final String serviceType) { - this.serviceType = serviceType; - } - - public RequestListener<I, O> getRequestListener() { - return requestListener; - } - - public void setRequestListener(final RequestListener<I, O> requestListener) { - this.requestListener = requestListener; - } - - public Endpoint getEndpoint() { - return endpoint; - } - - public void setEndpoint(final Endpoint endpoint) { - this.endpoint = endpoint; - } - - public void create() throws RemotingException { - final ServiceDeploymentSpec<?, ?> deploymentSpec = ServiceDeploymentSpec.DEFAULT - .setRequestType(requestType) - .setReplyType(replyType) - .setServiceGroupName(serviceGroupName) - .setServiceType(serviceType) - .setRequestListener(requestListener); - registration = endpoint.deployService(deploymentSpec); - } - - public void start() { - registration.start(); - } - - public void stop() { - registration.stop(); - } - - public void destroy() { - registration.unregister(); - } -}