public class ChannelEndpointStatus
extends java.lang.Object
Publication
or Subscription
.Modifier and Type | Field and Description |
---|---|
static long |
ACTIVE
Channel has finished initialization successfully and is active.
|
static int |
CHANNEL_OFFSET
Offset in the key meta data for the channel of the counter.
|
static long |
CLOSING
Channel is being closed.
|
static long |
ERRORED
Channel has errored.
|
static long |
INITIALIZING
Channel is being initialized.
|
static int |
MAX_CHANNEL_LENGTH
The maximum length in bytes of the encoded channel identity.
|
static int |
NO_ID_ALLOCATED
No counter ID is allocated yet.
|
Constructor and Description |
---|
ChannelEndpointStatus() |
Modifier and Type | Method and Description |
---|---|
static org.agrona.concurrent.status.AtomicCounter |
allocate(org.agrona.MutableDirectBuffer tempBuffer,
java.lang.String name,
int typeId,
org.agrona.concurrent.status.CountersManager countersManager,
java.lang.String channel)
Allocate an indicator for tracking the status of a channel endpoint.
|
static java.lang.String |
status(long status)
String representation of the channel status.
|
public static final long INITIALIZING
public static final long ERRORED
public static final long ACTIVE
public static final long CLOSING
public static final int NO_ID_ALLOCATED
public static final int CHANNEL_OFFSET
public static final int MAX_CHANNEL_LENGTH
public static java.lang.String status(long status)
status
- to be converted.public static org.agrona.concurrent.status.AtomicCounter allocate(org.agrona.MutableDirectBuffer tempBuffer, java.lang.String name, int typeId, org.agrona.concurrent.status.CountersManager countersManager, java.lang.String channel)
tempBuffer
- to be used for labels and metadata.name
- of the counter for the label.typeId
- of the counter for classification.countersManager
- from which to allocated the underlying storage.channel
- for the stream of messages.AtomicCounter
for tracking the status.Copyright © 2014-2018 Real Logic Ltd. All Rights Reserved.