[teiid-commits] teiid SVN: r3188 - branches/7.4.x/cache-jbosscache/src/main/java/org/teiid/events/jboss.
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());