public class Channel<T extends Channel<T>> extends Object
Modifier and Type | Class and Description |
---|---|
static class |
Channel.ChannelResources
Child mutators for Channel
|
Modifier and Type | Method and Description |
---|---|
void |
addPropertyChangeListener(PropertyChangeListener listener)
Adds a property change listener
|
String |
address()
The IP address of the channel.
|
T |
address(String value)
The IP address of the channel.
|
String |
addressAsUuid()
The address of the channel as a UUID.
|
T |
addressAsUuid(String value)
The address of the channel as a UUID.
|
String |
cluster()
The cluster name of the JGroups channel.
|
T |
cluster(String value)
The cluster name of the JGroups channel.
|
Boolean |
discardOwnMessages()
If true, do not receive messages sent by this node (ourself).
|
T |
discardOwnMessages(Boolean value)
If true, do not receive messages sent by this node (ourself).
|
T |
fork(Fork value)
Add the Fork object to the list of subresources
|
T |
fork(ForkSupplier supplier)
Install a supplied Fork object to the list of subresources
|
T |
fork(String childKey)
Create and configure a Fork object to the list of subresources
|
T |
fork(String childKey,
ForkConsumer consumer)
Create and configure a Fork object to the list of subresources
|
T |
forks(List<Fork> value)
Add all Fork objects to this subresource
|
String |
getKey() |
String |
module()
The module from which to load channel services
|
T |
module(String value)
The module from which to load channel services
|
Integer |
numTasksInTimer()
The current number of timer tasks.
|
T |
numTasksInTimer(Integer value)
The current number of timer tasks.
|
Integer |
numTimerThreads()
The number of timer threads.
|
T |
numTimerThreads(Integer value)
The number of timer threads.
|
Long |
receivedBytes()
The number of bytes received by this channel.
|
T |
receivedBytes(Long value)
The number of bytes received by this channel.
|
Long |
receivedMessages()
The number of messages received by this channel.
|
T |
receivedMessages(Long value)
The number of messages received by this channel.
|
void |
removePropertyChangeListener(PropertyChangeListener listener)
Removes a property change listener
|
Long |
sentBytes()
The number of bytes sent by this channel.
|
T |
sentBytes(Long value)
The number of bytes sent by this channel.
|
Long |
sentMessages()
The number of messages sent by this channel.
|
T |
sentMessages(Long value)
The number of messages sent by this channel.
|
String |
stack()
The protocol stack of the JGroups channel
|
T |
stack(String value)
The protocol stack of the JGroups channel
|
String |
state()
The state of the channel (OPEN, CONNECTING, CONNECTED, CLOSED).
|
T |
state(String value)
The state of the channel (OPEN, CONNECTING, CONNECTED, CLOSED).
|
Boolean |
statisticsEnabled()
If enabled, collect channel statistics.
|
T |
statisticsEnabled(Boolean value)
If enabled, collect channel statistics.
|
Boolean |
statsEnabled()
If enabled, collect channel statistics.
|
T |
statsEnabled(Boolean value)
If enabled, collect channel statistics.
|
Channel.ChannelResources |
subresources() |
String |
version()
The JGroups software version.
|
T |
version(String value)
The JGroups software version.
|
String |
view()
The channel's view of group membership.
|
T |
view(String value)
The channel's view of group membership.
|
public Channel(String key)
public String getKey()
public void addPropertyChangeListener(PropertyChangeListener listener)
public void removePropertyChangeListener(PropertyChangeListener listener)
public Channel.ChannelResources subresources()
public T forks(List<Fork> value)
value
- List of Fork objects.public T fork(Fork value)
value
- The Fork to addpublic T fork(String childKey, ForkConsumer consumer)
key
- The key for the Fork resourceconfig
- The ForkConsumer to usepublic T fork(String childKey)
key
- The key for the Fork resourcepublic T fork(ForkSupplier supplier)
public String address()
public String addressAsUuid()
public String cluster()
public T cluster(String value)
public Boolean discardOwnMessages()
public T discardOwnMessages(Boolean value)
public String module()
public Integer numTasksInTimer()
public Integer numTimerThreads()
public Long receivedBytes()
public Long receivedMessages()
public T receivedMessages(Long value)
public Long sentBytes()
public Long sentMessages()
public String stack()
public String state()
public Boolean statisticsEnabled()
public Boolean statsEnabled()
public String version()
public String view()
Copyright © 2019 JBoss by Red Hat. All rights reserved.