org.yamcs.artemis

Class ArtemisCommandQueueManagement

java.lang.Object

org.yamcs.artemis.ArtemisCommandQueueManagement

All Implemented Interfaces:

CommandQueueListener

public class ArtemisCommandQueueManagement
extends Object
implements CommandQueueListener

allows controlling command queues via hornet

Author:

nm

Constructor Summary

Constructors

Constructor and Description
ArtemisCommandQueueManagement(ManagementService managementService)

Method Summary

Modifier and Type	Method and Description
void	commandAdded(CommandQueue q, PreparedCommand pc) sends a "commandAdded" event
void	commandRejected(CommandQueue q, PreparedCommand pc) sends a "commandRejected" event
void	commandSent(CommandQueue q, PreparedCommand pc) sends a "commandSent" event
void	stop()
void	updateQueue(CommandQueue queue)

Methods inherited from class java.lang.Object

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

Constructor Detail

ArtemisCommandQueueManagement

public ArtemisCommandQueueManagement(ManagementService managementService)
                              throws YamcsApiException,
                                     org.apache.activemq.artemis.api.core.ActiveMQException

Throws:

YamcsApiException

org.apache.activemq.artemis.api.core.ActiveMQException

Method Detail

commandAdded

public void commandAdded(CommandQueue q,
                         PreparedCommand pc)

sends a "commandAdded" event

Specified by:

commandAdded in interface CommandQueueListener

commandRejected

public void commandRejected(CommandQueue q,
                            PreparedCommand pc)

sends a "commandRejected" event

Specified by:

commandRejected in interface CommandQueueListener

commandSent

public void commandSent(CommandQueue q,
                        PreparedCommand pc)

sends a "commandSent" event

Specified by:

commandSent in interface CommandQueueListener

updateQueue

public void updateQueue(CommandQueue queue)

Specified by:

updateQueue in interface CommandQueueListener

stop

public void stop()