software.chronicle.datagrid.cfg

Class QueueCfg

java.lang.Object

net.openhft.chronicle.wire.AbstractCommonMarshallable

net.openhft.chronicle.wire.SelfDescribingMarshallable

net.openhft.chronicle.wire.AbstractMarshallableCfg

software.chronicle.datagrid.cfg.QueueCfg

All Implemented Interfaces:

net.openhft.chronicle.bytes.BytesMarshallable, net.openhft.chronicle.bytes.CommonMarshallable, net.openhft.chronicle.bytes.ReadBytesMarshallable, net.openhft.chronicle.bytes.WriteBytesMarshallable, net.openhft.chronicle.core.io.Resettable, net.openhft.chronicle.wire.Marshallable, net.openhft.chronicle.wire.ReadMarshallable, net.openhft.chronicle.wire.WriteMarshallable, net.openhft.chronicle.wire.WriteValue, Installable

Direct Known Subclasses:

QueueProxyCfg

public class QueueCfg
extends net.openhft.chronicle.wire.AbstractMarshallableCfg
implements Installable

Author:

Rob Austin. Configures a Chronicle Queue

Field Summary

Fields inherited from interface net.openhft.chronicle.wire.ReadMarshallable

DISCARD

Fields inherited from interface net.openhft.chronicle.wire.WriteMarshallable

EMPTY

Constructor Summary

Constructors

Constructor and Description
QueueCfg()

Method Summary

Modifier and Type	Method and Description
boolean	acknowledgment()
@Nullable String	basePath()
@NotNull String	cluster()
@Nullable Void	install(@NotNull String uriPath, @NotNull AssetTree assetTree) Installs this Configuration Object in the system.
int	masterId()
@Nullable MessageAdaptor	messageAdaptor()
@NotNull Class<?>	messageClass()
boolean	pretouch()
long	pretouchIntervalMs()
@NotNull Class<?>	topicClass()
@NotNull net.openhft.chronicle.wire.WireType	wireType()

Methods inherited from class net.openhft.chronicle.wire.AbstractMarshallableCfg

readMarshallable, unexpectedField, writeMarshallable

Methods inherited from class net.openhft.chronicle.wire.SelfDescribingMarshallable

usesSelfDescribingMessage

Methods inherited from class net.openhft.chronicle.wire.AbstractCommonMarshallable

equals, hashCode, toString

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface net.openhft.chronicle.wire.ReadMarshallable

readMarshallable, unexpectedField, usesSelfDescribingMessage

Methods inherited from interface net.openhft.chronicle.wire.Marshallable

$equals, $fieldInfoMap, $fieldInfos, $hashCode, $toString, className, copyFrom, copyTo, deepCopy, fromFile, fromFile, fromFileAsMap, fromFileAsMap, fromHexString, fromString, fromString, fromString, getField, getLongField, mergeToMap, reset, setField, setLongField, streamFromFile, streamFromFile

Methods inherited from interface net.openhft.chronicle.wire.WriteMarshallable

writeValue

Methods inherited from interface net.openhft.chronicle.bytes.BytesMarshallable

$toString, readMarshallable, writeMarshallable

Constructor Detail

QueueCfg

public QueueCfg()

Method Detail

install

@Nullable
public @Nullable Void install(@NotNull
                                        @NotNull String uriPath,
                                        @NotNull
                                        @NotNull AssetTree assetTree)

Description copied from interface: Installable

Installs this Configuration Object in the system.

Specified by:

install in interface Installable

Parameters:

uriPath - to install to

assetTree - where the given path resides

Returns:

null or a component that shall be stored in a Map at the leaf of the path

masterId

public int masterId()

basePath

@Nullable
public @Nullable String basePath()

topicClass

@NotNull
public @NotNull Class<?> topicClass()

messageClass

@NotNull
public @NotNull Class<?> messageClass()

acknowledgment

public boolean acknowledgment()

messageAdaptor

@Nullable
public @Nullable MessageAdaptor messageAdaptor()

wireType

@NotNull
public @NotNull net.openhft.chronicle.wire.WireType wireType()

cluster

@NotNull
public @NotNull String cluster()

pretouch

public boolean pretouch()

pretouchIntervalMs

public long pretouchIntervalMs()