org.codice.ddf.broker.ui

Class UndeliveredMessages

java.lang.Object

org.codice.ddf.broker.ui.UndeliveredMessages

All Implemented Interfaces:

UndeliveredMessagesMBean

public class UndeliveredMessages
extends Object
implements UndeliveredMessagesMBean

Constructor Summary

Constructors

Constructor and Description
UndeliveredMessages(MBeanServer mBeanServer)

Method Summary

Modifier and Type	Method and Description
long	deleteMessages(String address, String queue, List<String> messageIds) Deletes messages from a queue/topic given its address, module and list of message ids of the messages to delete.
void	destroy()
List<CompositeData>	getMessages(String address, String queue) Gets messages from a queue/topic given its address and module.
void	init()
long	messageOperation(String operationName, String address, String queue, List<String> messageId)
long	resendMessages(String address, String queue, List<String> messageIds) Resends messages from a queue/topic given its address, module and list of message ids of the messages to resend.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

UndeliveredMessages

public UndeliveredMessages(MBeanServer mBeanServer)

Method Detail

getMessages

public List<CompositeData> getMessages(String address,
                                       String queue)

Description copied from interface: UndeliveredMessagesMBean

Gets messages from a queue/topic given its address and module.

Specified by:

getMessages in interface UndeliveredMessagesMBean

Parameters:

address - Address name of the queue/topic

queue - Queue name of the queue/topic

Returns:

List of messages in the form of CompositeData

resendMessages

public long resendMessages(String address,
                           String queue,
                           List<String> messageIds)

Description copied from interface: UndeliveredMessagesMBean

Resends messages from a queue/topic given its address, module and list of message ids of the messages to resend.

Specified by:

resendMessages in interface UndeliveredMessagesMBean

Parameters:

address - Address name of the queue/topic

queue - Queue name of the queue/topic

messageIds - List of message ids of each message to resend

Returns:

The number of messages that are resent

deleteMessages

public long deleteMessages(String address,
                           String queue,
                           List<String> messageIds)

Description copied from interface: UndeliveredMessagesMBean

Deletes messages from a queue/topic given its address, module and list of message ids of the messages to delete.

Specified by:

deleteMessages in interface UndeliveredMessagesMBean

Parameters:

address - Address name of the queue/topic

queue - Queue name of the queue/topic

messageIds - List of message ids of each message to delete

Returns:

The number of messages that are deleted

messageOperation

public long messageOperation(String operationName,
                             String address,
                             String queue,
                             List<String> messageId)

init

public void init()

destroy

public void destroy()