[teiid-commits] teiid SVN: r3188 - branches/7.4.x/cache-jbosscache/src/main/java/org/teiid/events/jboss.

[teiid-commits at lists.jboss.org]

Author: shawkins
Date: 2011-05-23 15:32:30 -0400 (Mon, 23 May 2011)
New Revision: 3188

Modified:
   branches/7.4.x/cache-jbosscache/src/main/java/org/teiid/events/jboss/JGroupsEventDistributor.java
Log:
TEIID-1591 changing to depend upon ChannelFactory

Modified: branches/7.4.x/cache-jbosscache/src/main/java/org/teiid/events/jboss/JGroupsEventDistributor.java
===================================================================
--- branches/7.4.x/cache-jbosscache/src/main/java/org/teiid/events/jboss/JGroupsEventDistributor.java	2011-05-23 19:15:59 UTC (rev 3187)
+++ branches/7.4.x/cache-jbosscache/src/main/java/org/teiid/events/jboss/JGroupsEventDistributor.java	2011-05-23 19:32:30 UTC (rev 3188)
@@ -35,7 +35,7 @@
 import org.jboss.util.naming.Util;
 import org.jgroups.Address;
 import org.jgroups.Channel;
-import org.jgroups.JChannelFactory;
+import org.jgroups.ChannelFactory;
 import org.jgroups.ReceiverAdapter;
 import org.jgroups.View;
 import org.jgroups.blocks.GroupRequest;
@@ -58,7 +58,7 @@
 
 	private static final long serialVersionUID = -1140683411842561358L;
 	
-	private transient JChannelFactory channelFactory;
+	private transient ChannelFactory channelFactory;
 	private String multiplexerStack;
 	private String clusterName;
 	private String jndiName;
@@ -71,7 +71,7 @@
 	private transient RpcDispatcher rpcDispatcher;
 	private transient Vector<Address> members;
 	
-	public JChannelFactory getChannelFactory() {
+	public ChannelFactory getChannelFactory() {
 		return channelFactory;
 	}
 	
@@ -99,7 +99,7 @@
 		return clusterName;
 	}
 	
-	public void setChannelFactory(JChannelFactory channelFactory) {
+	public void setChannelFactory(ChannelFactory channelFactory) {
 		this.channelFactory = channelFactory;
 	}
 	
@@ -115,7 +115,7 @@
 		if (this.channelFactory == null) {
 			return; //no need to distribute events
 		}
-		channel = this.channelFactory.createMultiplexerChannel(this.multiplexerStack, null);
+		channel = this.channelFactory.createMultiplexerChannel(this.multiplexerStack, "teiid-events"); //$NON-NLS-1$
 		channel.connect(this.clusterName);
 		
 		proxyEventDistributor = (EventDistributor) Proxy.newProxyInstance(Thread.currentThread().getContextClassLoader(), new Class[] {EventDistributor.class}, new ProxyHandler());