Package | Description |
---|---|
org.apache.synapse.config | |
org.apache.synapse.config.xml |
Factories and serializers for XML based configuration.
|
org.apache.synapse.message.processor.impl | |
org.apache.synapse.message.processor.impl.failover | |
org.apache.synapse.message.processor.impl.forwarder | |
org.apache.synapse.message.processor.impl.sampler |
Modifier and Type | Method and Description |
---|---|
MessageProcessor |
SynapseConfiguration.removeMessageProcessor(String name)
remove the message processor from the synapse configuration
|
Modifier and Type | Method and Description |
---|---|
Map<String,MessageProcessor> |
SynapseConfiguration.getMessageProcessors()
Get all Message processors in the Synapse configuration
|
Modifier and Type | Method and Description |
---|---|
void |
SynapseConfiguration.addMessageProcessor(String name,
MessageProcessor processor)
Add message processor to the synapse configuration with given name
|
Modifier and Type | Method and Description |
---|---|
static MessageProcessor |
MessageProcessorFactory.createMessageProcessor(org.apache.axiom.om.OMElement elem)
Creates a Message processor instance from given xml configuration element
|
static MessageProcessor |
SynapseXMLConfigurationFactory.defineMessageProcessor(SynapseConfiguration config,
org.apache.axiom.om.OMElement elem,
Properties properties) |
Modifier and Type | Method and Description |
---|---|
org.apache.axiom.om.OMElement |
MultiXMLConfigurationSerializer.serializeMessageProcessor(MessageProcessor messageProcessor,
SynapseConfiguration synapseConfiguration,
org.apache.axiom.om.OMElement parent) |
static org.apache.axiom.om.OMElement |
MessageProcessorSerializer.serializeMessageProcessor(org.apache.axiom.om.OMElement parent,
MessageProcessor processor)
Serialize a give Message processor instance to XML configuration
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractMessageProcessor
Class
AbstractMessageProcessor is handles Message processing of the messages
in Message Store. |
class |
ScheduledMessageProcessor
Implements the common message processor infrastructure which is used by the
both
Forwarding and Sampling message Processors. |
Modifier and Type | Class and Description |
---|---|
class |
FailoverScheduledMessageForwardingProcessor
Redelivery processor will Time to time Redeliver the Messages to a given message store.
|
Constructor and Description |
---|
FailoverForwardingService(MessageProcessor messageProcessor,
SynapseEnvironment synapseEnvironment,
long threshouldInterval,
boolean isDeactivatedAtStartup) |
Modifier and Type | Class and Description |
---|---|
class |
ScheduledMessageForwardingProcessor
Redelivery processor is the Message processor which implements the Dead letter channel EIP
It will Time to time Redeliver the Messages to a given target.
|
Constructor and Description |
---|
ForwardingService(MessageProcessor messageProcessor,
BlockingMsgSender sender,
SynapseEnvironment synapseEnvironment,
long threshouldInterval) |
ForwardingService(MessageProcessor messageProcessor,
BlockingMsgSender sender,
SynapseEnvironment synapseEnvironment,
long thresholdInterval,
boolean isDeactivatedAtStartup) |
Modifier and Type | Class and Description |
---|---|
class |
SamplingProcessor
Implements the functionality of the Sampling message processor which injects
a message to a given sequence.
|
Constructor and Description |
---|
SamplingService(MessageProcessor messageProcessor,
SynapseEnvironment synapseEnvironment,
String concurrencyPropName,
String sequencePropName) |
SamplingService(MessageProcessor messageProcessor,
SynapseEnvironment synapseEnvironment,
String concurrencyPropName,
String sequencePropName,
boolean isDeactivatedAtStartup) |
Copyright © 2005–2024 Apache Software Foundation. All rights reserved.