org.kie.commons.io.impl.cluster.helix
public class ClusterServiceHelix extends Object implements org.kie.commons.cluster.ClusterService
Constructor and Description |
---|
ClusterServiceHelix(String clusterName,
String zkAddress,
String instanceName,
String resourceName,
org.kie.commons.message.MessageHandlerResolver messageHandlerResolver) |
Modifier and Type | Method and Description |
---|---|
void |
broadcast(org.kie.commons.message.MessageType type,
Map<String,String> content) |
void |
broadcast(org.kie.commons.message.MessageType type,
Map<String,String> content,
int timeOut,
org.kie.commons.message.AsyncCallback callback) |
void |
broadcastAndWait(org.kie.commons.message.MessageType type,
Map<String,String> content,
int timeOut) |
void |
broadcastAndWait(org.kie.commons.message.MessageType type,
Map<String,String> content,
int timeOut,
org.kie.commons.message.AsyncCallback callback) |
void |
lock() |
void |
sendTo(String resourceId,
org.kie.commons.message.MessageType type,
Map<String,String> content) |
void |
unlock() |
public void lock()
lock
in interface org.kie.commons.lock.LockService
public void unlock()
unlock
in interface org.kie.commons.lock.LockService
public void broadcastAndWait(org.kie.commons.message.MessageType type, Map<String,String> content, int timeOut)
broadcastAndWait
in interface org.kie.commons.message.MessageService
public void broadcastAndWait(org.kie.commons.message.MessageType type, Map<String,String> content, int timeOut, org.kie.commons.message.AsyncCallback callback)
broadcastAndWait
in interface org.kie.commons.message.MessageService
public void broadcast(org.kie.commons.message.MessageType type, Map<String,String> content)
broadcast
in interface org.kie.commons.message.MessageService
public void broadcast(org.kie.commons.message.MessageType type, Map<String,String> content, int timeOut, org.kie.commons.message.AsyncCallback callback)
broadcast
in interface org.kie.commons.message.MessageService
Copyright © 2001-2013 JBoss by Red Hat. All Rights Reserved.