Package | Description |
---|---|
org.jgroups.auth | |
org.jgroups.protocols |
Provides implementations of transport protocols which are
responsible for sending and receiving messages to/from the network.
|
org.jgroups.protocols.pbcast |
Supports probabilistic broadcasts.
|
org.jgroups.stack |
Support for managing protocol stacks.
|
Modifier and Type | Field and Description |
---|---|
protected boolean |
RegexMembership.match_ip_address |
protected boolean |
RegexMembership.match_logical_name |
protected String |
RegexMembership.match_string |
Modifier and Type | Method and Description |
---|---|
void |
X509Token.setCertPassword(String pwd) |
void |
FixedMembershipToken.setFixedMembersSeparator(String value) |
void |
X509Token.setKeyStorePassword(String pwd) |
void |
FixedMembershipToken.setMemberList(String list) |
Modifier and Type | Field and Description |
---|---|
protected String |
S3_PING.access_key |
protected boolean |
RSVP.ack_on_delivery |
protected InetAddress |
TP.bind_addr |
protected InetAddress |
STOMP.bind_addr |
protected String |
VERIFY_SUSPECT.bind_interface_str |
protected String |
TP.bind_interface_str |
protected String |
MPING.bind_interface_str |
protected String |
FD_SOCK.bind_interface_str |
protected String |
FD_ICMP.bind_interface_str |
protected int |
TP.bind_port
The port to which the transport binds.
|
protected int |
BPING.bind_port |
protected boolean |
Discovery.break_on_coord_rsp |
protected String |
RELAY.bridge_name |
protected String |
RELAY.bridge_props |
protected int |
TP.bundler_capacity |
protected String |
TP.bundler_type |
protected boolean |
Locking.bypass_bundling |
protected boolean |
Executing.bypass_bundling |
protected boolean |
COUNTER.bypass_bundling |
protected long |
BasicTCP.conn_expire_time |
protected long |
UNICAST2.conn_expiry_timeout |
protected long |
UNICAST.conn_expiry_timeout |
protected String |
JDBC_PING.connection_driver |
protected String |
JDBC_PING.connection_password |
protected String |
JDBC_PING.connection_url |
protected String |
JDBC_PING.connection_username |
protected boolean |
DUPL.copy_multicast_msgs |
protected boolean |
DUPL.copy_unicast_msgs |
protected String |
JDBC_PING.datasource_jndi_name |
protected String |
JDBC_PING.delete_single_sql |
protected String |
BPING.dest |
protected InetAddress |
TP.diagnostics_addr |
protected int |
TP.diagnostics_port |
protected boolean |
UDP.disable_loopback |
protected boolean |
TP.discard_incompatible_packets
Discard packets with a different version.
|
protected boolean |
SHUFFLE.down |
protected boolean |
TP.enable_bundling |
protected boolean |
TP.enable_diagnostics |
protected boolean |
TP.enable_unicast_bundling
Enable bundling for unicast messages.
|
protected String |
STOMP.endpoint_addr |
protected boolean |
STOMP.exact_destination_match |
protected long |
SCOPE.expiration_interval |
protected long |
SCOPE.expiration_time |
protected InetAddress |
TP.external_addr |
protected InetAddress |
FD_SOCK.external_addr |
protected int |
TP.external_port |
protected int |
FD_SOCK.external_port |
protected boolean |
STOMP.forward_non_client_generated_msgs |
protected boolean |
FlowControl.ignore_synchronous_response
Whether an up thread that comes back down should be allowed to bypass blocking if all credits are exhausted.
|
protected int |
DUPL.incoming_copies |
protected int |
MERGE2.inconsistent_view_threshold |
protected String |
JDBC_PING.initialize_sql |
protected String |
JDBC_PING.insert_single_sql |
protected long |
FILE_PING.interval |
protected boolean |
UDP.ip_mcast |
protected int |
UDP.ip_ttl |
protected String |
FILE_PING.location |
protected boolean |
TP.log_discard_msgs
Whether or not warnings about messages from different groups are logged - private flag, not for common use
|
protected long |
TP.logical_addr_cache_expiration |
protected int |
TP.logical_addr_cache_max_size |
protected boolean |
TP.loopback
If true, messages sent to self are treated specially: unicast messages are looped back immediately,
multicast messages get a local copy first and - when the real copy arrives - it will be discarded.
|
protected long |
FlowControl.max_block_time
Max time (in milliseconds) to block.
|
protected long |
UNICAST2.max_bytes |
protected long |
RATE_LIMITER.max_bytes |
protected long |
FlowControl.max_credits
Max number of bytes to send per receiver until an ack must be received before continuing sending
|
protected int |
TCPPING.max_dynamic_hosts |
protected long |
MERGE2.max_interval |
protected int |
SHUFFLE.max_size |
protected int |
UNICAST2.max_stable_msgs |
protected long |
SHUFFLE.max_time |
protected InetAddress |
UDP.mcast_group_addr |
protected int |
UDP.mcast_port |
protected int |
UDP.mcast_recv_buf_size |
protected int |
UDP.mcast_send_buf_size |
protected boolean |
MERGE2.merge_fast |
protected long |
MERGE2.merge_fast_delay |
protected long |
FlowControl.min_credits
Computed as max_credits times min_theshold.
|
protected long |
MERGE2.min_interval |
protected double |
FlowControl.min_threshold
If we're down to (min_threshold * max_credits) bytes for P, we send more credits to P.
|
protected int |
COUNTER.num_backups |
protected int |
CENTRAL_LOCK.num_backups |
protected int |
CENTRAL_EXECUTOR.num_backups |
protected int |
Discovery.num_initial_members |
protected int |
Discovery.num_initial_srv_members
Deprecated.
|
protected boolean |
TP.oob_thread_pool_enabled |
protected boolean |
TP.oob_thread_pool_queue_enabled |
protected int |
TP.oob_thread_pool_queue_max_size |
protected int |
DUPL.outgoing_copies |
protected int |
STOMP.port |
protected int |
TP.port_range |
protected int |
BPING.port_range |
protected String |
S3_PING.pre_signed_delete_url |
protected String |
S3_PING.pre_signed_put_url |
protected String |
S3_PING.prefix |
protected boolean |
RELAY.present_global_views |
protected long |
BasicTCP.reaper_interval |
protected List<NetworkInterface> |
TP.receive_interfaces
List
|
protected boolean |
TP.receive_on_all_interfaces |
protected long |
COUNTER.reconciliation_timeout |
protected boolean |
RELAY.relay |
protected long |
RSVP.resend_interval |
protected boolean |
Discovery.return_entire_cache |
protected String |
S3_PING.secret_access_key |
protected int |
UNICAST.segment_capacity |
protected String |
JDBC_PING.select_all_pingdata_sql |
protected boolean |
STOMP.send_info |
protected String |
TP.singleton_name |
protected String |
RELAY.site |
protected long |
UNICAST2.stable_interval |
protected long |
Discovery.stagger_timeout |
protected String |
TP.thread_naming_pattern |
protected String |
SCOPE.thread_naming_pattern |
protected boolean |
TP.thread_pool_enabled |
protected boolean |
TP.thread_pool_queue_enabled |
protected int |
TP.thread_pool_queue_max_size |
protected String |
TP.thread_pool_rejection_policy |
protected boolean |
RSVP.throw_exception_on_timeout |
protected long |
TP.tick_time |
protected long |
RATE_LIMITER.time_period |
protected long |
RSVP.timeout |
protected long |
Discovery.timeout |
protected long |
COUNTER.timeout |
protected int |
TP.timer_queue_max_size |
protected String |
TP.timer_rejection_policy |
protected String |
TP.timer_type |
protected int |
UDP.tos
Traffic class for sending unicast and multicast datagrams.
|
protected int |
FD_ICMP.ttl
Time-to-live for InetAddress.isReachable()
|
protected int |
UDP.ucast_recv_buf_size |
protected int |
UDP.ucast_send_buf_size |
protected boolean |
SHUFFLE.up |
protected boolean |
DISCARD.use_gui |
protected int |
TP.wheel_size |
Modifier and Type | Method and Description |
---|---|
void |
AUTH.setAuthClass(String class_name) |
void |
TUNNEL.setGossipRouterHosts(String hosts) |
void |
TCPGOSSIP.setInitialHosts(List<InetSocketAddress> hosts) |
void |
FlowControl.setMaxBlockTimes(String str) |
void |
FC.setMaxBlockTimes(String str) |
void |
UDP.setMaxBundleSize(int size) |
void |
TP.setMaxBundleSize(int size) |
void |
TP.setMaxBundleTimeout(long timeout) |
void |
UNICAST2.setMaxRetransmitTime(long max_retransmit_time) |
void |
UNICAST.setMaxRetransmitTime(long max_retransmit_time) |
void |
TP.setOOBThreadPoolKeepAliveTime(long time) |
void |
TP.setOOBThreadPoolMaxThreads(int size) |
void |
TP.setOOBThreadPoolMinThreads(int size) |
void |
TP.setThreadPoolKeepAliveTime(long time) |
void |
SCOPE.setThreadPoolKeepAliveTime(long time) |
void |
TP.setThreadPoolMaxThreads(int size) |
void |
SCOPE.setThreadPoolMaxThreads(int size) |
void |
TP.setThreadPoolMinThreads(int size) |
void |
SCOPE.setThreadPoolMinThreads(int size) |
void |
UNICAST2.setTimeout(int[] val) |
void |
UNICAST.setTimeout(int[] val) |
void |
TP.setTimerKeepAliveTime(long time) |
void |
TP.setTimerMaxThreads(int size) |
void |
TP.setTimerMinThreads(int size) |
Modifier and Type | Field and Description |
---|---|
protected InetAddress |
STATE_SOCK.bind_addr |
protected String |
STATE_SOCK.bind_interface_str |
protected int |
STATE_SOCK.bind_port |
protected int |
StreamingStateTransfer.buffer_size |
protected double |
STABLE.cap |
protected InetAddress |
STATE_SOCK.external_addr |
protected int |
STATE_SOCK.external_port |
protected Class<Callable<Boolean>> |
GMS.flushInvokerClass |
protected long |
STABLE.max_bytes
Total amount of bytes from incoming messages (default = 0 = disabled).
|
protected int |
StreamingStateTransfer.max_pool |
protected int |
GMS.num_prev_mbrs |
protected long |
StreamingStateTransfer.pool_thread_keep_alive |
protected boolean |
NAKACK.print_stability_history_on_failed_xmit
When not finding a message on an XMIT request, include the last N
stability messages in the error message
|
protected long |
NAKACK.xmit_stagger_timeout |
Modifier and Type | Field and Description |
---|---|
protected boolean |
Protocol.ergonomics |
protected short |
Protocol.id |
protected String |
Protocol.name
The name of the protocol.
|
protected boolean |
Protocol.stats |
Modifier and Type | Method and Description |
---|---|
void |
Protocol.setLevel(String level)
Sets the level of a logger.
|
Copyright © 2012 JBoss by Red Hat. All Rights Reserved.