[jboss-cvs] JBoss Messaging SVN: r1909 - in trunk/src/main/org/jboss/messaging/core/plugin: . postoffice/cluster postoffice/cluster/jchannelfactory
jboss-cvs-commits at lists.jboss.org
jboss-cvs-commits at lists.jboss.org
Sat Jan 6 01:08:31 EST 2007
Author: clebert.suconic at jboss.com
Date: 2007-01-06 01:08:03 -0500 (Sat, 06 Jan 2007)
New Revision: 1909
Added:
trunk/src/main/org/jboss/messaging/core/plugin/postoffice/cluster/jchannelfactory/
trunk/src/main/org/jboss/messaging/core/plugin/postoffice/cluster/jchannelfactory/JChannelFactory.java
trunk/src/main/org/jboss/messaging/core/plugin/postoffice/cluster/jchannelfactory/MultiplexorJChannelFactory.java
trunk/src/main/org/jboss/messaging/core/plugin/postoffice/cluster/jchannelfactory/XMLJChannelFactory.java
Removed:
trunk/src/main/org/jboss/messaging/core/plugin/postoffice/cluster/channelfactory/
trunk/src/main/org/jboss/messaging/core/plugin/postoffice/cluster/jchannelfactory/ChannelFactory.java
trunk/src/main/org/jboss/messaging/core/plugin/postoffice/cluster/jchannelfactory/MultiplexorChannelFactory.java
trunk/src/main/org/jboss/messaging/core/plugin/postoffice/cluster/jchannelfactory/NameChannelFactory.java
trunk/src/main/org/jboss/messaging/core/plugin/postoffice/cluster/jchannelfactory/XMLChannelFactory.java
Modified:
trunk/src/main/org/jboss/messaging/core/plugin/ClusteredPostOfficeService.java
trunk/src/main/org/jboss/messaging/core/plugin/postoffice/cluster/DefaultClusteredPostOffice.java
Log:
http://jira.jboss.org/jira/browse/JBMESSAGING-578 - Refactoring packages
Modified: trunk/src/main/org/jboss/messaging/core/plugin/ClusteredPostOfficeService.java
===================================================================
--- trunk/src/main/org/jboss/messaging/core/plugin/ClusteredPostOfficeService.java 2007-01-06 03:36:50 UTC (rev 1908)
+++ trunk/src/main/org/jboss/messaging/core/plugin/ClusteredPostOfficeService.java 2007-01-06 06:08:03 UTC (rev 1909)
@@ -43,9 +43,9 @@
import org.jboss.messaging.core.plugin.postoffice.cluster.DefaultFailoverMapper;
import org.jboss.messaging.core.plugin.postoffice.cluster.MessagePullPolicy;
import org.jboss.messaging.core.plugin.postoffice.cluster.Peer;
-import org.jboss.messaging.core.plugin.postoffice.cluster.channelfactory.ChannelFactory;
-import org.jboss.messaging.core.plugin.postoffice.cluster.channelfactory.MultiplexorChannelFactory;
-import org.jboss.messaging.core.plugin.postoffice.cluster.channelfactory.XMLChannelFactory;
+import org.jboss.messaging.core.plugin.postoffice.cluster.jchannelfactory.JChannelFactory;
+import org.jboss.messaging.core.plugin.postoffice.cluster.jchannelfactory.MultiplexorJChannelFactory;
+import org.jboss.messaging.core.plugin.postoffice.cluster.jchannelfactory.XMLJChannelFactory;
import org.jboss.messaging.core.tx.TransactionRepository;
import org.w3c.dom.Element;
@@ -59,7 +59,7 @@
*
* @author <a href="mailto:tim.fox at jboss.com">Tim Fox</a>
* @author <a href="mailto:ovidiu at jboss.org">Ovidiu Feodorov</a>
- * @version <tt>$Revision: 1.1 $</tt>
+ * @version <tt>$Revision$</tt>
*
* $Id$
*
@@ -331,7 +331,7 @@
FilterFactory ff = new SelectorFactory();
FailoverMapper mapper = new DefaultFailoverMapper();
- ChannelFactory channelFactory = null;
+ JChannelFactory JChannelFactory = null;
if (this.channelFactoryName != null)
{
@@ -348,18 +348,18 @@
if (info!=null)
{
log.debug("*********************************** Using Multiplexor");
- channelFactory = new MultiplexorChannelFactory(server, channelFactoryName, channelPartitionName, syncChannelName, asyncChannelName);
+ JChannelFactory = new MultiplexorJChannelFactory(server, channelFactoryName, channelPartitionName, syncChannelName, asyncChannelName);
}
else
{
- log.debug("*********************************** Using XMLChannelFactory");
- channelFactory = new XMLChannelFactory(syncChannelConfig, asyncChannelConfig);
+ log.debug("*********************************** Using XMLJChannelFactory");
+ JChannelFactory = new XMLJChannelFactory(syncChannelConfig, asyncChannelConfig);
}
}
else
{
- log.debug("*********************************** Using XMLChannelFactory");
- channelFactory = new XMLChannelFactory(syncChannelConfig, asyncChannelConfig);
+ log.debug("*********************************** Using XMLJChannelFactory");
+ JChannelFactory = new XMLJChannelFactory(syncChannelConfig, asyncChannelConfig);
}
postOffice = new DefaultClusteredPostOffice(ds, tm, sqlProperties,
@@ -367,7 +367,7 @@
nodeId, officeName, ms,
pm, tr, ff, cf, pool,
groupName,
- channelFactory,
+ JChannelFactory,
stateTimeout, castTimeout,
pullPolicy, rf,
mapper,
Property changes on: trunk/src/main/org/jboss/messaging/core/plugin/ClusteredPostOfficeService.java
___________________________________________________________________
Name: svn:keywords
+ Id LastChangedDate Author Revision
Modified: trunk/src/main/org/jboss/messaging/core/plugin/postoffice/cluster/DefaultClusteredPostOffice.java
===================================================================
--- trunk/src/main/org/jboss/messaging/core/plugin/postoffice/cluster/DefaultClusteredPostOffice.java 2007-01-06 03:36:50 UTC (rev 1908)
+++ trunk/src/main/org/jboss/messaging/core/plugin/postoffice/cluster/DefaultClusteredPostOffice.java 2007-01-06 06:08:03 UTC (rev 1909)
@@ -68,7 +68,7 @@
import org.jboss.messaging.core.plugin.postoffice.Binding;
import org.jboss.messaging.core.plugin.postoffice.DefaultBinding;
import org.jboss.messaging.core.plugin.postoffice.DefaultPostOffice;
-import org.jboss.messaging.core.plugin.postoffice.cluster.channelfactory.ChannelFactory;
+import org.jboss.messaging.core.plugin.postoffice.cluster.jchannelfactory.JChannelFactory;
import org.jboss.messaging.core.tx.Transaction;
import org.jboss.messaging.core.tx.TransactionRepository;
import org.jboss.messaging.util.StreamUtils;
@@ -92,7 +92,7 @@
* @author <a href="mailto:tim.fox at jboss.com">Tim Fox</a>
* @author <a href="mailto:ovidiu at jboss.org">Ovidiu Feodorov</a>
* @author <a href="mailto:clebert.suconic at jboss.com">Clebert Suconic</a>
- * @version <tt>$Revision: 1.1 $</tt>
+ * @version <tt>$Revision$</tt>
*
* $Id$
*
@@ -163,7 +163,7 @@
private volatile boolean started;
private volatile boolean stopping;
- private ChannelFactory channelFactory;
+ private JChannelFactory JChannelFactory;
private Channel syncChannel;
@@ -231,7 +231,7 @@
ConditionFactory conditionFactory,
QueuedExecutorPool pool,
String groupName,
- ChannelFactory channelFactory,
+ JChannelFactory JChannelFactory,
long stateTimeout, long castTimeout,
MessagePullPolicy redistributionPolicy,
ClusterRouterFactory rf,
@@ -274,7 +274,7 @@
viewExecutor = new QueuedExecutor();
- this.channelFactory = channelFactory;
+ this.JChannelFactory = JChannelFactory;
}
// MessagingComponent overrides -----------------------------------------------------------------
@@ -288,8 +288,8 @@
if (trace) { log.trace(this + " starting"); }
- this.syncChannel = channelFactory.createSyncChannel();
- this.asyncChannel = channelFactory.createASyncChannel();
+ this.syncChannel = JChannelFactory.createSyncChannel();
+ this.asyncChannel = JChannelFactory.createASyncChannel();
// We don't want to receive local messages on any of the channels
syncChannel.setOpt(Channel.LOCAL, Boolean.FALSE);
Property changes on: trunk/src/main/org/jboss/messaging/core/plugin/postoffice/cluster/DefaultClusteredPostOffice.java
___________________________________________________________________
Name: svn:keywords
+ Id LastChangedDate Author Revision
Copied: trunk/src/main/org/jboss/messaging/core/plugin/postoffice/cluster/jchannelfactory (from rev 1892, trunk/src/main/org/jboss/messaging/core/plugin/postoffice/cluster/channelfactory)
Deleted: trunk/src/main/org/jboss/messaging/core/plugin/postoffice/cluster/jchannelfactory/ChannelFactory.java
===================================================================
--- trunk/src/main/org/jboss/messaging/core/plugin/postoffice/cluster/channelfactory/ChannelFactory.java 2007-01-04 22:02:16 UTC (rev 1892)
+++ trunk/src/main/org/jboss/messaging/core/plugin/postoffice/cluster/jchannelfactory/ChannelFactory.java 2007-01-06 06:08:03 UTC (rev 1909)
@@ -1,15 +0,0 @@
-package org.jboss.messaging.core.plugin.postoffice.cluster.channelfactory;
-
-import org.jgroups.JChannel;
-
-/**
- * @author <a href="mailto:clebert.suconic at jboss.org">Clebert Suconic</a>
- * @version <tt>$Revision:$</tt>
- * <p/>
- * $Id$
- */
-public interface ChannelFactory
-{
- public JChannel createSyncChannel() throws Exception;
- public JChannel createASyncChannel() throws Exception;
-}
Copied: trunk/src/main/org/jboss/messaging/core/plugin/postoffice/cluster/jchannelfactory/JChannelFactory.java (from rev 1892, trunk/src/main/org/jboss/messaging/core/plugin/postoffice/cluster/channelfactory/ChannelFactory.java)
===================================================================
--- trunk/src/main/org/jboss/messaging/core/plugin/postoffice/cluster/channelfactory/ChannelFactory.java 2007-01-04 22:02:16 UTC (rev 1892)
+++ trunk/src/main/org/jboss/messaging/core/plugin/postoffice/cluster/jchannelfactory/JChannelFactory.java 2007-01-06 06:08:03 UTC (rev 1909)
@@ -0,0 +1,15 @@
+package org.jboss.messaging.core.plugin.postoffice.cluster.jchannelfactory;
+
+import org.jgroups.JChannel;
+
+/**
+ * @author <a href="mailto:clebert.suconic at jboss.org">Clebert Suconic</a>
+ * @version <tt>$Revision$</tt>
+ * <p/>
+ * $Id$
+ */
+public interface JChannelFactory
+{
+ public JChannel createSyncChannel() throws Exception;
+ public JChannel createASyncChannel() throws Exception;
+}
Property changes on: trunk/src/main/org/jboss/messaging/core/plugin/postoffice/cluster/jchannelfactory/JChannelFactory.java
___________________________________________________________________
Name: svn:keywords
+ Id LastChangedDate Author Revision
Deleted: trunk/src/main/org/jboss/messaging/core/plugin/postoffice/cluster/jchannelfactory/MultiplexorChannelFactory.java
===================================================================
--- trunk/src/main/org/jboss/messaging/core/plugin/postoffice/cluster/channelfactory/MultiplexorChannelFactory.java 2007-01-04 22:02:16 UTC (rev 1892)
+++ trunk/src/main/org/jboss/messaging/core/plugin/postoffice/cluster/jchannelfactory/MultiplexorChannelFactory.java 2007-01-06 06:08:03 UTC (rev 1909)
@@ -1,138 +0,0 @@
-/*
- * JBoss, Home of Professional Open Source
- * Copyright 2005, JBoss Inc., and individual contributors as indicated
- * by the @authors tag. See the copyright.txt in the distribution for a
- * full listing of individual contributors.
- *
- * This is free software; you can redistribute it and/or modify it
- * under the terms of the GNU Lesser General Public License as
- * published by the Free Software Foundation; either version 2.1 of
- * the License, or (at your option) any later version.
- *
- * This software is distributed in the hope that it will be useful,
- * but WITHOUT ANY WARRANTY; without even the implied warranty of
- * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
- * Lesser General Public License for more details.
- *
- * You should have received a copy of the GNU Lesser General Public
- * License along with this software; if not, write to the Free
- * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
- * 02110-1301 USA, or see the FSF site: http://www.fsf.org.
- */
-
-package org.jboss.messaging.core.plugin.postoffice.cluster.channelfactory;
-
-import javax.management.MBeanServer;
-import javax.management.ObjectName;
-import org.jgroups.JChannel;
-
-/**
- * A ChannelFactory that will use the MBean JChannelFactory interface
- *
- * @author <a href="mailto:clebert.suconic at jboss.org">Clebert Suconic</a>
- * @version <tt>$Revision:$</tt>
- * <p/>
- * $Id$
- */
-public class MultiplexorChannelFactory implements ChannelFactory
-{
-
- // Constants
- private static final String[] MUX_SIGNATURE = new String[]{"java.lang.String", "java.lang.String", "boolean", "java.lang.String"};
-
- // Attributes
- MBeanServer server;
- ObjectName channelFactory;
- String asyncStack;
- String syncStack;
- String uniqueID;
- private static final String MUX_OPERATION = "createMultiplexerChannel";
-
- // Static
-
- // Constructors
-
- public MultiplexorChannelFactory(MBeanServer server,
- ObjectName channelFactory,
- String uniqueID,
- String syncStack,
- String asyncStack)
- {
- this.server = server;
- this.channelFactory = channelFactory;
- this.uniqueID = uniqueID;
- this.asyncStack = asyncStack;
- this.syncStack = syncStack;
- }
-
- // Public
-
- public MBeanServer getServer()
- {
- return server;
- }
-
- public void setServer(MBeanServer server)
- {
- this.server = server;
- }
-
- public ObjectName getChannelFactory()
- {
- return channelFactory;
- }
-
- public void setChannelFactory(ObjectName channelFactory)
- {
- this.channelFactory = channelFactory;
- }
-
- public String getAsyncStack()
- {
- return asyncStack;
- }
-
- public void setAsyncStack(String asyncStack)
- {
- this.asyncStack = asyncStack;
- }
-
- public String getSyncStack()
- {
- return syncStack;
- }
-
- public void setSyncStack(String syncStack)
- {
- this.syncStack = syncStack;
- }
-
- public String getUniqueID()
- {
- return uniqueID;
- }
-
- public void setUniqueID(String uniqueID)
- {
- this.uniqueID = uniqueID;
- }
-
- public JChannel createSyncChannel() throws Exception
- {
- return (JChannel) server.invoke(this.channelFactory, MUX_OPERATION, new Object[]{syncStack, uniqueID, Boolean.TRUE, uniqueID}, MUX_SIGNATURE);
- }
-
- public JChannel createASyncChannel() throws Exception
- {
- return (JChannel) server.invoke(this.channelFactory, MUX_OPERATION, new Object[]{asyncStack, uniqueID, Boolean.TRUE, uniqueID}, MUX_SIGNATURE);
- }
-
- // Package protected
-
- // Protected
-
- // Private
-
- // Inner classes
-
-}
Copied: trunk/src/main/org/jboss/messaging/core/plugin/postoffice/cluster/jchannelfactory/MultiplexorJChannelFactory.java (from rev 1892, trunk/src/main/org/jboss/messaging/core/plugin/postoffice/cluster/channelfactory/MultiplexorChannelFactory.java)
===================================================================
--- trunk/src/main/org/jboss/messaging/core/plugin/postoffice/cluster/channelfactory/MultiplexorChannelFactory.java 2007-01-04 22:02:16 UTC (rev 1892)
+++ trunk/src/main/org/jboss/messaging/core/plugin/postoffice/cluster/jchannelfactory/MultiplexorJChannelFactory.java 2007-01-06 06:08:03 UTC (rev 1909)
@@ -0,0 +1,138 @@
+/*
+ * JBoss, Home of Professional Open Source
+ * Copyright 2005, JBoss Inc., and individual contributors as indicated
+ * by the @authors tag. See the copyright.txt in the distribution for a
+ * full listing of individual contributors.
+ *
+ * This is free software; you can redistribute it and/or modify it
+ * under the terms of the GNU Lesser General Public License as
+ * published by the Free Software Foundation; either version 2.1 of
+ * the License, or (at your option) any later version.
+ *
+ * This software is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
+ * Lesser General Public License for more details.
+ *
+ * You should have received a copy of the GNU Lesser General Public
+ * License along with this software; if not, write to the Free
+ * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
+ * 02110-1301 USA, or see the FSF site: http://www.fsf.org.
+ */
+
+package org.jboss.messaging.core.plugin.postoffice.cluster.jchannelfactory;
+
+import javax.management.MBeanServer;
+import javax.management.ObjectName;
+import org.jgroups.JChannel;
+
+/**
+ * A JChannelFactory that will use the MBean JChannelFactory interface
+ *
+ * @author <a href="mailto:clebert.suconic at jboss.org">Clebert Suconic</a>
+ * @version <tt>$Revision$</tt>
+ * <p/>
+ * $Id$
+ */
+public class MultiplexorJChannelFactory implements JChannelFactory
+{
+
+ // Constants
+ private static final String[] MUX_SIGNATURE = new String[]{"java.lang.String", "java.lang.String", "boolean", "java.lang.String"};
+
+ // Attributes
+ MBeanServer server;
+ ObjectName channelFactory;
+ String asyncStack;
+ String syncStack;
+ String uniqueID;
+ private static final String MUX_OPERATION = "createMultiplexerChannel";
+
+ // Static
+
+ // Constructors
+
+ public MultiplexorJChannelFactory(MBeanServer server,
+ ObjectName channelFactory,
+ String uniqueID,
+ String syncStack,
+ String asyncStack)
+ {
+ this.server = server;
+ this.channelFactory = channelFactory;
+ this.uniqueID = uniqueID;
+ this.asyncStack = asyncStack;
+ this.syncStack = syncStack;
+ }
+
+ // Public
+
+ public MBeanServer getServer()
+ {
+ return server;
+ }
+
+ public void setServer(MBeanServer server)
+ {
+ this.server = server;
+ }
+
+ public ObjectName getChannelFactory()
+ {
+ return channelFactory;
+ }
+
+ public void setChannelFactory(ObjectName channelFactory)
+ {
+ this.channelFactory = channelFactory;
+ }
+
+ public String getAsyncStack()
+ {
+ return asyncStack;
+ }
+
+ public void setAsyncStack(String asyncStack)
+ {
+ this.asyncStack = asyncStack;
+ }
+
+ public String getSyncStack()
+ {
+ return syncStack;
+ }
+
+ public void setSyncStack(String syncStack)
+ {
+ this.syncStack = syncStack;
+ }
+
+ public String getUniqueID()
+ {
+ return uniqueID;
+ }
+
+ public void setUniqueID(String uniqueID)
+ {
+ this.uniqueID = uniqueID;
+ }
+
+ public JChannel createSyncChannel() throws Exception
+ {
+ return (JChannel) server.invoke(this.channelFactory, MUX_OPERATION, new Object[]{syncStack, uniqueID, Boolean.TRUE, uniqueID}, MUX_SIGNATURE);
+ }
+
+ public JChannel createASyncChannel() throws Exception
+ {
+ return (JChannel) server.invoke(this.channelFactory, MUX_OPERATION, new Object[]{asyncStack, uniqueID, Boolean.TRUE, uniqueID}, MUX_SIGNATURE);
+ }
+
+ // Package protected
+
+ // Protected
+
+ // Private
+
+ // Inner classes
+
+}
Property changes on: trunk/src/main/org/jboss/messaging/core/plugin/postoffice/cluster/jchannelfactory/MultiplexorJChannelFactory.java
___________________________________________________________________
Name: svn:keywords
+ Id LastChangedDate Author Revision
Deleted: trunk/src/main/org/jboss/messaging/core/plugin/postoffice/cluster/jchannelfactory/NameChannelFactory.java
===================================================================
--- trunk/src/main/org/jboss/messaging/core/plugin/postoffice/cluster/channelfactory/NameChannelFactory.java 2007-01-04 22:02:16 UTC (rev 1892)
+++ trunk/src/main/org/jboss/messaging/core/plugin/postoffice/cluster/jchannelfactory/NameChannelFactory.java 2007-01-06 06:08:03 UTC (rev 1909)
@@ -1,96 +0,0 @@
-/*
- * JBoss, Home of Professional Open Source
- * Copyright 2005, JBoss Inc., and individual contributors as indicated
- * by the @authors tag. See the copyright.txt in the distribution for a
- * full listing of individual contributors.
- *
- * This is free software; you can redistribute it and/or modify it
- * under the terms of the GNU Lesser General Public License as
- * published by the Free Software Foundation; either version 2.1 of
- * the License, or (at your option) any later version.
- *
- * This software is distributed in the hope that it will be useful,
- * but WITHOUT ANY WARRANTY; without even the implied warranty of
- * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
- * Lesser General Public License for more details.
- *
- * You should have received a copy of the GNU Lesser General Public
- * License along with this software; if not, write to the Free
- * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
- * 02110-1301 USA, or see the FSF site: http://www.fsf.org.
- */
-
-package org.jboss.messaging.core.plugin.postoffice.cluster.channelfactory;
-
-import org.jgroups.JChannel;
-
-/**
- * A ChannelFactory that will use config names (from channelfactory)
- * @author <a href="mailto:clebert.suconic at jboss.org">Clebert Suconic</a>
- * @version <tt>$Revision:$</tt>
- * <p/>
- * $Id$
- */
-public class NameChannelFactory implements ChannelFactory
-{
-
- // Constants
-
- // Attributes
-
- String asyncConfig;
- String syncConfig;
-
- // Static
-
- // Constructors
-
- public NameChannelFactory(String syncConfig, String asyncConfig)
- {
- this.syncConfig = syncConfig;
- this.asyncConfig = asyncConfig;
- }
-
- // Public
-
- public String getAsyncConfig()
- {
- return asyncConfig;
- }
-
- public void setAsyncConfig(String asyncConfig)
- {
- this.asyncConfig = asyncConfig;
- }
-
- public String getSyncConfig()
- {
- return syncConfig;
- }
-
- public void setSyncConfig(String syncConfig)
- {
- this.syncConfig = syncConfig;
- }
-
- // ChannelFactory implementation
-
- public JChannel createSyncChannel() throws Exception
- {
- return new JChannel(syncConfig);
- }
-
- public JChannel createASyncChannel() throws Exception
- {
- return new JChannel(asyncConfig);
- }
-
- // Package protected
-
- // Protected
-
- // Private
-
- // Inner classes
-
-}
Deleted: trunk/src/main/org/jboss/messaging/core/plugin/postoffice/cluster/jchannelfactory/XMLChannelFactory.java
===================================================================
--- trunk/src/main/org/jboss/messaging/core/plugin/postoffice/cluster/channelfactory/XMLChannelFactory.java 2007-01-04 22:02:16 UTC (rev 1892)
+++ trunk/src/main/org/jboss/messaging/core/plugin/postoffice/cluster/jchannelfactory/XMLChannelFactory.java 2007-01-06 06:08:03 UTC (rev 1909)
@@ -1,95 +0,0 @@
-/*
- * JBoss, Home of Professional Open Source
- * Copyright 2005, JBoss Inc., and individual contributors as indicated
- * by the @authors tag. See the copyright.txt in the distribution for a
- * full listing of individual contributors.
- *
- * This is free software; you can redistribute it and/or modify it
- * under the terms of the GNU Lesser General Public License as
- * published by the Free Software Foundation; either version 2.1 of
- * the License, or (at your option) any later version.
- *
- * This software is distributed in the hope that it will be useful,
- * but WITHOUT ANY WARRANTY; without even the implied warranty of
- * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
- * Lesser General Public License for more details.
- *
- * You should have received a copy of the GNU Lesser General Public
- * License along with this software; if not, write to the Free
- * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
- * 02110-1301 USA, or see the FSF site: http://www.fsf.org.
- */
-
-package org.jboss.messaging.core.plugin.postoffice.cluster.channelfactory;
-
-import org.w3c.dom.Element;
-import org.jgroups.JChannel;
-
-/**
- * A ChannelFactory that will use Elements to create channels.
- * @author <a href="mailto:clebert.suconic at jboss.org">Clebert Suconic</a>
- * @version <tt>$Revision:$</tt>
- * <p/>
- * $Id:$
- */
-public class XMLChannelFactory implements ChannelFactory
-{
-
- // Constants
-
- // Attributes
- Element syncConfig;
- Element asyncConfig;
-
- // Static
-
- // Constructors
-
- public XMLChannelFactory(Element syncConfig, Element asyncConfig)
- {
- this.syncConfig = syncConfig;
- this.asyncConfig = asyncConfig;
- }
-
- // Public
-
- public Element getSyncConfig()
- {
- return syncConfig;
- }
-
- public void setSyncConfig(Element syncConfig)
- {
- this.syncConfig = syncConfig;
- }
-
- public Element getAsyncConfig()
- {
- return asyncConfig;
- }
-
- public void setAsyncConfig(Element asyncConfig)
- {
- this.asyncConfig = asyncConfig;
- }
-
- // implementation of ChannelFactory
- public JChannel createSyncChannel() throws Exception
- {
- return new JChannel(syncConfig);
- }
-
- public JChannel createASyncChannel() throws Exception
- {
- return new JChannel(asyncConfig);
- }
-
- // Package protected
-
- // Protected
-
- // Private
-
- // Inner classes
-
-}
Copied: trunk/src/main/org/jboss/messaging/core/plugin/postoffice/cluster/jchannelfactory/XMLJChannelFactory.java (from rev 1892, trunk/src/main/org/jboss/messaging/core/plugin/postoffice/cluster/channelfactory/XMLChannelFactory.java)
===================================================================
--- trunk/src/main/org/jboss/messaging/core/plugin/postoffice/cluster/channelfactory/XMLChannelFactory.java 2007-01-04 22:02:16 UTC (rev 1892)
+++ trunk/src/main/org/jboss/messaging/core/plugin/postoffice/cluster/jchannelfactory/XMLJChannelFactory.java 2007-01-06 06:08:03 UTC (rev 1909)
@@ -0,0 +1,95 @@
+/*
+ * JBoss, Home of Professional Open Source
+ * Copyright 2005, JBoss Inc., and individual contributors as indicated
+ * by the @authors tag. See the copyright.txt in the distribution for a
+ * full listing of individual contributors.
+ *
+ * This is free software; you can redistribute it and/or modify it
+ * under the terms of the GNU Lesser General Public License as
+ * published by the Free Software Foundation; either version 2.1 of
+ * the License, or (at your option) any later version.
+ *
+ * This software is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
+ * Lesser General Public License for more details.
+ *
+ * You should have received a copy of the GNU Lesser General Public
+ * License along with this software; if not, write to the Free
+ * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
+ * 02110-1301 USA, or see the FSF site: http://www.fsf.org.
+ */
+
+package org.jboss.messaging.core.plugin.postoffice.cluster.jchannelfactory;
+
+import org.w3c.dom.Element;
+import org.jgroups.JChannel;
+
+/**
+ * A JChannelFactory that will use Elements to create channels.
+ * @author <a href="mailto:clebert.suconic at jboss.org">Clebert Suconic</a>
+ * @version <tt>$Revision$</tt>
+ * <p/>
+ * $Id$
+ */
+public class XMLJChannelFactory implements JChannelFactory
+{
+
+ // Constants
+
+ // Attributes
+ Element syncConfig;
+ Element asyncConfig;
+
+ // Static
+
+ // Constructors
+
+ public XMLJChannelFactory(Element syncConfig, Element asyncConfig)
+ {
+ this.syncConfig = syncConfig;
+ this.asyncConfig = asyncConfig;
+ }
+
+ // Public
+
+ public Element getSyncConfig()
+ {
+ return syncConfig;
+ }
+
+ public void setSyncConfig(Element syncConfig)
+ {
+ this.syncConfig = syncConfig;
+ }
+
+ public Element getAsyncConfig()
+ {
+ return asyncConfig;
+ }
+
+ public void setAsyncConfig(Element asyncConfig)
+ {
+ this.asyncConfig = asyncConfig;
+ }
+
+ // implementation of JChannelFactory
+ public JChannel createSyncChannel() throws Exception
+ {
+ return new JChannel(syncConfig);
+ }
+
+ public JChannel createASyncChannel() throws Exception
+ {
+ return new JChannel(asyncConfig);
+ }
+
+ // Package protected
+
+ // Protected
+
+ // Private
+
+ // Inner classes
+
+}
Property changes on: trunk/src/main/org/jboss/messaging/core/plugin/postoffice/cluster/jchannelfactory/XMLJChannelFactory.java
___________________________________________________________________
Name: svn:keywords
+ Id LastChangedDate Author Revision
More information about the jboss-cvs-commits
mailing list