Apache
/
activemq-artemis
mirror of https://github.com/apache/activemq-artemis.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

[ARTEMIS-561] JMS Bridge should display statistics about messages that have been processed

This commit is contained in:
bayern39 2016-06-08 17:22:05 +08:00 committed by Clebert Suconic
parent bafa59cc38
commit 0ed7f586a8
2 changed files with 23 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
artemis-jms-server/src/main/java/org/apache/activemq/artemis/jms/bridge/JMSBridge.java
View File

@ -90,6 +90,10 @@ public interface JMSBridge extends ActiveMQComponent {
boolean isFailed();
int getMessageCount();
int getabortedMessageCount();
void setSourceConnectionFactoryFactory(ConnectionFactoryFactory cff);
void setTargetConnectionFactoryFactory(ConnectionFactoryFactory cff);

19
artemis-jms-server/src/main/java/org/apache/activemq/artemis/jms/bridge/impl/JMSBridgeImpl.java
View File

@ -181,6 +181,10 @@ public final class JMSBridgeImpl implements JMSBridge {
private ClassLoader moduleTccl;
private int message_count = 0;
private int aborted_message_count = 0;
/*
* Constructor for MBean
*/
@ -488,6 +492,7 @@ public final class JMSBridgeImpl implements JMSBridge {
try {
tx.rollback();
aborted_message_count += messages.size();
}
catch (Exception ignore) {
if (JMSBridgeImpl.trace) {
@ -774,6 +779,16 @@ public final class JMSBridgeImpl implements JMSBridge {
return failed;
}
@Override
public synchronized int getMessageCount() {
return message_count;
}
@Override
public synchronized int getabortedMessageCount() {
return aborted_message_count;
}
@Override
public synchronized void setSourceConnectionFactoryFactory(final ConnectionFactoryFactory cff) {
checkBridgeNotStarted();
@ -1199,6 +1214,7 @@ public final class JMSBridgeImpl implements JMSBridge {
try {
// Terminate the tx
tx.rollback();
aborted_message_count += messages.size();
}
catch (Throwable ignore) {
if (JMSBridgeImpl.trace) {
@ -1398,6 +1414,7 @@ public final class JMSBridgeImpl implements JMSBridge {
try {
// we call this just in case there is a failure other than failover
tx.rollback();
aborted_message_count += messages.size();
}
catch (Throwable ignored) {
}
@ -1493,6 +1510,8 @@ public final class JMSBridgeImpl implements JMSBridge {
targetProducer.send(targetDestination, msg, msg.getJMSDeliveryMode(), msg.getJMSPriority(), timeToLive);
if (msg != null)
message_count++;
if (JMSBridgeImpl.trace) {
ActiveMQJMSBridgeLogger.LOGGER.trace("Sent message " + msg);
}