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());