public interface GatewaySenderMXBean
GatewaySender
.Modifier and Type | Method and Description |
---|---|
int |
getAlertThreshold()
Returns the alert threshold for entries in a GatewaySender's queue.
|
long |
getAverageDistributionTimePerBatch()
Returns the average time taken to send a batch of events.
|
float |
getBatchesDispatchedRate()
Returns the average number of batches sent per second.
|
int |
getBatchSize()
Returns the size of a batch that gets delivered by the GatewaySender.
|
long |
getBatchTimeInterval()
Returns the interval between transmissions by the GatewaySender.
|
long |
getBytesOverflowedToDisk()
Returns the number of bytes overflowed to disk for this Sender.
|
int |
getDispatcherThreads()
Returns the number of dispatcher threads working for this
GatewaySender . |
long |
getEntriesOverflowedToDisk()
Returns the number of entries overflowed to disk for this Sender.
|
int |
getEventQueueSize()
Returns the current size of the event queue.
|
int |
getEventsExceedingAlertThreshold()
Returns number of events which have exceeded the configured alert threshold.
|
float |
getEventsQueuedRate()
Returns the rate of events being queued.
|
float |
getEventsReceivedRate()
Returns the rate of events received per second by this Sender.
|
String[] |
getGatewayEventFilters()
Returns a list of
GatewayEventFilter s added to this GatewaySender. |
String |
getGatewayReceiver()
Returns the host and port information of GatewayReceiver to which this gateway sender is
connected.
|
String[] |
getGatewayTransportFilters()
Returns a list of
GatewayTransportFilter s added to this GatewaySender. |
float |
getLRUEvictionsRate()
Returns the rate of LRU evictions per second by this Sender.
|
int |
getMaximumQueueMemory()
Returns the maximum memory after which the data needs to be overflowed to disk.
|
String |
getOrderPolicy()
Returns the order policy followed while dispatching the events to remote distributed system.
|
String |
getOverflowDiskStoreName()
Returns the name of the disk store that is used for persistence.
|
int |
getRemoteDSId()
Returns the id of the remote
GatewayReceiver 's DistributedSystem. |
String |
getSenderId()
Returns the ID of the GatewaySender.
|
int |
getSocketBufferSize()
Returns the configured buffer size of the socket connection between this GatewaySender and its
receiving
GatewayReceiver . |
long |
getSocketReadTimeout()
Returns the amount of time (in milliseconds) that a socket read between a sending GatewaySender
and its receiving
GatewayReceiver is allowed to block. |
int |
getTotalBatchesDistributed()
Returns the total number of batches of events that were resent.
|
int |
getTotalBatchesRedistributed()
Returns the total number of batches of events that were resent.
|
int |
getTotalBatchesWithIncompleteTransactions()
Returns the total number of batches sent with incomplete transactions.
|
int |
getTotalEventsConflated()
Returns the number of events received, but not added to the event queue, because the queue
already contains an event with the same key.
|
long |
getTotalQueueSizeBytesInUse()
Returns the total number of bytes in heap occupied by the event queue.
|
boolean |
isBatchConflationEnabled()
Returns whether batch conflation for the GatewaySender's queue is enabled
|
boolean |
isConnected()
Returns whether this GatewaySender is connected and sending data to a GatewayReceiver.
|
boolean |
isDiskSynchronous()
Returns whether the isDiskSynchronous property is set for this GatewaySender.
|
boolean |
isManualStart()
Returns whether the GatewaySender is configured for manual start.
|
boolean |
isParallel()
Returns whether the isParallel property is set for this GatewaySender.
|
boolean |
isPaused()
Returns whether or not this GatewaySender is paused.
|
boolean |
isPersistenceEnabled()
Returns whether the GatewaySender is configured to be persistent or non-persistent.
|
boolean |
isPrimary()
Returns whether this GatewaySender is primary or secondary.
|
boolean |
isRunning()
Returns whether or not this GatewaySender is running.
|
boolean |
mustGroupTransactionEvents() |
void |
pause()
Pauses this GatewaySender.
|
void |
rebalance()
Rebalances this GatewaySender.
|
void |
resume()
Resumes this paused GatewaySender.
|
void |
start()
Starts this GatewaySender.
|
void |
startWithCleanQueue()
Starts this GatewaySender and cleans previous queue content.
|
void |
stop()
Stops this GatewaySender.
|
String getSenderId()
int getRemoteDSId()
GatewayReceiver
's DistributedSystem.GatewayReceiver
's DistributedSystemint getSocketBufferSize()
GatewayReceiver
.GatewayReceiver
long getSocketReadTimeout()
GatewayReceiver
is allowed to block.GatewayReceiver
is allowed to blockString getOverflowDiskStoreName()
int getMaximumQueueMemory()
int getBatchSize()
long getBatchTimeInterval()
boolean isBatchConflationEnabled()
boolean isPersistenceEnabled()
int getAlertThreshold()
String[] getGatewayEventFilters()
GatewayEventFilter
s added to this GatewaySender.GatewayEventFilter
s added to this GatewaySenderString[] getGatewayTransportFilters()
GatewayTransportFilter
s added to this GatewaySender.GatewayTransportFilter
s added to this GatewaySenderboolean isManualStart()
boolean isRunning()
boolean isPaused()
float getEventsReceivedRate()
float getEventsQueuedRate()
float getLRUEvictionsRate()
long getEntriesOverflowedToDisk()
long getBytesOverflowedToDisk()
int getEventQueueSize()
int getTotalEventsConflated()
float getBatchesDispatchedRate()
long getAverageDistributionTimePerBatch()
int getTotalBatchesDistributed()
int getTotalBatchesRedistributed()
int getTotalBatchesWithIncompleteTransactions()
long getTotalQueueSizeBytesInUse()
void start()
void startWithCleanQueue()
void stop()
void pause()
void resume()
void rebalance()
boolean isPrimary()
int getDispatcherThreads()
GatewaySender
.GatewaySender
String getOrderPolicy()
boolean isDiskSynchronous()
boolean isParallel()
boolean mustGroupTransactionEvents()
String getGatewayReceiver()
boolean isConnected()
int getEventsExceedingAlertThreshold()