org.miloss.fgsms.agentcore

Class MessageProcessorAdapter

java.lang.Object

org.miloss.fgsms.agentcore.MessageProcessorAdapter

All Implemented Interfaces:

MessageProcessorAdapterMBean

public class MessageProcessorAdapter
extends Object
implements MessageProcessorAdapterMBean

Provides an implementation that exposes message processor functionality via JMX

Author:

AO

Constructor Summary

Constructors

Constructor and Description
MessageProcessorAdapter()

Method Summary

Methods

Modifier and Type	Method and Description
void	Abort()
void	ForceNewDataPusherThread()
String	GetLastErrorMessage()
int	GetPolicyCache()
Long	GetProcessedMessageCount()
int	InternalMessageMapSize()
boolean	IsDependencyInjectionEnabled()
int	OutboundQueueSize()
void	PurgeMessageMap()
void	PurgeOutboundQueue()
void	PurgePolicyCache()
void	PurgeThreadMap()
void	PurgeURLMap()
void	RemoveDeadMessage()
int	ThreadMapSize()
int	URLMappingCacheSize()

Methods inherited from class java.lang.Object

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

Constructor Detail

MessageProcessorAdapter

public MessageProcessorAdapter()

Method Detail

RemoveDeadMessage

public void RemoveDeadMessage()

Specified by:

RemoveDeadMessage in interface MessageProcessorAdapterMBean

Abort

public void Abort()

Specified by:

Abort in interface MessageProcessorAdapterMBean

GetPolicyCache

public int GetPolicyCache()

Specified by:

GetPolicyCache in interface MessageProcessorAdapterMBean

OutboundQueueSize

public int OutboundQueueSize()

Specified by:

OutboundQueueSize in interface MessageProcessorAdapterMBean

InternalMessageMapSize

public int InternalMessageMapSize()

Specified by:

InternalMessageMapSize in interface MessageProcessorAdapterMBean

PurgePolicyCache

public void PurgePolicyCache()

Specified by:

PurgePolicyCache in interface MessageProcessorAdapterMBean

PurgeOutboundQueue

public void PurgeOutboundQueue()

Specified by:

PurgeOutboundQueue in interface MessageProcessorAdapterMBean

PurgeMessageMap

public void PurgeMessageMap()

Specified by:

PurgeMessageMap in interface MessageProcessorAdapterMBean

ForceNewDataPusherThread

public void ForceNewDataPusherThread()

Specified by:

ForceNewDataPusherThread in interface MessageProcessorAdapterMBean

IsDependencyInjectionEnabled

public boolean IsDependencyInjectionEnabled()

Specified by:

IsDependencyInjectionEnabled in interface MessageProcessorAdapterMBean

ThreadMapSize

public int ThreadMapSize()

Specified by:

ThreadMapSize in interface MessageProcessorAdapterMBean

PurgeThreadMap

public void PurgeThreadMap()

Specified by:

PurgeThreadMap in interface MessageProcessorAdapterMBean

GetLastErrorMessage

public String GetLastErrorMessage()

Specified by:

GetLastErrorMessage in interface MessageProcessorAdapterMBean

GetProcessedMessageCount

public Long GetProcessedMessageCount()

Specified by:

GetProcessedMessageCount in interface MessageProcessorAdapterMBean

URLMappingCacheSize

public int URLMappingCacheSize()

Specified by:

URLMappingCacheSize in interface MessageProcessorAdapterMBean

PurgeURLMap

public void PurgeURLMap()

Specified by:

PurgeURLMap in interface MessageProcessorAdapterMBean