@UriEndpoint(scheme="jgroups", title="JGroups", syntax="jgroups:clusterName", consumerClass=JGroupsConsumer.class, label="clustering,messaging") public class JGroupsEndpoint extends org.apache.camel.impl.DefaultEndpoint
Modifier and Type | Field and Description |
---|---|
static String |
HEADER_JGROUPS_CHANNEL_ADDRESS |
static String |
HEADER_JGROUPS_DEST |
static String |
HEADER_JGROUPS_ORIGINAL_MESSAGE |
static String |
HEADER_JGROUPS_SRC |
Constructor and Description |
---|
JGroupsEndpoint(String endpointUri,
org.apache.camel.Component component,
org.jgroups.Channel channel,
String clusterName,
String channelProperties,
boolean enableViewMessages) |
Modifier and Type | Method and Description |
---|---|
void |
connect()
Connect shared channel, called by producer and consumer.
|
org.apache.camel.Consumer |
createConsumer(org.apache.camel.Processor processor) |
org.apache.camel.Exchange |
createExchange() |
org.apache.camel.Exchange |
createExchange(org.jgroups.Message message) |
org.apache.camel.Exchange |
createExchange(org.jgroups.View view) |
org.apache.camel.Producer |
createProducer() |
void |
disconnect()
Disconnect shared channel, called by producer and consumer.
|
protected void |
doStart() |
protected void |
doStop() |
org.jgroups.Channel |
getChannel() |
String |
getChannelProperties() |
String |
getClusterName() |
boolean |
isEnableViewMessages() |
boolean |
isSingleton() |
void |
setChannel(org.jgroups.Channel channel)
The channel to use
|
void |
setChannelProperties(String channelProperties)
Specifies configuration properties of the JChannel used by the endpoint.
|
void |
setClusterName(String clusterName)
The name of the JGroups cluster the component should connect to.
|
void |
setEnableViewMessages(boolean enableViewMessages)
If set to true, the consumer endpoint will receive org.jgroups.View messages as well (not only org.jgroups.Message instances).
|
configureConsumer, configurePollingConsumer, configureProperties, createEndpointConfiguration, createEndpointUri, createExchange, createExchange, createPollingConsumer, equals, getCamelContext, getComponent, getConsumerProperties, getEndpointConfiguration, getEndpointKey, getEndpointUri, getExceptionHandler, getExchangePattern, getId, getPollingConsumerBlockTimeout, getPollingConsumerQueueSize, hashCode, isBridgeErrorHandler, isLenientProperties, isPollingConsumerBlockWhenFull, isSynchronous, setBridgeErrorHandler, setCamelContext, setConsumerProperties, setEndpointConfiguration, setEndpointUri, setEndpointUriIfNotSpecified, setExceptionHandler, setExchangePattern, setPollingConsumerBlockTimeout, setPollingConsumerBlockWhenFull, setPollingConsumerQueueSize, setProperties, setSynchronous, toString
doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspend
public static final String HEADER_JGROUPS_ORIGINAL_MESSAGE
public static final String HEADER_JGROUPS_SRC
public static final String HEADER_JGROUPS_DEST
public static final String HEADER_JGROUPS_CHANNEL_ADDRESS
public org.apache.camel.Consumer createConsumer(org.apache.camel.Processor processor) throws Exception
Exception
public boolean isSingleton()
public org.apache.camel.Exchange createExchange(org.jgroups.Message message)
public org.apache.camel.Exchange createExchange(org.jgroups.View view)
public org.apache.camel.Exchange createExchange()
createExchange
in interface org.apache.camel.Endpoint
createExchange
in class org.apache.camel.impl.DefaultEndpoint
protected void doStart() throws Exception
doStart
in class org.apache.camel.impl.DefaultEndpoint
Exception
protected void doStop() throws Exception
doStop
in class org.apache.camel.impl.DefaultEndpoint
Exception
public void connect() throws Exception
Exception
public void disconnect()
public org.jgroups.Channel getChannel()
public void setChannel(org.jgroups.Channel channel)
public String getClusterName()
public void setClusterName(String clusterName)
public String getChannelProperties()
public void setChannelProperties(String channelProperties)
public boolean isEnableViewMessages()
public void setEnableViewMessages(boolean enableViewMessages)
Apache Camel