public static class ConsumerInfo.Details
extends java.lang.Object
Modifier and Type | Method and Description |
---|---|
static ConsumerInfo.Details |
from(javax.management.openmbean.CompositeData cd) |
long |
getCurrentMsgCountSentByServer()
Returns number of messages sent to consumer and not yet
acknowledged by consumer's session.
|
long |
getCurrentMsgSizeSentByServer()
Returns combined size of messages sent to consumer and not yet
acknowledged by consumer's session.
|
int |
getDestinationPrefetch()
Returns destination prefetch value.
|
long |
getElapsedSinceLastAcknowledged()
Returns number of milliseconds elapsed since last time a message
sent to this consumer was acknowledged by consumer's session.
|
long |
getElapsedSinceLastSent()
Returns number of milliseconds elapsed since last time the server
sent a message to this consumer.
|
int |
getPrefetchDelivered()
Returns number of prefetch messages delivered to consumer by the server.
|
java.lang.String |
getRouteName()
Returns queue owner server name if this consumer's destination
is a routed queue.
|
int |
getSessionAcknowledgeMode()
Returns consumer's session acknowledge mode as a constant defined
in
TibjmsAdmin . |
long |
getTotalAcknowledgedCount()
Returns total number of messages which were delivered to this
consumer and have been acknowledged by consumer's session.
|
long |
getTotalMsgCountSentByServer()
Returns total number of messages the server sent to this consumer since
consumer was created.
|
boolean |
isActive()
Returns
true if this consumer is active. |
boolean |
isSystem()
Returns
true if this consumer has been created
automatically by the system. |
java.lang.String |
toString()
Returns string representation of this object.
|
public java.lang.String getRouteName()
null
for topic
consumers and for queue consumers receiving messages
from queues local to the server.null
public int getDestinationPrefetch()
DestinationInfo.PREFETCH_NONE
which is available for queues.DestinationInfo.PREFETCH_NONE
for queues
configured as no-prefetch queue.public int getPrefetchDelivered()
public long getCurrentMsgCountSentByServer()
ConsumerInfo.getPendingMessageCount()
.public long getCurrentMsgSizeSentByServer()
ConsumerInfo.getPendingMessageSize()
.public long getElapsedSinceLastSent()
public long getElapsedSinceLastAcknowledged()
public long getTotalMsgCountSentByServer()
public long getTotalAcknowledgedCount()
public boolean isSystem()
true
if this consumer has been created
automatically by the system. If this method returns
false
, this consumer has been created by user
application. If this method returns true
this
consumer has been created automatically by the system. There
are several types of consumers the system may create automatically.true
if this consumer has been created by EMS
server and not by application.public boolean isActive()
true
if this consumer is active.
Active are consumers which the server can send messages to.
Only queue consumers which never called receive()
remain in inactive state. Queue consumers which called
receive
at least once or are configured with the
message callback, and all topic consumers are always active.
This method can identify inactive queue consumers which never
called receive
and, while present, never receive
any messages from the server even in presence of pending messages
in corresponding queue.false
if this is a queue consumer which is not
configured with the message callback and never called receive().
Returns true
in all other cases.public int getSessionAcknowledgeMode()
TibjmsAdmin
.
This method returns consumer's session acknowledge mode as a value
defined in TibjmsAdmin
class. Returned value is
TibjmsAdmin.SESSION_UNKNOWN_ACKNOWLEDGE
if consumer is currently
not connected (for durable topic subscribers), TibjmsAdmin.SESSION_XA
if consumer's session is XA session, TibjmsAdmin.SESSION_TRANSACTED
if consumer's session is transacted, or one of values TibjmsAdmin.SESSION_NO_ACKNOWLEDGE
,
TibjmsAdmin.SESSION_AUTO_ACKNOWLEDGE
, TibjmsAdmin.SESSION_DUPS_OK_ACKNOWLEDGE
,
TibjmsAdmin.SESSION_CLIENT_ACKNOWLEDGE
.
public java.lang.String toString()
toString
in class java.lang.Object
public static ConsumerInfo.Details from(javax.management.openmbean.CompositeData cd) throws java.lang.Exception
java.lang.Exception
Copyright © Cloud Software Group, Inc. All rights reserved