org.apache.activemq.artemis.api.jms.management.JMSQueueControl to org.apache.activemq.artemis.api.core.management.QueueControl
No. of Instances - 6
No. of Commits - 1
No. of Projects - {'wildfly'}
Hierarchy/Composition: -
Primitive Info: -
NameSpace: Internal -> Internal
Mapping:
- Add or Remove Method invocation
- filter to convertToActiveMQFilterString(filter)
- filter to convertToActiveMQFilterString(filter)
- filter to convertToActiveMQFilterString(filter)
- filter to convertToActiveMQFilterString(filter)
- filter to convertToActiveMQFilterString(filter)
- filter to convertToActiveMQFilterString(filter)
- filter to convertToActiveMQFilterString(filter)
- filter to convertToActiveMQFilterString(filter)
- filter to convertToActiveMQFilterString(filter)
- filter to convertToActiveMQFilterString(filter)
- filter to convertToActiveMQFilterString(filter)
- filter to convertToActiveMQFilterString(filter)
- filter to convertToActiveMQFilterString(filter)
- filter to convertToActiveMQFilterString(filter)
- Rename Method invocation
- listMessageCounter to listMessageCounterAsHTML
- listMessageCounter to listMessageCounterHistory
- listMessageCounter to listMessageCounterHistoryAsHTML
- listMessageCounterAsHTML to listMessageCounter
- listMessageCounterHistory to listMessageCounter
- listMessageCounterHistory to listMessageCounterHistoryAsHTML
- listMessageCounterHistoryAsHTML to listMessageCounter
- listMessageCounterHistoryAsHTML to listMessageCounterHistory
- listMessageCounter to listMessageCounterAsHTML
- listMessageCounter to listMessageCounterHistory
- listMessageCounter to listMessageCounterHistoryAsHTML
- listMessageCounterAsHTML to listMessageCounter
- listMessageCounterHistory to listMessageCounter
- listMessageCounterHistory to listMessageCounterHistoryAsHTML
- listMessageCounterHistoryAsHTML to listMessageCounter
- listMessageCounterHistoryAsHTML to listMessageCounterHistory
- Cascading Type Change (Similar)
- AbstractQueueControlHandler.DelegatingQueueControl<JMSQueueControl> to AbstractQueueControlHandler.DelegatingQueueControl<QueueControl>
- Update Anonymous class
- { @Override public JMSQueueControl getDelegate(){ return control; } @Override public String listMessagesAsJSON( String filter) throws Exception { return control.listMessagesAsJSON(filter); } @Override public long countMessages( String filter) throws Exception { return control.countMessages(filter); } @Override public boolean removeMessage( ModelNode id) throws Exception { return control.removeMessage(id.asString()); } @Override public int removeMessages( String filter) throws Exception { return control.removeMessages(filter); } @Override public int expireMessages( String filter) throws Exception { return control.expireMessages(filter); } @Override public boolean expireMessage( ModelNode id) throws Exception { return control.expireMessage(id.asString()); } @Override public boolean sendMessageToDeadLetterAddress( ModelNode id) throws Exception { return control.sendMessageToDeadLetterAddress(id.asString()); } @Override public int sendMessagesToDeadLetterAddress( String filter) throws Exception { return control.sendMessagesToDeadLetterAddress(filter); } @Override public boolean changeMessagePriority( ModelNode id, int priority) throws Exception { return control.changeMessagePriority(id.asString(),priority); } @Override public int changeMessagesPriority( String filter, int priority) throws Exception { return control.changeMessagesPriority(filter,priority); } @Override public boolean moveMessage( ModelNode id, String otherQueue) throws Exception { return control.moveMessage(id.asString(),otherQueue); } @Override public boolean moveMessage( ModelNode id, String otherQueue, boolean rejectDuplicates) throws Exception { return control.moveMessage(id.asString(),otherQueue,rejectDuplicates); } @Override public int moveMessages( String filter, String otherQueue) throws Exception { return control.moveMessages(filter,otherQueue); } @Override public int moveMessages( String filter, String otherQueue, boolean rejectDuplicates) throws Exception { return control.moveMessages(filter,otherQueue,rejectDuplicates); } @Override public String listMessageCounter() throws Exception { return control.listMessageCounter(); } @Override public void resetMessageCounter() throws Exception { control.resetMessageCounter(); } @Override public String listMessageCounterAsHTML() throws Exception { return control.listMessageCounterAsHTML(); } @Override public String listMessageCounterHistory() throws Exception { return control.listMessageCounterHistory(); } @Override public String listMessageCounterHistoryAsHTML() throws Exception { return control.listMessageCounterHistoryAsHTML(); } @Override public void pause() throws Exception { control.pause(); } @Override public void resume() throws Exception { control.resume(); } @Override public String listConsumersAsJSON() throws Exception { return control.listConsumersAsJSON(); } @Override public String listScheduledMessagesAsJSON() throws Exception { return control.listScheduledMessagesAsJSON(); } @Override public String listDeliveringMessagesAsJSON() throws Exception { return control.listDeliveringMessagesAsJSON(); } } to { @Override public QueueControl getDelegate(){ return control; } @Override public String listMessagesAsJSON( String filter) throws Exception { String result=control.listMessagesAsJSON(convertToActiveMQFilterString(filter)); return convertToJMSProperties(result); } @Override public long countMessages( String filter) throws Exception { return control.countMessages(convertToActiveMQFilterString(filter)); } @Override public boolean removeMessage( ModelNode id) throws Exception { int n=control.removeMessages(createFilterForJMSMessageID(id)); return n == 1; } @Override public int removeMessages( String filter) throws Exception { return control.removeMessages(convertToActiveMQFilterString(filter)); } @Override public int expireMessages( String filter) throws Exception { return control.expireMessages(convertToActiveMQFilterString(filter)); } @Override public boolean expireMessage( ModelNode id) throws Exception { int n=control.expireMessages(createFilterForJMSMessageID(id)); return n == 1; } @Override public boolean sendMessageToDeadLetterAddress( ModelNode id) throws Exception { int n=control.sendMessagesToDeadLetterAddress(createFilterForJMSMessageID(id)); return n == 1; } @Override public int sendMessagesToDeadLetterAddress( String filter) throws Exception { return control.sendMessagesToDeadLetterAddress(convertToActiveMQFilterString(filter)); } @Override public boolean changeMessagePriority( ModelNode id, int priority) throws Exception { int n=control.changeMessagesPriority(createFilterForJMSMessageID(id),priority); return n == 1; } @Override public int changeMessagesPriority( String filter, int priority) throws Exception { return control.changeMessagesPriority(convertToActiveMQFilterString(filter),priority); } @Override public boolean moveMessage( ModelNode id, String otherQueue) throws Exception { int n=control.moveMessages(createFilterForJMSMessageID(id),otherQueue); return n == 1; } @Override public boolean moveMessage( ModelNode id, String otherQueue, boolean rejectDuplicates) throws Exception { int n=control.moveMessages(createFilterForJMSMessageID(id),otherQueue,rejectDuplicates); return n == 1; } @Override public int moveMessages( String filter, String otherQueue) throws Exception { return control.moveMessages(convertToActiveMQFilterString(filter),otherQueue); } @Override public int moveMessages( String filter, String otherQueue, boolean rejectDuplicates) throws Exception { return control.moveMessages(convertToActiveMQFilterString(filter),otherQueue,rejectDuplicates); } @Override public String listMessageCounter() throws Exception { return control.listMessageCounter(); } @Override public void resetMessageCounter() throws Exception { control.resetMessageCounter(); } @Override public String listMessageCounterAsHTML() throws Exception { return control.listMessageCounterAsHTML(); } @Override public String listMessageCounterHistory() throws Exception { return control.listMessageCounterHistory(); } @Override public String listMessageCounterHistoryAsHTML() throws Exception { return control.listMessageCounterHistoryAsHTML(); } @Override public void pause() throws Exception { control.pause(); } @Override public void resume() throws Exception { control.resume(); } @Override public String listConsumersAsJSON() throws Exception { return control.listConsumersAsJSON(); } @Override public String listScheduledMessagesAsJSON() throws Exception { return control.listScheduledMessagesAsJSON(); } @Override public String listDeliveringMessagesAsJSON() throws Exception { return control.listDeliveringMessagesAsJSON(); } private String createFilterForJMSMessageID( ModelNode id){ return "AMQUserID='" + id.asString() + "'"; } private String convertToJMSProperties( String text){ return text.replaceAll("priority","JMSPriority").replaceAll("timestamp","JMSTimestamp").replaceAll("expiration","JMSExpiration").replaceAll("durable","JMSDeliveryMode").replaceAll("userID","JMSMessageID"); } }