@UriParams public class ChronicleEngineConfiguration extends Object
Constructor and Description |
---|
ChronicleEngineConfiguration() |
Modifier and Type | Method and Description |
---|---|
String |
getAction() |
String |
getClusterName() |
String[] |
getFilteredMapEvents() |
net.openhft.chronicle.wire.WireType |
getWireType() |
boolean |
isPersistent() |
boolean |
isSubscribeMapEvents() |
boolean |
isSubscribeTopicEvents() |
boolean |
isSubscribeTopologicalEvents() |
void |
setAction(String action)
The default action to perform, valid values are:
- PUBLISH
- PPUBLISH_AND_INDEX
- PPUT
- PGET_AND_PUT
- PPUT_ALL
- PPUT_IF_ABSENT
- PGET
- PGET_AND_REMOVE
- PREMOVE
- PIS_EMPTY
- PSIZE
|
void |
setClusterName(String clusterName)
Cluster name for queue
|
void |
setFilteredMapEvents(String filteredMapEvents)
A comma separated list of Map event type to filer, valid values are: INSERT, UPDATE, REMOVE.
|
void |
setFilteredMapEvents(String[] filteredMapEvents)
The list of Map event type to filer, valid values are: INSERT, UPDATE, REMOVE.
|
void |
setPersistent(boolean persistent)
Enable/disable data persistence
|
void |
setSubscribeMapEvents(boolean subscribeMapEvents)
Set if consumer should subscribe to Map events, default true.
|
void |
setSubscribeTopicEvents(boolean subscribeTopicEvents)
Set if consumer should subscribe to TopicEvents,d efault false.
|
void |
setSubscribeTopologicalEvents(boolean subscribeTopologicalEvents)
Set if consumer should subscribe to TopologicalEvents,d efault false.
|
void |
setWireType(String wireType)
The Wire type to use, default to binary wire.
|
void |
setWireType(net.openhft.chronicle.wire.WireType wireType)
The Wire type to use, default to binary wire.
|
public net.openhft.chronicle.wire.WireType getWireType()
public void setWireType(String wireType)
public void setWireType(net.openhft.chronicle.wire.WireType wireType)
public boolean isSubscribeMapEvents()
public void setSubscribeMapEvents(boolean subscribeMapEvents)
public String[] getFilteredMapEvents()
public void setFilteredMapEvents(String filteredMapEvents)
public void setFilteredMapEvents(String[] filteredMapEvents)
public boolean isSubscribeTopologicalEvents()
public void setSubscribeTopologicalEvents(boolean subscribeTopologicalEvents)
public boolean isSubscribeTopicEvents()
public void setSubscribeTopicEvents(boolean subscribeTopicEvents)
public String getAction()
public void setAction(String action)
public boolean isPersistent()
public void setPersistent(boolean persistent)
public String getClusterName()
public void setClusterName(String clusterName)
Apache Camel